fix timing issue with stomp client and tx publishing

Author: mbuckton

src/main/java/io/mapsmessaging/network/protocol/impl/stomp/listener/SendListener.java

@@ -40,6 +40,6 @@ protected void processEvent(SessionState engine, Event event, Message message) t
         throw new RuntimeException(e);
       }
       return destination;
-    });
+    }).join();
   }
 }

src/test/java/io/mapsmessaging/network/protocol/impl/stomp/StompPublishEventTest.java

@@ -117,6 +117,7 @@ void testTransactionalPublishContentLength() throws Exception {
         start = stompSubscriber.counter.get();
       }
     }
+    Assertions.assertEquals(10, stompSubscriber.counter.get());
 
     stompConnection.begin("tx2");
     for (int x = 0; x < 100; x++) {
@@ -160,7 +161,7 @@ public StompSubscriber(String topicName, String hostname, int port, String usern
       stompConnection.open(hostname, port );
       stompConnection.connect(username, getPassword(username), "client-subscribe");
       headers = new HashMap<>();
-      headers.put("id", "client-subscribe/"+topicName);
+      headers.put("id", topicName);
       stompConnection.subscribe(topicName, "client-individual", headers);
       Thread t = new Thread(this);
       t.start();
@@ -180,12 +181,13 @@ public void run() {
       while (!end.get()) {
         try {
           try {
-            StompFrame stompFrame = stompConnection.receive(100);
+            StompFrame stompFrame = stompConnection.receive(1000);
             if (stompFrame.isMessage()) {
                 stompConnection.ack(stompFrame);
             }
             counter.incrementAndGet();
           } catch (SocketTimeoutException e) {
+            System.err.println("SocketTimeoutException");
             // ignore
           }
         } catch (Exception e) {