i´m using version 4.1.1. rajdavies wrote: > > which version are you using ? > > On 3 May 2007, at 10:16, goldi wrote: > >> >> 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 >> >> >> I don't know if this is ok. Would be nice, if someone could take a >> look at >> this. >> >> >> Greets Goldi >> >> >> >> -- >> View this message in context: http://www.nabble.com/Master-Slaver- >> persistent--tf3685398s2354.html#a10301385 >> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com. >> > > >
-- View this message in context: http://www.nabble.com/Master-Slaver-persistent--tf3685398s2354.html#a10344575 Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
