[prev in list] [next in list] [prev in thread] [next in thread] 

List:       activemq-dev
Subject:    [jira] Created: (AMQ-1257) Pure Master/Slave configuration doesn't
From:       "Denis Abramov (JIRA)" <jira () apache ! org>
Date:       2007-05-31 13:16:32
Message-ID: 27369104.1180617392834.JavaMail.jira () brutus
[Download RAW message or body]

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
            Priority: Blocker


> 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.


[prev in list] [next in list] [prev in thread] [next in thread]