activemq examples query :EmbeddedBroker

[Eric Nygma <pr...@gmail.com>]

Hi,

I am trying to work with the examples shipped with apache-activemq-4.1.1.
I have put the EmbeddedBroker.java code inside the ProducerTool.java code so
as to have an embedded broker spawned from the Producer.
Upon doing an : ant producer, I got the following exception :

Buildfile: build.xml

init:

compile:

producer:
     [echo] Running producer against server at $url = tcp://localhost:61616
for subject $subject = ERIC.TOPIC
     [java] Connecting to Queue url : tcp://localhost:61616
     [java] Publishing a message of size = 1000 to ERIC.TOPIC
     [java]
     [java] Starting the Embedded broker
     [java] 15:53:33 INFO  ActiveMQ 4.1.1 JMS Message Broker (localhost) is
starting
     [java] 15:53:33 INFO  For help or more information please see:
http://incubator.apache.org/activemq/
     [java] javax.jms.JMSException: Could not connect to broker URL:
tcp://localhost:61616. Reason: java.net.ConnectException: Connection
refused: connect
     [java]     at org.apache.activemq.util.JMSExceptionSupport.create(
JMSExceptionSupport.java:33)
     [java]     at
org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
ActiveMQConnectionFactory.java:280)
     [java]     at
org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
ActiveMQConnectionFactory.java:214)
     [java]     at
org.apache.activemq.ActiveMQConnectionFactory.createConnection(
ActiveMQConnectionFactory.java:161)
     [java]     at Producer.run(Unknown Source)
     [java]     at Producer.main(Unknown Source)
     [java] Caused by: java.net.ConnectException: Connection refused:
connect
     [java]     at java.net.PlainSocketImpl.socketConnect(Native Method)
     [java]     at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java
:333)
     [java]     at java.net.PlainSocketImpl.connectToAddress(
PlainSocketImpl.java:195)
     [java]     at java.net.PlainSocketImpl.connect(PlainSocketImpl.java
:182)
     [java]     at java.net.SocksSocketImpl.connect(SocksSocketImpl.java
:366)
     [java]     at java.net.Socket.connect(Socket.java:519)
     [java]     at org.apache.activemq.transport.tcp.TcpTransport.connect(
TcpTransport.java:335)
     [java]     at org.apache.activemq.transport.tcp.TcpTransport.doStart(
TcpTransport.java:303)
     [java]     at org.apache.activemq.util.ServiceSupport.start(
ServiceSupport.java:49)
     [java]     at org.apache.activemq.transport.TransportFilter.start(
TransportFilter.java:54)
     [java]     at org.apache.activemq.transport.TransportFilter.start(
TransportFilter.java:54)
     [java]     at org.apache.activemq.transport.WireFormatNegotiator.start(
WireFormatNegotiator.java:66)
     [java]     at org.apache.activemq.transport.TransportFilter.start(
TransportFilter.java:54)
     [java]     at org.apache.activemq.transport.TransportFilter.start(
TransportFilter.java:54)
     [java]     at
org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
ActiveMQConnectionFactory.java:265)
     [java]     ... 4 more
     [java] 15:53:35 INFO  Database driver recognized:
[apache_derby_embedded_jdbc_driver]
     [java] 15:53:37 INFO  Attempting to acquire the exclusive lock to
become the Master broker
     [java] 15:53:37 INFO  Becoming the master on dataSource:
org.apache.derby.jdbc.EmbeddedDataSource@12f1bf0
     [java] 15:53:37 INFO  Journal Recovery Started from: Active Journal:
using 2 x 20.0 Megs at:
D:\data\scratch\queapp\activemq-data\localhost\journal
     [java] 15:53:37 INFO  Journal Recovered: 0 message(s) in transactions
recovered.
     [java] 15:53:37 INFO  Listening for connections at:
tcp://SOAMATRIX-PC:61616
     [java] 15:53:37 INFO  Connector tcp://SOAMATRIX-PC:61616 Started
     [java] 15:53:37 INFO  ActiveMQ JMS Message Broker (localhost,
ID:SOAMATRIX-PC-52783-1181211813415-3:0) started
     [java] 15:53:37 INFO  JMX consoles can connect to
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi

Can anyone help me fix this ?

Thanks
Eric.