activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sambit <sambit.diks...@apple.com>
Subject Re: Problems with Master/Slave and failover
Date Mon, 09 Jul 2007 08:54:31 GMT

Hi,
  Did you find a solution to this? 

Regards
-Sambit 

William Blackburn-2 wrote:
> 
> I'm out of my depth - and I apologize for posting this on both lists,  
> but I am desperate.
> 
> I have configured ActiveMQ in a Master/Slave arrangement according to  
> the instructions for 'pure' master/slave. The brokers start with no  
> problem and I can immediately start using my servicemix-based  
> application. The jmsflow starts up fine with a failover url like:
> 
> 	failover://(tcp://localhost:61617,tcp://localhost:61618)? 
> randomize=false
> 
> I then kill the master broker - I can see from the logs that the  
> slave is opening its transports and ready to receive messages, but at  
> this point my servicemix app stops working. I see in the logs for the  
> Slave broker a problem that I don't understand the implications of:
> 
> 
> 2006-12-13 09:24:50,900 [127.0.0.1:61617] ERROR  
> MasterConnector                - Network connection between vm:// 
> localhost#0 and tcp://localhost/127.0.0.1:61617 shutdown: null
> java.io.EOFException
>          at java.io.DataInputStream.readInt(DataInputStream.java:358)
>          at org.apache.activemq.openwire.OpenWireFormat.unmarshal 
> (OpenWireFormat.java:275)
>          at org.apache.activemq.transport.tcp.TcpTransport.run 
> (TcpTransport.java:136)
>          at java.lang.Thread.run(Thread.java:613)
> 2006-12-13 09:24:50,903 [127.0.0.1:61617] WARN   
> BrokerService                  - Master Failed - starting all connectors
> 2006-12-13 09:24:51,139 [127.0.0.1:61617] INFO   
> TransportServerThreadSupport   - Listening for connections at: tcp:// 
> fastgt.local:61618
> 2006-12-13 09:24:51,213 [127.0.0.1:61617] INFO   
> TransportConnector             - Connector default Started
> 2006-12-13 09:24:51,343 [127.0.0.1:49336] ERROR  
> ManagedRegionBroker            - Failed to register subscription  
> QueueSubscription:  
> consumer=ID:fastgt.local-49287-1166030617711-1:0:1:14,  
> destinations=0, dispatched=0, delivered=0, pending=0
> javax.management.InstanceAlreadyExistsException:  
> org.apache.activemq:BrokerName=localhost,Type=Subscription,active=true,n 
> ame=ID_fastgt.local-49287-1166030617711-1_0_1_14
>          at com.sun.jmx.mbeanserver.RepositorySupport.addMBean 
> (RepositorySupport.java:452)
>          at  
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.internal_addObject 
> (DefaultMBeanServerInterceptor.java:1410)
>          at  
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject 
> (DefaultMBeanServerInterceptor.java:936)
>          at  
> com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean 
> (DefaultMBeanServerInterceptor.java:337)
>          at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean 
> (JmxMBeanServer.java:497)
>          at  
> org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription( 
> ManagedRegionBroker.java:264)
>          at  
> org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription( 
> ManagedRegionBroker.java:184)
>          at  
> org.apache.activemq.broker.jmx.ManagedQueueRegion.createSubscription 
> (ManagedQueueRegion.java:46)
>          at  
> org.apache.activemq.broker.region.AbstractRegion.addConsumer 
> (AbstractRegion.java:146)
>          at org.apache.activemq.broker.region.RegionBroker.addConsumer 
> (RegionBroker.java:297)
>          at org.apache.activemq.broker.BrokerFilter.addConsumer 
> (BrokerFilter.java:74)
>          at org.apache.activemq.advisory.AdvisoryBroker.addConsumer 
> (AdvisoryBroker.java:78)
>          at org.apache.activemq.broker.BrokerFilter.addConsumer 
> (BrokerFilter.java:74)
>          at org.apache.activemq.broker.MutableBrokerFilter.addConsumer 
> (MutableBrokerFilter.java:87)
>          at  
> org.apache.activemq.broker.AbstractConnection.processAddConsumer 
> (AbstractConnection.java:529)
>          at org.apache.activemq.command.ConsumerInfo.visit 
> (ConsumerInfo.java:296)
>          at org.apache.activemq.broker.AbstractConnection.service 
> (AbstractConnection.java:237)
>          at org.apache.activemq.broker.TransportConnection$1.onCommand 
> (TransportConnection.java:61)
>          at org.apache.activemq.transport.ResponseCorrelator.onCommand 
> (ResponseCorrelator.java:92)
>          at org.apache.activemq.transport.TransportFilter.onCommand 
> (TransportFilter.java:67)
>          at  
> org.apache.activemq.transport.WireFormatNegotiator.onCommand 
> (WireFormatNegotiator.java:124)
>          at org.apache.activemq.transport.InactivityMonitor.onCommand 
> (InactivityMonitor.java:123)
>          at org.apache.activemq.transport.TransportSupport.doConsume 
> (TransportSupport.java:88)
>          at org.apache.activemq.transport.tcp.TcpTransport.run 
> (TcpTransport.java:137)
>          at java.lang.Thread.run(Thread.java:613)
> 2006-12-13 09:24:51,468 [127.0.0.1:61617] INFO   
> TransportConnector             - Connector vm://localhost Stopped
> 
> 
> 
>  From this point on, any new attempt to send an exchange in  
> servicemix results in:
> 
> javax.jms.JMSException: Cannot send from a session that had not been  
> registered: ID:fastgt.local-49287-1166030617711-1:0:1
>          at org.apache.activemq.util.JMSExceptionSupport.create 
> (JMSExceptionSupport.java:45)
>          at org.apache.activemq.ActiveMQConnection.syncSendPacket 
> (ActiveMQConnection.java:1118)
>          at org.apache.activemq.ActiveMQSession.send 
> (ActiveMQSession.java:1555)
>          at org.apache.activemq.ActiveMQMessageProducer.send 
> (ActiveMQMessageProducer.java:462)
>          at org.apache.activemq.ActiveMQMessageProducer.send 
> (ActiveMQMessageProducer.java:415)
>          at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.doRouting 
> (JMSFlow.java:501)
>          at org.apache.servicemix.jbi.nmr.flow.jms.JMSFlow.doSend 
> (JMSFlow.java:460)
>          at org.apache.servicemix.jbi.nmr.flow.AbstractFlow.send 
> (AbstractFlow.java:121)
>          at  
> org.apache.servicemix.jbi.nmr.DefaultBroker.sendExchangePacket 
> (DefaultBroker.java:298)
>          at  
> org.apache.servicemix.jbi.container.JBIContainer.sendExchange 
> (JBIContainer.java:793)
>          at  
> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend 
> (DeliveryChannelImpl.java:375)
>          at  
> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send 
> (DeliveryChannelImpl.java:411)
>          at org.apache.servicemix.components.util.PojoSupport.send 
> (PojoSupport.java:228)
>          at  
> com.clairmail.component.sm.SmppServerComponent.handleInMessage 
> (SmppServerComponent.java:148)
>          at  
> com.clairmail.smpp.mblox.DeliverSMHandlerNotifier.notifyMessageHandler 
> (DeliverSMHandlerNotifier.java:49)
>          at com.clairmail.smpp.mblox.DeliverSMHandlerNotifier.run 
> (DeliverSMHandlerNotifier.java:40)
>          at java.util.concurrent.ThreadPoolExecutor$Worker.runTask 
> (ThreadPoolExecutor.java:650)
>          at java.util.concurrent.ThreadPoolExecutor$Worker.run 
> (ThreadPoolExecutor.java:675)
>          at java.lang.Thread.run(Thread.java:613)
> 
> 
> Has anyone successfully got servicemix working with AMQ failover? Any  
> advice welcomed, I know I must be missing something.
> 
> 

-- 
View this message in context: http://www.nabble.com/Problems-with-Master-Slave-and-failover-tf2815585s2354.html#a11498164
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message