[#AMQ-1257] Pure Master/Slave configuration doesn't work - Apache ActiveMQ, Apache ServiceMix, Apache Camel

ActiveMQ

Pure Master/Slave configuration doesn't work

Created: 31/May/07 06:16 AM Updated: 23/Jul/07 12:51 AM

Return to search

Component/s:

Broker

Affects Version/s:

4.1.0

Fix Version/s:

5.0.0

Time Tracking:

Not Specified

Description

« Hide

From the discussion board. Please fix this issue as it is happening for us also and is a showstopper.

----------------------------------------------------------------------------------------------------------------------------------------------

Hi everybody,

I made this post:

http://www.nabble.com/Master-Slaver-persistent--t3681637s2354.html

in the user Forum. Now I looked myself in the source to find out the mistake. It seems that the method

protected void sendSyncToSlave(Command command){
try{

Response response=(Response) slave.request(command);
if (response.isException()){ ExceptionResponse er=(ExceptionResponse)response; log.error("Slave Failed",er.getException()); }

}catch(Throwable e){ log.error("Slave Failed",e); }
}

of the "org.apache.activemq.broker.ft.MasterBroker" will always throw an Exception. The next thing is that the method "sendAsyncToSlave" is called more than one time, if I just send one Message:

INFO MasterBroker - SendASync
INFO MasterBroker - SendASync
INFO MasterBroker - SendASync
INFO MasterBroker - SendASync
INFO MasterBroker - SendSync
ERROR MasterBroker - Slave Failed
java.lang.AssertionError: Unsupported Method
at org.apache.activemq.transport.TransportSupport.request(TransportSuppo
rt.java:71)
at org.apache.activemq.transport.TransportFilter.request(TransportFilter
.java:92)
at org.apache.activemq.transport.TransportFilter.request(TransportFilter
.java:92)
at org.apache.activemq.transport.MutexTransport.request(MutexTransport.j
ava:55)
at org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBrok
er.java:364)
at org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.j
ava:333)
at org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307
)
at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilt
er.java:136)
at org.apache.activemq.broker.TransportConnection.processMessage(Transpo
rtConnection.java:498)
at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.jav
a:604)
at org.apache.activemq.broker.TransportConnection.service(TransportConne
ction.java:294)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC
onnection.java:185)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt
er.java:68)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireForm
atNegotiator.java:133)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityM
onitor.java:122)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSup
port.java:84)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
137)
at java.lang.Thread.run(Thread.java:595)
INFO MasterBroker - SendASync
INFO MasterBroker - SendASync
INFO MasterBroker - SendASync
INFO MasterBroker - SendASync

Description

From the discussion board. Please fix this issue as it is happening for us also and is a showstopper. ---------------------------------------------------------------------------------------------------------------------------------------------- Hi everybody, I made this post: http://www.nabble.com/Master-Slaver-persistent--t3681637s2354.html in the user Forum. Now I looked myself in the source to find out the mistake. It seems that the method protected void sendSyncToSlave(Command command){ try{ Response response=(Response) slave.request(command); if (response.isException()){ ExceptionResponse er=(ExceptionResponse)response; log.error("Slave Failed",er.getException()); } }catch(Throwable e){ log.error("Slave Failed",e); } } of the "org.apache.activemq.broker.ft.MasterBroker" will always throw an Exception. The next thing is that the method "sendAsyncToSlave" is called more than one time, if I just send one Message: INFO MasterBroker - SendASync INFO MasterBroker - SendASync INFO MasterBroker - SendASync INFO MasterBroker - SendASync INFO MasterBroker - SendSync ERROR MasterBroker - Slave Failed java.lang.AssertionError: Unsupported Method at org.apache.activemq.transport.TransportSupport.request(TransportSuppo rt.java:71) at org.apache.activemq.transport.TransportFilter.request(TransportFilter .java:92) at org.apache.activemq.transport.TransportFilter.request(TransportFilter .java:92) at org.apache.activemq.transport.MutexTransport.request(MutexTransport.j ava:55) at org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBrok er.java:364) at org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.j ava:333) at org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307 ) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilt er.java:136) at org.apache.activemq.broker.TransportConnection.processMessage(Transpo rtConnection.java:498) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.jav a:604) at org.apache.activemq.broker.TransportConnection.service(TransportConne ction.java:294) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC onnection.java:185) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt er.java:68) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireForm atNegotiator.java:133) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityM onitor.java:122) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSup port.java:84) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java: 137) at java.lang.Thread.run(Thread.java:595) INFO MasterBroker - SendASync INFO MasterBroker - SendASync INFO MasterBroker - SendASync INFO MasterBroker - SendASync

Show »

All

Comments

Work Log

Change History

Subversion Commits

FishEye

Crucible

Sort Order:

[ Permlink | « Hide ]

Mike Lawrence added a comment - 19/Jul/07 01:48 PM

~~AMQ-1079~~

I'm seeing the same issue, except only a single SendAsync

2007-07-19 22:40:20,584 [main] INFO org.apache.activemq.broker.TransportConnector - Connector defaultSSL Started
2007-07-19 22:40:20,584 [main] INFO org.apache.activemq.broker.BrokerService - ActiveMQ JMS Message Broker (ns-i-jms-m01, ID:ns-i-jms-m01-41598-1184899219647-1:0) started
2007-07-19 22:40:20,598 [main] DEBUG org.apache.xbean.spring.context.ClassPathXmlApplicationContext - Publishing event in context [org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=26348010]: org.springframework.context.event.ContextRefreshedEvent[source=org.apache.xbean.spring.context.ClassPathXmlApplicationContext: display name [org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=26348010]; startup date [Thu Jul 19 22:40:19 EDT 2007]; root of context hierarchy]
2007-07-19 22:40:35,014 [ActiveMQ Transport Server: tcp://localhost:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2007-07-19 22:40:35,065 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2007-07-19 22:40:35,065 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///10.160.160.54:57884 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false}
2007-07-19 22:40:35,066 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///10.160.160.54:57884 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
2007-07-19 22:40:35,069 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.broker.TransportConnection - Setting up new connection: org.apache.activemq.broker.jmx.ManagedTransportConnection@d56b37
2007-07-19 22:40:35,086 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Connection
2007-07-19 22:40:35,102 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Topic
2007-07-19 22:40:35,111 [ActiveMQ Transport: tcp:///10.160.160.54:57884] INFO org.apache.activemq.broker.TransportConnection - Slave Broker ns-i-jms-s01 is attached

2007-07-19 22:40:43,998 [ActiveMQ Transport Server: ssl://localhost:443] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.transport.WireFormatNegotiator - ssl:///10.160.160.86:3084 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false}
2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.transport.WireFormatNegotiator - ssl:///10.160.160.86:3084 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
2007-07-19 22:40:44,232 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.broker.TransportConnection - Setting up new connection: org.apache.activemq.broker.jmx.ManagedTransportConnection@173ec72
2007-07-19 22:40:44,283 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:lawrence-dt-2181-1184873519591-0:0:-1:1
2007-07-19 22:40:54,878 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Producer.Queue.Nsirad.DICOM.Images

2007-07-19 22:40:55,211 [ActiveMQ Transport: ssl:///10.160.160.86:3084] ERROR org.apache.activemq.broker.ft.MasterBroker - Slave Failed
java.lang.AssertionError: Unsupported Method
at org.apache.activemq.transport.TransportSupport.request(TransportSupport.java:71)
at org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88)
at org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88)
at org.apache.activemq.transport.MutexTransport.request(MutexTransport.java:54)
at org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.java:363)
at org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java:333)
at org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307)
at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:498)
at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
at java.lang.Thread.run(Thread.java:595)

[ Show » ]

Mike Lawrence added a comment - 19/Jul/07 01:48 PM ~~AMQ-1079~~ I'm seeing the same issue, except only a single SendAsync 2007-07-19 22:40:20,584 [main] INFO org.apache.activemq.broker.TransportConnector - Connector defaultSSL Started 2007-07-19 22:40:20,584 [main] INFO org.apache.activemq.broker.BrokerService - ActiveMQ JMS Message Broker (ns-i-jms-m01, ID:ns-i-jms-m01-41598-1184899219647-1:0) started 2007-07-19 22:40:20,598 [main] DEBUG org.apache.xbean.spring.context.ClassPathXmlApplicationContext - Publishing event in context [org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=26348010]: org.springframework.context.event.ContextRefreshedEvent[source=org.apache.xbean.spring.context.ClassPathXmlApplicationContext: display name [org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=26348010]; startup date [Thu Jul 19 22:40:19 EDT 2007]; root of context hierarchy] 2007-07-19 22:40:35,014 [ActiveMQ Transport Server: tcp://localhost:61616] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} 2007-07-19 22:40:35,065 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} 2007-07-19 22:40:35,065 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///10.160.160.54:57884 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} 2007-07-19 22:40:35,066 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.transport.WireFormatNegotiator - tcp:///10.160.160.54:57884 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} 2007-07-19 22:40:35,069 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.broker.TransportConnection - Setting up new connection: org.apache.activemq.broker.jmx.ManagedTransportConnection@d56b37 2007-07-19 22:40:35,086 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Connection 2007-07-19 22:40:35,102 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Topic 2007-07-19 22:40:35,111 [ActiveMQ Transport: tcp:///10.160.160.54:57884] INFO org.apache.activemq.broker.TransportConnection - Slave Broker ns-i-jms-s01 is attached 2007-07-19 22:40:43,998 [ActiveMQ Transport Server: ssl://localhost:443] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} 2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat: WireFormatInfo { version=2, properties={TightEncodingEnabled=true, CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} 2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.transport.WireFormatNegotiator - ssl:///10.160.160.86:3084 before negotiation: OpenWireFormat{version=2, cacheEnabled=false, stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false} 2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.transport.WireFormatNegotiator - ssl:///10.160.160.86:3084 after negotiation: OpenWireFormat{version=2, cacheEnabled=true, stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false} 2007-07-19 22:40:44,232 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.broker.TransportConnection - Setting up new connection: org.apache.activemq.broker.jmx.ManagedTransportConnection@173ec72 2007-07-19 22:40:44,283 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding consumer: ID:lawrence-dt-2181-1184873519591-0:0:-1:1 2007-07-19 22:40:54,878 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG org.apache.activemq.broker.region.AbstractRegion - Adding destination: topic://ActiveMQ.Advisory.Producer.Queue.Nsirad.DICOM.Images 2007-07-19 22:40:55,211 [ActiveMQ Transport: ssl:///10.160.160.86:3084] ERROR org.apache.activemq.broker.ft.MasterBroker - Slave Failed java.lang.AssertionError: Unsupported Method at org.apache.activemq.transport.TransportSupport.request(TransportSupport.java:71) at org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88) at org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88) at org.apache.activemq.transport.MutexTransport.request(MutexTransport.java:54) at org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.java:363) at org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java:333) at org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136) at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:498) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137) at java.lang.Thread.run(Thread.java:595)