activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Nakarikanti, Nageswara" <NNakarika...@dwd.IN.gov>
Subject RE: ActiveMQ Failover URL problems
Date Tue, 05 Apr 2011 17:14:48 GMT
 
I see your additional parameters were same on both ActiveMQs, Try using them besides 'randomize=false'


i.e. after you apecify your activemq machines...

I am not sure but give a try.

-Nag.
-----Original Message-----
From: ajb [mailto:alistairjbastian@gmail.com] 
Sent: Tuesday, April 05, 2011 1:02 PM
To: users@activemq.apache.org
Subject: ActiveMQ Failover URL problems

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