[
https://issues.apache.org/activemq/browse/AMQ-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_39715
]
Mike Lawrence commented on AMQ-1257:
------------------------------------
AMQ-1079
I'm seeing the same issue, except only a single SendAsync
2007-07-19 22:40:20,584 [main] INFO
org.apache.activemq.broker.TransportConnector - Connector defaultSSL Started
2007-07-19 22:40:20,584 [main] INFO org.apache.activemq.broker.BrokerService -
ActiveMQ JMS Message Broker (ns-i-jms-m01,
ID:ns-i-jms-m01-41598-1184899219647-1:0) started
2007-07-19 22:40:20,598 [main] DEBUG
org.apache.xbean.spring.context.ClassPathXmlApplicationContext - Publishing
event in context
[org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=26348010]:
org.springframework.context.event.ContextRefreshedEvent[source=org.apache.xbean.spring.context.ClassPathXmlApplicationContext:
display name
[org.apache.xbean.spring.context.ClassPathXmlApplicationContext;hashCode=26348010];
startup date [Thu Jul 19 22:40:19 EDT 2007]; root of context hierarchy]
2007-07-19 22:40:35,014 [ActiveMQ Transport Server: tcp://localhost:61616]
DEBUG org.apache.activemq.transport.WireFormatNegotiator - Sending:
WireFormatInfo { version=2, properties={TightEncodingEnabled=true,
CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
2007-07-19 22:40:35,065 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat:
WireFormatInfo { version=2, properties={TightEncodingEnabled=true,
CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
2007-07-19 22:40:35,065 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - tcp:///10.160.160.54:57884
before negotiation: OpenWireFormat{version=2, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false}
2007-07-19 22:40:35,066 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - tcp:///10.160.160.54:57884
after negotiation: OpenWireFormat{version=2, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
2007-07-19 22:40:35,069 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG
org.apache.activemq.broker.TransportConnection - Setting up new connection:
[EMAIL PROTECTED]
2007-07-19 22:40:35,086 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG
org.apache.activemq.broker.region.AbstractRegion - Adding destination:
topic://ActiveMQ.Advisory.Connection
2007-07-19 22:40:35,102 [ActiveMQ Transport: tcp:///10.160.160.54:57884] DEBUG
org.apache.activemq.broker.region.AbstractRegion - Adding destination:
topic://ActiveMQ.Advisory.Topic
2007-07-19 22:40:35,111 [ActiveMQ Transport: tcp:///10.160.160.54:57884] INFO
org.apache.activemq.broker.TransportConnection - Slave Broker ns-i-jms-s01 is
attached
2007-07-19 22:40:43,998 [ActiveMQ Transport Server: ssl://localhost:443] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - Sending: WireFormatInfo {
version=2, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - Received WireFormat:
WireFormatInfo { version=2, properties={TightEncodingEnabled=true,
CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - ssl:///10.160.160.86:3084
before negotiation: OpenWireFormat{version=2, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false}
2007-07-19 22:40:44,228 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG
org.apache.activemq.transport.WireFormatNegotiator - ssl:///10.160.160.86:3084
after negotiation: OpenWireFormat{version=2, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
2007-07-19 22:40:44,232 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG
org.apache.activemq.broker.TransportConnection - Setting up new connection:
[EMAIL PROTECTED]
2007-07-19 22:40:44,283 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG
org.apache.activemq.broker.region.AbstractRegion - Adding consumer:
ID:lawrence-dt-2181-1184873519591-0:0:-1:1
2007-07-19 22:40:54,878 [ActiveMQ Transport: ssl:///10.160.160.86:3084] DEBUG
org.apache.activemq.broker.region.AbstractRegion - Adding destination:
topic://ActiveMQ.Advisory.Producer.Queue.Nsirad.DICOM.Images
2007-07-19 22:40:55,211 [ActiveMQ Transport: ssl:///10.160.160.86:3084] ERROR
org.apache.activemq.broker.ft.MasterBroker - Slave Failed
java.lang.AssertionError: Unsupported Method
at
org.apache.activemq.transport.TransportSupport.request(TransportSupport.java:71)
at
org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88)
at
org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88)
at
org.apache.activemq.transport.MutexTransport.request(MutexTransport.java:54)
at
org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.java:363)
at
org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java:333)
at
org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:498)
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
at java.lang.Thread.run(Thread.java:595)
> 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.
