more information:
it only happens when i start the second client up.
the log lines above the error are:
[BpmScript] INFO [Multicast Discovery Agent Notifier] DemandForwardingBridge.sta
rt(108) | Starting a network connection between vm://localhost#4 and tcp://null:
0 has been established.
[BpmScript] INFO [Thread-9] DemandForwardingBridge.startLocalBridge(185) | Netwo
rk connection between vm://localhost#4 and tcp://localhost/127.0.0.1:1571(localh
ost) has been established.
[BpmScript] INFO [Multicast Discovery Agent Notifier] NetworkConnector.onService
Add(91) | Establishing network connection between from vm://broker1?network=true
to tcp://SIM-JamesM:1574
[BpmScript] INFO [Multicast Discovery Agent Notifier] DemandForwardingBridge.sta
rt(108) | Starting a network connection between vm://broker1#6 and tcp://null:0
has been established.
[BpmScript] INFO [Thread-11] DemandForwardingBridge.startLocalBridge(185) | Netw
ork connection between vm://broker1#6 and tcp://localhost/127.0.0.1:1574(broker1
) has been established.
if i kill and restart one of the clients, the live one throws the
following errors:
[BpmScript] INFO [Thread-15] Service.serviceException(180) | Async error occurre
d: javax.jms.InvalidClientIDException: Broker: broker1 - Client: NC_broker1_inbo
undbroker1 already connected
javax.jms.InvalidClientIDException: Broker: broker1 - Client: NC_broker1_inbound
broker1 already connected
at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBr
oker.java:154)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.ja
va:65)
at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBro
ker.java:67)
at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.ja
va:65)
at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableB
rokerFilter.java:77)
at org.apache.activemq.broker.AbstractConnection.processAddConnection(Ab
stractConnection.java:500)
at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:
106)
at org.apache.activemq.broker.AbstractConnection.service(AbstractConnect
ion.java:196)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC
onnection.java:62)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCo
rrelator.java:88)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt
er.java:70)
at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:
75)
at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.ja
va:44)
at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorre
lator.java:55)
at org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalB
ridge(DemandForwardingBridgeSupport.java:180)
at org.apache.activemq.network.DemandForwardingBridgeSupport$3.run(Deman
dForwardingBridgeSupport.java:150)
[BpmScript] INFO [Thread-15] DemandForwardingBridge.startLocalBridge(185) | Netw
ork connection between vm://broker1#10 and tcp://localhost/127.0.0.1:1587(broker
1) has been established.
[BpmScript] WARN [ActiveMQ Task] DemandForwardingBridge.serviceLocalCommand(420)
| Unexpected local command: ConnectionError {commandId = 2, responseRequired =
false, connectionId = null, exception = javax.jms.InvalidClientIDException: Brok
er: broker1 - Client: NC_broker1_inboundbroker1 already connected}
[BpmScript] INFO [ActiveMQ Task] DemandForwardingBridge.serviceLocalException(33
9) | Network connection between vm://broker1#10 and tcp://localhost/127.0.0.1:15
87 shutdown: null
java.lang.NullPointerException
at org.apache.activemq.network.DemandForwardingBridgeSupport.configureMe
ssage(DemandForwardingBridgeSupport.java:361)
at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceLoca
lCommand(DemandForwardingBridgeSupport.java:382)
at org.apache.activemq.network.DemandForwardingBridgeSupport$1.onCommand
(DemandForwardingBridgeSupport.java:111)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCo
rrelator.java:88)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt
er.java:70)
at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:
75)
at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.ja
va:44)
at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorre
lator.java:55)
at org.apache.activemq.broker.TransportConnection.dispatch(TransportConn
ection.java:211)
at org.apache.activemq.broker.AbstractConnection.processDispatch(Abstrac
tConnection.java:568)
at org.apache.activemq.broker.AbstractConnection.iterate(AbstractConnect
ion.java:584)
at org.apache.activemq.thread.SimpleTaskRunner.runTask(SimpleTaskRunner.
java:110)
at org.apache.activemq.thread.SimpleTaskRunner.access$100(SimpleTaskRunn
er.java:25)
at org.apache.activemq.thread.SimpleTaskRunner$1.run(SimpleTaskRunner.ja
va:43)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
ker.runTask(ThreadPoolExecutor.java:650)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
ker.run(ThreadPoolExecutor.java:675)
at java.lang.Thread.run(Thread.java:595)
On 4/28/06, Jamie McCrindle <[EMAIL PROTECTED]> wrote:
hi,
I'm running with the latest activemq 4.0 snapshots and i'm trying to
set up a couple of embedded brokers but i'm getting this error:
[BpmScript] INFO [ActiveMQ Task] DemandForwardingBridge.serviceLocalException(33
9) | Network connection between vm://broker1#6 and tcp://localhost/127.0.0.1:154
6 shutdown: null
java.lang.NullPointerException
at org.apache.activemq.network.DemandForwardingBridgeSupport.configureMe
ssage(DemandForwardingBridgeSupport.java:361)
at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceLoca
lCommand(DemandForwardingBridgeSupport.java:382)
at org.apache.activemq.network.DemandForwardingBridgeSupport$1.onCommand
(DemandForwardingBridgeSupport.java:111)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCo
rrelator.java:88)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt
er.java:70)
at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:
75)
at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.ja
va:44)
at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorre
lator.java:55)
at org.apache.activemq.broker.TransportConnection.dispatch(TransportConn
ection.java:211)
at org.apache.activemq.broker.AbstractConnection.processDispatch(Abstrac
tConnection.java:568)
at org.apache.activemq.broker.AbstractConnection.iterate(AbstractConnect
ion.java:584)
at org.apache.activemq.thread.SimpleTaskRunner.runTask(SimpleTaskRunner.
java:110)
at org.apache.activemq.thread.SimpleTaskRunner.access$100(SimpleTaskRunn
er.java:25)
at org.apache.activemq.thread.SimpleTaskRunner$1.run(SimpleTaskRunner.ja
va:43)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
ker.runTask(ThreadPoolExecutor.java:650)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Wor
ker.run(ThreadPoolExecutor.java:675)
at java.lang.Thread.run(Thread.java:595)
this is what my activemq configuration looks like:
<!-- START SNIPPET: xbean -->
<beans xmlns="http://activemq.org/config/1.0";>
<broker useJmx="true">
<transportConnectors>
<transportConnector uri="tcp://localhost:0"
discoveryUri="multicast://default"/>
</transportConnectors>
<networkConnectors>
<networkConnector uri="multicast://default"/>
</networkConnectors>
<persistenceAdapter>
<memoryPersistenceAdapter/>
</persistenceAdapter>
</broker>
</beans>
and this is what the spring beans config for my
activemqconnectionfactory looks like:
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<constructor-arg value="peer://groupa/broker1?persistent=false"/>
</bean>
any ideas?
Regards,
Jamie.
