I updated the wiki - but this might take a while before its published
to the amq site: http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html?refresh=1
Basically you can do something like this:
BrokerService broker = new BrokerService();
broker.setName("fred");
broker.addConnector("tcp://localhost:61616");
broker.start();
Then remote clients can use the tcp://somehost:61616 uri to bind to
the embedded broker - and in JVM clients can use vm://fred
With regards to the class path error - which jars are you using ?
cheers,
Rob
Rob Davies
'Go further faster with Apache Camel!'
http://rajdavies.blogspot.com/
On Dec 18, 2007, at 5:43 AM, JS75 wrote:
First, thank you for your apply~
I tried to assign name to each embedded broker.
And these twn connections starts successfully, however, they do not
work as
I wish!
As URI as tcp://localhost:61616, producers send messages and consumers
receive messages.
After assigning names, they seemd to work without any relationship.
Is there any thing I can do to make embedded VM broker as embedded TCP
broker?
BTW, I tried to upgrade activeMQ to 5.0, and I found this exception in
console
java.lang.NoSuchMethodError:
org
.apache
.activemq.ActiveMQMessageProducerSupport.getDestination()Ljavax/jms/
Destination;
Have I misses to include any lib?
Sincerely,
Jean
ttmdev wrote:
Try assigning different names to your two embedded brokers. For
example,
ActiveMQConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(vm://clientbroker);
ActiveMQConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(vm://serverbroker);
Joe
JS75 wrote:
Dear Sirs:
As a neophyte of activeMQ, I encountered some tasks, and please
help me
to solve them >"<!
I tried to embedded one broker into my connections -
producer (ClientSide) and consumer (ServerSide)
separately in
one JVM.
ActiveMQConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(vm://localhost);
However, when I started these two connections, the latter one has
above
messages in cosole
org.apache.activemq.store.DefaultPersistenceAdapterFactory
createJournal
資訊: Journal is locked... waiting 10 seconds for the journal
to be
unlocked.
Unless did I close the former connection (usually Producer
connection),
the latter broker started (Consumer connection received)?
But I wish each of them can work in pararrel as TCP can do?
Did I make any mistake or forget to do any configurations?
Sincerely,
Jean
--
View this message in context:
http://www.nabble.com/Journal-is-locked-tp14375869s2354p14384479.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
