activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ajb <alistairjbast...@gmail.com>
Subject ActiveMQ Failover URL problems
Date Tue, 05 Apr 2011 17:01:38 GMT
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.

Mime
View raw message