Java Reference
In-Depth Information
public static final String BOOKING_QUEUE = "java:global/
jms/bookingQueue ";
Then, in BookingQueueReceiver , you can just change propertyValue =
"java:jboss/jms/queue/ticketQueue" to propertyValue = Book-
ingQueueDefinition.BOOKING_QUEUE .
Adding the JMS producer
Once we're done with the JMS consumer, we need a component that will take care of
sending JMS messages. For this purpose, we will add an Application Scoped CDI Bean,
say BookingQueueProducer , which gets injected in the JMS resources:
package com.packtpub.wflydevelopment.chapter6.jms;
import javax.annotation.Resource;
import javax.enterprise.context.RequestScoped;
import javax.inject.Inject;
import javax.jms.JMSContext;
import javax.jms.Queue;
public class BookingQueueProducer {
private JMSContext context;
@Resource(mappedName =
private Queue syncQueue;
public void sendMessage(String txt) {
context.createProducer().send(syncQueue, txt);
This might be a bit shocking for those who have used the previous versions of the JMS.
For those who haven't, in the following code we present this code's equivalent in JMS 1.1:
Search WWH ::

Custom Search