Chapter 6. Using MRG Messaging with Java JMS

6.1. Java JMS Client Compatibility and Interoperability

6.2. Creating and Closing Connections and Sessions with JNDI

6.2.1. Basic JNDI Programming for MRG Messaging
6.2.2. JNDI Properties for MRG Messaging
6.2.3. Connection URLs
6.2.4. Binding URLs

6.3. Creating and Closing Connections and Sessions with AMQP

6.4. Writing Direct Applications in Java JMS

6.4.1. Running the Direct Examples
6.4.2. JNDI Properties
6.4.3. Publishing Messages to a Queue
6.4.4. Reading Messages from the Queue with a Message Consumer
6.4.5. Reading Messages from the Queue using a Message Listener

6.5. Writing Fanout Applications in Java JMS

6.5.1. Running the Fanout Examples
6.5.2. JNDI Properties
6.5.3. Reading Messages from a Queue with a Message Consumer
6.5.4. Reading Messages from the Queue using a Message Listener
6.5.5. Publishing Messages to a Fanout Exchange

6.6. Writing Publish/Subscribe Applications in Java JMS

6.6.1. Running the Publish/Subscribe Examples
6.6.2. JNDI Properties
6.6.3. Publishing Messages to a Topic
6.6.4. Reading Messages from the Queue

6.7. Writing Request/Response Applications in Java JMS

6.7.1. JNDI Properties
6.7.2. Running the Request/Response Examples
6.7.3. Client
6.7.4. The Server

6.8. Durability and Persistence in Java JMS

6.9. Using Transactions in Java JMS

6.10. Logging in Java clients

This chapter shows how to write direct, publish/subscribe, and request/response programs in Java JMS. These paradigms are explained in Chapter 2, Examples Overview. It then shows how to use important features like persistence and transactions with MRG Messaging. Unlike Python and C++, Java has an established API standard for messaging called JMS (Java Message Service). This chapter does not attempt to teach JMS programming. We suggest that you look at the Java JMS Tutorial for an extensive tutorial on JMS.

This chapter focuses on using Java JMS that can work together with AMQP clients written in other languages, even if these other clients use features not directly supported in Java JMS. In general, we accomplish this by using JNDI (Java Naming and Directory Interface) to specify properties for configuring queues and bindings.

The instructions in this section assume you have installed the client libraries and started a broker using the instructions shown in Chapter 3, Installing MRG Messaging.

Running the Examples

The example code shown in this chapter is shipped as part of the rhm-docs package. Use rpm to see where this code is installed on your system:

$ rpm -qal rhm-docs

By default, these examples are placed in /usr/share/doc/rhm-0.2/java. There is a script in that directory that compiles and runs sample programs; it is called runSample.sh. This script takes the name of the class to be run as an argument, for example:

$ ./runSample.sh org.apache.qpid.example.jmsexample.direct.Producer

Run this script in a directory where you have write permission. You might need to copy the entire /usr/share/doc/rhm-0.2/java directory to a place where you can modify the code and create subdirectories as part of the compilation process. If you do not intend to modify the code, you can simply copy the script and run it from a directory where you have write privileges.