Hi,
I have a stand alone ActiveMQ Broker, the client's connection that I use is
as follows:
tcp://hostname:61616?jms.redeliveryPolicy.maximumRedeliveries=-1&jms.redeliveryPolicy.backOffMultiplier=1&jms.prefetchPolicy.durableTopicPrefetch=3000
When moving to a Master / Failover scenario, I have used the failover
transport as follows:
failover://(tcp://hostname:61615?jms.redeliveryPolicy.maximumRedeliveries=-1&jms.redeliveryPolicy.backOffMultiplier=1&jms.prefetchPolicy.durableTopicPrefetch=3000,tcp://slaveHostname:61615?jms.redeliveryPolicy.maximumRedeliveries=-1&jms.redeliveryPolicy.backOffMultiplier=1&jms.prefetchPolicy.durableTopicPrefetch=3000)?randomize=false
However when starting my application, the following exception is thrown:
javax.jms.JMSException: Could not create Transport. Reason:
java.io.IOException: Invalid location: failover://hostname:61615
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:35)
at
org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:242)
at
org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:255)
at
org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(ActiveMQConnectionFactory.java:212)
at
com.detica.analyzer.EnterpriseCollectionIndexManager.(EnterpriseCollectionIndexManager.java:364)
at
com.detica.analyzer.EnterpriseIndexServer.addCollectionIndexManager(EnterpriseIndexServer.java:1050)
at
com.detica.analyzer.EnterpriseIndexServer.access$14(EnterpriseIndexServer.java:1015)
at
com.detica.analyzer.EnterpriseIndexServer$CollectionUpdateTask.run(EnterpriseIndexServer.java:761)
at java.util.TimerThread.mainLoop(Timer.java:512)
at java.util.TimerThread.run(Timer.java:462)
Caused by: java.io.IOException: Invalid location: failover://hostname:61615
at
org.apache.activemq.transport.failover.FailoverTransportFactory.doConnect(FailoverTransportFactory.java:42)
at
org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:51)
at
org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:80)
at
org.apache.activemq.ActiveMQConnectionFactory.createTransport(ActiveMQConnectionFactory.java:240)
... 8 more
When I use a failover transport without any additional parameters as shown
below, no exceptions are thrown.
failover://(tcp://hostname:61615,tcp://slaveHostname:61615)?randomize=false
How do I add additional parameters to the connection string when using the
failover transport?
Thank you,
Ali
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Failover-URL-problems-tp3428623p3428623.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
