diff --git a/hornetq/HornetQ_Spring-master.zip b/hornetq/HornetQ_Spring-master.zip new file mode 100644 index 0000000..2d37ce1 Binary files /dev/null and b/hornetq/HornetQ_Spring-master.zip differ diff --git a/src/main/java/jennom/hot/AppContext.java b/src/main/java/jennom/hot/AppContext.java index 239e9ad..ea6fd23 100644 --- a/src/main/java/jennom/hot/AppContext.java +++ b/src/main/java/jennom/hot/AppContext.java @@ -18,6 +18,7 @@ import javax.jms.Topic; import jennom.jms.JmsExceptionListener; import org.hornetq.api.jms.HornetQJMSClient; +import org.hornetq.api.jms.JMSFactoryType; import org.hornetq.jms.client.HornetQTopic; import org.springframework.core.task.SimpleAsyncTaskExecutor; import org.springframework.core.task.TaskExecutor; @@ -66,7 +67,8 @@ private ConnectionFactory createJmsConnectionFactory(JmsExceptionListener jmsExc TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName(), connDetails); // HornetQJMSConnectionFactory(boolean ha, TransportConfiguration[] initialConnectors) - ConnectionFactory hornetCF = new HornetQJMSConnectionFactory(false, transportConfiguration); + //ConnectionFactory hornetCF = new HornetQJMSConnectionFactory(false, transportConfiguration); + ConnectionFactory hornetCF = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.QUEUE_CF, transportConfiguration); UserCredentialsConnectionFactoryAdapter userCF = new UserCredentialsConnectionFactoryAdapter(); userCF.setTargetConnectionFactory(hornetCF); userCF.setUsername("romka");