activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Mike Lawrence (JIRA)" <j...@apache.org>
Subject [jira] Commented: (AMQ-1257) Pure Master/Slave configuration doesn't work
Date Thu, 19 Jul 2007 20:50:28 GMT

    [ 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: org.apache.activemq.broker.jmx.ManagedTransportConnection@d56b37
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: org.apache.activemq.broker.jmx.ManagedTransportConnection@173ec72
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.


Mime
View raw message