You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Jamie McCrindle <ja...@gmail.com> on 2006/04/28 17:02:11 UTC
peer configuration
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.
Re: peer configuration
Posted by Jamie McCrindle <ja...@gmail.com>.
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 <ja...@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.
>
Re: peer configuration
Posted by Jamie McCrindle <ja...@gmail.com>.
hi Rob,
Thanks. Will move on to RC2.
cheers,
j.
On 5/1/06, Rob Davies <ra...@gmail.com> wrote:
> looking at the src I don't think your using the latest snaphot -
> what's the date your using ?
> You can get the latest and greatest here: http://cvs.apache.org/
> repository/incubator-activemq/distributions/
>
> cheers,
>
> Rob
> http://rajdavies.blogspot.com/
>
> On 1 May 2006, at 13:43, Jamie McCrindle wrote:
>
> > any thoughts?
> >
> > i want to get an embedded broker with zero-conf up and running. it's
> > working fine using an external broker but i really like the idea of
> > being able to cluster by just starting up new copies of the app on the
> > same subnet.
> >
> > cheers,
> > j.
> >
> > On 4/28/06, Jamie McCrindle <ja...@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.
> >>
>
>
Re: peer configuration
Posted by Rob Davies <ra...@gmail.com>.
looking at the src I don't think your using the latest snaphot -
what's the date your using ?
You can get the latest and greatest here: http://cvs.apache.org/
repository/incubator-activemq/distributions/
cheers,
Rob
http://rajdavies.blogspot.com/
On 1 May 2006, at 13:43, Jamie McCrindle wrote:
> any thoughts?
>
> i want to get an embedded broker with zero-conf up and running. it's
> working fine using an external broker but i really like the idea of
> being able to cluster by just starting up new copies of the app on the
> same subnet.
>
> cheers,
> j.
>
> On 4/28/06, Jamie McCrindle <ja...@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.
>>
Re: peer configuration
Posted by Jamie McCrindle <ja...@gmail.com>.
any thoughts?
i want to get an embedded broker with zero-conf up and running. it's
working fine using an external broker but i really like the idea of
being able to cluster by just starting up new copies of the app on the
same subnet.
cheers,
j.
On 4/28/06, Jamie McCrindle <ja...@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.
>