Using Servicemix with ActiveMQ failover does not work

[William Blackburn <wj...@mac.com>]

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.