activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From goldi <gold...@freenet.de>
Subject Re: Master/Slaver persistent?
Date Sun, 06 May 2007 11:19:59 GMT

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.


Mime
View raw message