Chapter 2. Getting started

Procedure

1. Log in as a messaging tenant:

   oc login -u developer

2. Create the project for the messaging application:

   oc new-project myapp

3. Create an address space definition:

   apiVersion: enmasse.io/v1beta1
   kind: AddressSpace
   metadata:
     name: myspace
   spec:
     type: standard
     plan: standard-unlimited

4. Create the address space:

   oc create -f standard-address-space.yaml

5. Check the status of the address space:

   oc get addressspace myspace -o jsonpath={.status.isReady}

   The address space is ready for use when the previous command outputs true.

Procedure

1. Create an address definition:

   apiVersion: enmasse.io/v1beta1
   kind: Address
   metadata:
       name: myspace.myqueue
   spec:
       address: myqueue
       type: queue
       plan: standard-small-queue

   Note

   Prefixing the name with the address space name is required to ensure addresses from different address spaces do not collide.

2. Create the address:

   oc create -f standard-small-queue.yaml

3. List the addresses:

   oc get addresses -o yaml

Procedure

1. To correctly base64 encode a password for the user definition file, run the following command:

   echo -n password | base64 #cGFzc3dvcmQ=

   Note

   Be sure to use the -n parameter when running this command. Not specifying that parameter will result in an improperly coded password and cause log-in issues.

2. Save the user definition to a file:

   apiVersion: user.enmasse.io/v1beta1
   kind: MessagingUser
   metadata:
     name: myspace.user1
   spec:
     username: user1
     authentication:
       type: password
       password: cGFzc3dvcmQ= # Base64 encoded
     authorization:
       - addresses: ["myqueue", "queue1", "queue2", "topic*"]
         operations: ["send", "recv"]
       - addresses: ["anycast1"]
         operations: ["send"]

3. Create the user and associated user permissions:

   oc create -f user-example1.yaml

4. Confirm that the user was created:

   oc get messagingusers

Procedure

1. Save Python client example to a file:

   from __future__ import print_function, unicode_literals
   import optparse
   from proton import Message
   from proton.handlers import MessagingHandler
   from proton.reactor import Container
   
   class HelloWorld(MessagingHandler):
       def __init__(self, url):
           super(HelloWorld, self).__init__()
           self.url = url
   
       def on_start(self, event):
           event.container.create_receiver(self.url)
           event.container.create_sender(self.url)
   
       def on_sendable(self, event):
           event.sender.send(Message(body="Hello World!"))
           event.sender.close()
   
       def on_message(self, event):
           print("Received: " + event.message.body)
           event.connection.close()
   
   parser = optparse.OptionParser(usage="usage: %prog [options]")
   parser.add_option("-u", "--url", default="amqps://localhost:5672/myqueue",
                     help="url to use for sending and receiving messages")
   opts, args = parser.parse_args()
   
   try:
       Container(HelloWorld(opts.url)).run()
   except KeyboardInterrupt: pass

2. Retrieve the address space messaging endpoint host name:

   oc get addressspace myspace -o 'jsonpath={.status.endpointStatuses[?(@.name=="messaging")].externalHost}'

   Use the output as the host name in the following step.

3. Run the client:

   python client-example1.py -u amqps://user1:password@messaging.example1.com:443/myqueue