[
https://issues.apache.org/activemq/browse/AMQ-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rob Davies resolved AMQ-1257.
-----------------------------
Resolution: Fixed
Fix Version/s: 5.0.0
> Pure Master/Slave configuration doesn't work
> --------------------------------------------
>
> Key: AMQ-1257
> URL: https://issues.apache.org/activemq/browse/AMQ-1257
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 4.1.0
> Reporter: Denis Abramov
> Assignee: Rob Davies
> Priority: Blocker
> Fix For: 5.0.0
>
>
> 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
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
