How To

Hello World for AMQ interconnect

December 4, 2019
Developer Tools

Install an AMQ interconnect router

AMQ interconnect 1.10 is distributed as a set of RPM packages, which are available through your Red Hat subscription. To get these packages:

  1. Ensure that your subscription has been activated and your system is registered. For more information on using the customer portal to activate your Red Hat subscription and register your system for packages, see Using Your Subscription.

  2. Subscribe to the required repositories:

    Red Hat Enterprise Linux 7

    $ sudo subscription-manager repos --enable=amq-interconnect-1-for-rhel-7-server-rpms --enable=amq-clients-2-for-rhel-7-server-rpms

    Red Hat Enterprise Linux 8

    $ sudo subscription-manager repos --enable=amq-interconnect-1-for-rhel-8-x86_64-rpms --enable=amq-clients-2-for-rhel-8-x86_64-rpms

  3. Use the yum or dnf command to install the qpid-proton-c and python-qpid-proton packages.

    $ sudo yum install qpid-proton-c python-qpid-proton python-qpid-proton-docs -y

    The AMQ interconnect packages depend on these Qpid Proton packages.

  4. Use the yum or dnf command to install the qpid-dispatch-router and qpid-dispatch-tools packages.

    $ sudo yum install qpid-dispatch-router qpid-dispatch-console qpid-dispatch-tools -y

  5. Use the which command to verify that the qdrouterd executable is present.

    $ which qdrouterd

The qdrouterd executable should be located at /usr/sbin/qdrouterd.

Start the router service

  1. To start the router with the default configuration, do one of the following:
     
    • To run the router as a service in Red Hat Enterprise Linux, enter the command:

      $ sudo systemctl start qdrouterd.service
       
    • To run the router as a daemon, enter the command:

      $ qdrouterd -d

      Note: To start the router in the foreground, do not use the -d parameter.

    • View the log to verify the router status.

      $ qdstat --log

Send and receive messages

Before you send and receive messages, you first need to start the receiver client.

Starting the Python receiver client

To start the receiver by using the Python receiver client, navigate to the Python examples directory (for example, /usr/share/proton/) and run the simple_recv.py example.

$ cd <install_dir>/examples/python/
$ python simple_recv.py -a 127.0.0.1:5672/examples -m 5

This command starts the receiver and listens on the default address (127.0.0.1:5672/examples). The receiver is also set to receive a maximum of five messages.

Sending messages

After starting the receiver client, you can send messages from the sender, which then travel through the router to the receiver. In a new terminal window, navigate to the Python examples directory and run the simple_send.py example:

$ cd <install_dir>/examples/python/
$ python simple_send.py -a 127.0.0.1:5672/examples -m 5

This command sends five auto-generated messages to the default address (127.0.0.1:5672/examples) then confirms that they were delivered and acknowledged by the receiver:

all messages confirmed

The receiver client receives the messages and displays their content:

{u'sequence': int32(1)}
{u'sequence': int32(2)}
{u'sequence': int32(3)}
{u'sequence': int32(4)}
{u'sequence': int32(5)}

You just sent and received messages via Red Hat A­MQ interconnect. Visit frequently to view more tutorials and other topics around A­MQ.

Last updated: February 25, 2021

Comments