activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jamie McCrindle" <jamiemccrin...@gmail.com>
Subject Re: peer configuration
Date Fri, 28 Apr 2006 15:06:48 GMT
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 <jamiemccrindle@gmail.com> 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.
>

Mime
View raw message