activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rob Davies (JIRA)" <j...@apache.org>
Subject [jira] Assigned: (AMQ-1257) Pure Master/Slave configuration doesn't work
Date Mon, 23 Jul 2007 07:51:49 GMT

     [ https://issues.apache.org/activemq/browse/AMQ-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Rob Davies reassigned AMQ-1257:
-------------------------------

    Assignee: Rob Davies

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


Mime
View raw message