After following steps in wiki, the embedded broker starts successfully!!
Now I included two jars -
activemq-all-5.0.0.jar and commons-logging-1.1.jar
but I got this exception when my queue producer initialized :
java.lang.NoSuchMethodError:
org.apache.activemq.ActiveMQMessageProducerSupport.ge
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.add
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
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:
>
>
