activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "pleaseHelpMe:o)" <jason.m.brews...@gmail.com>
Subject Re: Networking help, not working for me....
Date Wed, 11 Jun 2008 12:19:07 GMT

I upgraded my client libraries, but couldn't get past this error.  Will try
again tonight, maybe i missed something.  Shouldn't i really just need the
library that contains this, and not have to modify old client code?

JB


rajdavies wrote:
> 
> ok - looks like a version mismatch - can you upgrade your clients too ?
> On 11 Jun 2008, at 02:04, pleaseHelpMe:o) wrote:
> 
>>
>> I upgraded to 5.1, now my client reports this and won't connect.  Will
>> investigate, but if anybody knows this error, please advise.
>>
>> Exception in thread "ActiveMQ Transport: tcp:///192.168.1.101:61616"
>> java.lang.IllegalArgumentException: Invalid version: 3, could not load
>> org.apache.activemq.openwire.v3.MarshallerFactory
>> 	at
>> org
>> .apache
>> .activemq.openwire.OpenWireFormat.setVersion(OpenWireFormat.java:329)
>> 	at
>> org
>> .apache
>> .activemq
>> .openwire.OpenWireFormat.renegociatWireFormat(OpenWireFormat.java:569)
>> 	at
>> org
>> .apache
>> .activemq
>> .transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java: 
>> 108)
>> 	at
>> org 
>> .apache 
>> .activemq 
>> .transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
>> 	at
>> org 
>> .apache 
>> .activemq.transport.TransportSupport.doConsume(TransportSupport.java: 
>> 87)
>> 	at
>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java: 
>> 127)
>> 	at java.lang.Thread.run(Thread.java:595)
>> Caused by: java.lang.ClassNotFoundException:
>> org.apache.activemq.openwire.v3.MarshallerFactory
>> 	at  
>> org.apache.activemq.util.ClassLoading.loadClass(ClassLoading.java:104)
>> 	at
>> org 
>> .apache 
>> .activemq.openwire.OpenWireFormat.setVersion(OpenWireFormat.java:327)
>> 	... 6 more
>>
>>
>>
>> rajdavies wrote:
>>>
>>> Hi Jason,
>>>
>>> this will work on ActiveMQ 5.x - I suggest you upgrade
>>>
>>> cheers,
>>>
>>> Rob
>>>
>>> On 10 Jun 2008, at 03:58, pleaseHelpMe:o)  
>>> <jason.m.brewster@gmail.com>
>>> wrote:
>>>
>>>>
>>>> I tried this but no luck, is it the way my client connects to
>>>> broker1, then
>>>> if broker1 dies, the client disconnects?
>>>>
>>>> <networkConnector name="jason cluster"
>>>> uri="static://(tcp://localhost:61617,tcp://localhost:61618)"
>>>> failover="true"
>>>> dynamicOnly="true" networkTTL="3"/>
>>>>
>>>> Should this mean that if broker1 dies, broker2 takes over, so if the
>>>> client
>>>> is connected to broker1, he auto connects over to broker2, thus the
>>>> client
>>>> stays connected?
>>>>
>>>> I have been searching for an example of how to do this, but no luck,
>>>> can
>>>> somebody tell me if my logic is good or bad, and where I can find an
>>>> example
>>>> of doing what I am trying to do?  Surely it can't be this hard to
>>>> setup to
>>>> work properly, so I must have something configured wrong, and don't
>>>> know
>>>> what it is?
>>>>
>>>> JB
>>>>
>>>>
>>>>
>>>>
>>>> pleaseHelpMe:o) wrote:
>>>>>
>>>>> What is the syntax for that option to configure?
>>>>>
>>>>> JB
>>>>>
>>>>> navneek wrote:
>>>>>>
>>>>>> Hi,
>>>>>>
>>>>>> It seems you missed to configure DynamicallyIncludedDestination
>>>>>> attribute
>>>>>> in your network connector configuration.
>>>>>> Add this attribute and try again.
>>>>>>
>>>>>> regds
>>>>>> Nava.
>>>>>>
>>>>>> pleaseHelpMe:o) wrote:
>>>>>>>
>>>>>>> Here is the setup:
>>>>>>> ActiveMQ 4.0.2 (I know it's old, but need to try to get it  
>>>>>>> working
>>>>>>> before upgrading, seems backwards logic, but short on time)
>>>>>>>
>>>>>>> 4 brokers running locally on a Windows machine, Java code
>>>>>>> connecting to
>>>>>>> brokers, i.e. connect to transport with this code from java:
>>>>>>> props.setProperty(Context.PROVIDER_URL,"tcp://localhost:61616");
>>>>>>> this connection works great and everything is fine, but I want
to
>>>>>>> provide redundancy if this connection were to fail, so I am 

>>>>>>> trying
>>>>>>> this.....
>>>>>>>
>>>>>>> in xml config for brokers, I want to provide a network of brokers
>>>>>>> that
>>>>>>> can work as a cluster, or will work if 1 fails.  My preference
>>>>>>> would be
>>>>>>> to randomly connect to 1 of the brokers in the network, and
>>>>>>> failover to
>>>>>>> any other 1 if possible.  It appears I have hardcoded connection
>>>>>>> to this
>>>>>>> 1, so not sure how to randomly connect, unless I modify my java
>>>>>>> code to
>>>>>>> randomly connect (is this the best approach?).
>>>>>>>
>>>>>>> When I do connect to the 61616 port on localhost, I have  
>>>>>>> configured
>>>>>>> networkConnector to other ports statically.  My log shows this
 
>>>>>>> when
>>>>>>> starting up brokers.
>>>>>>> ACTIVEMQ_HOME: C:\DIVAS Snapshot\activemq-4.0.2 Broker1\bin\..
>>>>>>> Loading message broker from: xbean:activemq.xml
>>>>>>> INFO  BrokerService                  - ActiveMQ 4.0.2 JMS Message
>>>>>>> Broker
>>>>>>> (broker
>>>>>>> 1) is starting
>>>>>>> INFO  BrokerService                  - For help or more  
>>>>>>> information
>>>>>>> please see:
>>>>>>> http://incubator.apache.org/activemq/
>>>>>>> INFO  TransportServerThreadSupport   - Listening for connections
>>>>>>> at:
>>>>>>> tcp://MAVS0
>>>>>>> 1:61616?connectionTimeout=0
>>>>>>> INFO  TransportConnector             - Connector default Started
>>>>>>> INFO  NetworkConnector               - Establishing network
>>>>>>> connection
>>>>>>> between f
>>>>>>> rom vm://broker1?network=true to
>>>>>>> failover:(tcp://localhost:61617)?maxReconnectDelay
>>>>>>> =1000
>>>>>>> INFO  TransportConnector             - Connector vm://broker1
>>>>>>> Started
>>>>>>> INFO  NetworkConnector               - Establishing network
>>>>>>> connection
>>>>>>> between f
>>>>>>> rom vm://broker1?network=true to
>>>>>>> failover:(tcp://localhost:61618)?maxReconnectDelay
>>>>>>> =1000
>>>>>>> INFO  NetworkConnector               - Establishing network
>>>>>>> connection
>>>>>>> between f
>>>>>>> rom vm://broker1?network=true to
>>>>>>> failover:(tcp://localhost:61619)?maxReconnectDelay
>>>>>>> =1000
>>>>>>> INFO  NetworkConnector               - Network Connector host1
>>>>>>> and host2
>>>>>>> and hos
>>>>>>> t3 and host4 and host5 and host6 and host7 Started
>>>>>>> INFO  BrokerService                  - ActiveMQ JMS Message 

>>>>>>> Broker
>>>>>>> (broker1, ID:
>>>>>>> localhost-3643-1212949248389-0:0) started
>>>>>>> INFO  DemandForwardingBridge         - Network connection between
>>>>>>> vm://broker1#0
>>>>>>> and tcp://localhost:61617(broker2) has been established.
>>>>>>> INFO  DemandForwardingBridge         - Network connection between
>>>>>>> vm://broker1#4
>>>>>>> and tcp://localhost:61619(broker4) has been established.
>>>>>>> INFO  DemandForwardingBridge         - Network connection between
>>>>>>> vm://broker1#2
>>>>>>> and tcp://localhost:61618(Unknown) has been established.
>>>>>>>
>>>>>>> So it appears connections seem good, but....if I kill broker1,
my
>>>>>>> java
>>>>>>> client reports The session is closed.  Below is my config file,
>>>>>>> anything
>>>>>>> I am missing with this logic or implementation?
>>>>>>>
>>>>>>> <transportConnector name="default"
>>>>>>> uri="tcp://localhost:61616?connectionTimeout=0" />
>>>>>>>
>>>>>>> <networkConnector name="host1 and host2"
>>>>>>> uri="static://(tcp://localhost:61617,tcp://localhost:61618"
>>>>>>> failover="true"/>
>>>>>>>
>>>>>>>
>>>>>>> Any help would be greatly appreciated, I am trying to run a test
>>>>>>> where I
>>>>>>> close broker1, and broker 2 will maintain the connection to the
>>>>>>> client.
>>>>>>> I would also like to understand how to randomly connect to 1
or  
>>>>>>> the
>>>>>>> other from my client?  Do I do this in client code or is there
a
>>>>>>> way to
>>>>>>> configure it in ActiveMQ?
>>>>>>>
>>>>>>
>>>>>>
>>>>>
>>>>>
>>>>
>>>> -- 
>>>> View this message in context:
>>>> http://www.nabble.com/Networking-help%2C-not-working-for-me....-tp17721624p17746763.html
>>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>>
>>>
>>>
>>>
>>
>> -- 
>> View this message in context:
>> http://www.nabble.com/Networking-help%2C-not-working-for-me....-tp17721624p17768019.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Networking-help%2C-not-working-for-me....-tp17721624p17776191.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message