HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType....

harp077 · Nov 23, 2021 · 17d00a2 · 17d00a2
1 parent 22cde47
commit 17d00a2
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/hornetq/HornetQ_Spring-master.zip b/hornetq/HornetQ_Spring-master.zip
diff --git 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");