On 6.1.0, the asynchronous receiver below doesn't wait a message and stops soon after had connected to swiftmq without an exception. I confirmed this waited a message on 5.2.6.

			

			import java.util.Hashtable;
			

			import javax.jms.*;
			

			import javax.naming.Context;
			

			import javax.naming.InitialContext;
			

			

			public class TestReceiver implements MessageListener, ExceptionListener {
			

			

			TestReceiver() throws Exception {
			

			Hashtable env = new Hashtable();
			

			env.put(Context.INITIAL_CONTEXT_FACTORY,
			

			"com.swiftmq.jndi.InitialContextFactoryImpl");
			

			env.put(Context.PROVIDER_URL, "smqp://localhost:8900/timeout=10000"); // update port num to 8900
			

			Context jndiContext = new InitialContext(env);
			

			TopicConnectionFactory factory = (TopicConnectionFactory) jndiContext
			

			.lookup("TopicConnectionFactory");
			

			TopicConnection connection = factory.createTopicConnection();
			

			TopicSubscriber subscriber = connection.createTopicSession(false,
			

			Session.AUTO_ACKNOWLEDGE).createSubscriber(
			

			(Topic) jndiContext.lookup("TestTopic"));
			

			subscriber.setMessageListener(this);
			

			connection.start();
			

			}
			

			

			public void onMessage(Message message) {
			

			try {
			

			System.out.println(
			

			"----- message received:["
			

			+ message.getJMSMessageID()
			

			+ "]  -----");
			

			} catch (Exception e) {
			

			e.printStackTrace();
			

			}
			

			}
			

			

			public void onException(JMSException exception) {
			

			exception.printStackTrace();
			

			System.out.println("--- LinkedException ---");
			

			exception.getLinkedException().printStackTrace();
			

			}
			

			

			public static void main(String[] args) {
			

			try {
			

			new TestReceiver();
			

			} catch (Exception e) {
			

			e.printStackTrace();
			

			}
			

			}
			

			}