Folks,
I can't figure out why my configuration doesn't work.
My configuration: activeMQ 5.4.2 servicemix 3.3.2
One activeMQ, 2 servicemix connected to activeMQ (box 1 and box2, box 1
produces messages to box2). In this configuration everything works fine.
When I try to instanciate only activeMQ and Box1, using Oracle connected to
activeMQ, I can check messages produced by Box1 in my Oracle schema.
Then stop activeMQ and start it again just with box2 which should compute
messages from box1.
An error occurs in servicemix log:
INFO - AutoDeploymentService - Directory: hotdeploy: Finished
installation of archive: servicemix-shared-2010.01-installer.zip
WARN - ActiveMQManagedConnection - Connection failed:
javax.jms.JMSException: Cannot remove a consumer from a connection that had not
been registered: ID:vhmucj3.helios.cp-55010-1322581269935-2:7
75454 [ActiveMQ Connection Worker: tcp:///10.78.252.223:6666] WARN
org.apache.geronimo.connector.outbound.GeronimoConnectionEventListener -
connectionErrorOccurred called with null
javax.jms.JMSException: Cannot remove a consumer from a connection that had not
been registered: ID:vhmucj3.helios.cp-55010-1322581269935-2:7
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
at
org.apache.activemq.ActiveMQConnection.onAsyncException(ActiveMQConnection.java:1784)
at
org.apache.activemq.ActiveMQConnection$2$1.run(ActiveMQConnection.java:1705)
at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:897)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:919)
at java.lang.Thread.run(Thread.java:736)
Caused by: java.lang.IllegalStateException: Cannot remove a consumer from a
connection that had not been registered:
ID:vhmucj3.helios.cp-55010-1322581269935-2:7
at
org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:565)
at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:76)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:311)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:228)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
activemq.log:
2011-11-29 16:42:27,830 | DEBUG | box1-direct-technical-split.event.1 toPageIn:
0, Inflight: 0, pagedInMessages.size 1, enqueueCount: 0, dequeueCount: 1 |
org.apache.activemq.broker.region.Queue | BrokerService[cocololo] Task
2011-11-29 16:42:27,830 | DEBUG | cocololo removing consumer:
ID:vhmucj3.helios.cp-55010-1322581269935-2:7:-1:2 for destination:
topic://ActiveMQ.Advisory.TempQueue,topic://ActiveMQ.Advisory.TempTopic |
org.apache.activemq.broker.region.AbstractRegion | ActiveMQ Transport:
tcp:///10.78.252.1:55039
2011-11-29 16:42:27,830 | DEBUG | remove connection id:
ID:vhmucj3.helios.cp-55010-1322581269935-2:7 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
tcp:///10.78.252.1:55039
2011-11-29 16:42:27,999 | DEBUG | Transport failed: java.io.EOFException |
org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport:
tcp:///10.78.252.1:55039
java.io.EOFException
at java.io.DataInputStream.readInt(DataInputStream.java:386)
at
org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:269)
at
org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:227)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202)
at java.lang.Thread.run(Thread.java:736)
here is my activeMQ config:
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd";>
<bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<value>file:${activemq.base}/conf/credentials.properties</value>
</property>
</bean>
<broker xmlns="http://activemq.apache.org/schema/core";
brokerName="cocololo" brokerId="tamoule" persistent="true"
dataDirectory="${activemq.base}/pll" useJmx="true">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" producerFlowControl="false"/>
</policyEntries>
</policyMap>
</destinationPolicy>
<managementContext>
<managementContext createConnector="true"/>
</managementContext>
<persistenceFactory>
<journalPersistenceAdapterFactory journalLogFiles="1"
dataDirectory="${activemq.base}/pll" dataSource="#oracle-ds">
</journalPersistenceAdapterFactory>
</persistenceFactory>
<transportConnectors>
<transportConnector name="openwire"
uri="tcp://10.78.252.223:6666?connectionTimeout=0&wireFormat.maxInactivityDuration=0"/>
</transportConnectors>
</broker>
<bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName"
value="oracle.jdbc.driver.OracleDriver"/>
<property name="url"
value="jdbc:oracle:thin:@vhmucj3:15212:HPRD10"/>
<property name="username" value="amq"/>
<property name="password" value="amq"/>
<property name="maxActive" value="200"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
<!--import resource="jetty.xml"/-->
</beans>
What I would be able to do is to consume messages produced by Box1 during the
day by Box2 during the night.
Any help would be appreciated.
Regards,
Phi-Long LE
________________________________
Ce message et les pi?ces jointes sont confidentiels et r?serv?s ? l'usage
exclusif de ses destinataires. Il peut ?galement ?tre prot?g? par le secret
professionnel. Si vous recevez ce message par erreur, merci d'en avertir
imm?diatement l'exp?diteur et de le d?truire. L'int?grit? du message ne pouvant
?tre assur?e sur Internet, la responsabilit? du groupe Atos ne pourra ?tre
engag?e quant au contenu de ce message. Bien que les meilleurs efforts soient
faits pour maintenir cette transmission exempte de tout virus, l'exp?diteur ne
donne aucune garantie ? cet ?gard et sa responsabilit? ne saurait ?tre engag?e
pour tout dommage r?sultant d'un virus transmis.
This e-mail and the documents attached are confidential and intended solely for
the addressee; it may also be privileged. If you receive this e-mail in error,
please notify the sender immediately and destroy it. As its integrity cannot be
secured on the Internet, the Atos group liability cannot be triggered for the
message content. Although the sender endeavors to maintain a computer
virus-free network, the sender does not warrant that this transmission is
virus-free and will not be liable for any damages resulting from any virus
transmitted.
