Update to code. Is there way to create JMS resource dynamically with a managed Glassfish server? No. The only way is to manually administer GlassFish with the required JMS resources at the command line or use the Admin UI web interface. #2

Author: Peter Pilgrim

ch09/jms-async/src/main/java/je7hb/jms/async/PayloadCheckAsync.java

@@ -48,10 +48,9 @@ public class PayloadCheckAsync {
     private CompletionListener completionListener = new CompletionListener() {
         @Override
         public void onCompletion(Message msg) {
-            TextMessage textMsg = (TextMessage)msg;
+            final TextMessage textMsg = (TextMessage)msg;
             try {
-                System.out.printf("%s.onCompletion(%s) Thread: %s\n",
-                        getClass().getSimpleName(), textMsg.getText(), Thread.currentThread());
+                System.out.printf("***** %s.onCompletion(%s) Thread: %s\n", getClass().getSimpleName(), textMsg.getText(), Thread.currentThread());
                 messages.add(textMsg.getText());
             } catch (JMSException e) {
                 e.printStackTrace(System.err);
@@ -65,9 +64,8 @@ public void onException(Message msg, Exception ex) {
     };
 
     public void sendPayloadMessage( String payload ) {
-        System.out.printf("%s.sendPayloadMessage(%s) Thread: %s\n",
-                getClass().getSimpleName(), payload, Thread.currentThread());
-        JMSProducer producer = context.createProducer();
+        System.out.printf("**** %s.sendPayloadMessage(%s) Thread: %s\n", getClass().getSimpleName(), payload, Thread.currentThread());
+        final JMSProducer producer = context.createProducer();
         producer.setAsync(completionListener);
         context.createProducer().send(inboundQueue, payload);
     }

ch09/jms-async/src/test/java/je7hb/jms/async/PayloadCheckAsyncTest.java

@@ -115,6 +115,8 @@ public void shouldFireMessageAsynchronously() throws Exception {
         producer.send(queue, "world");
         producer.send(queue, "asynchronously");
 
+        System.out.println(".... waiting ...");
+
         Thread.sleep(2000);
 
         System.out.println("Done");