Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (herse.apache.org: domain of profoundmystery@gmail.com
 designates 72.14.204.225 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=beta;
        h=received:message-id:date:from:to:subject:mime-version:content-type;
        b=HVNXM6Nne4sUick19Ar9pvl36qarJIwMWyGzqU1HpILql8jXfkuNalVXaSPfZ5khcJKs8v9jN6iMop271etk2Lj/nRtOT+b4wkV1yZ5QyOFhLwhfgKI+yVlq04RbGubXT/32NEjj7JPHPEON9htV71Zy5WKv/TP0Z6GrBv75dCg=
Message-ID: <9a8abc1b0706070326ndccc6bdybafb3f408a5ce068@mail.gmail.com>
Date: Thu, 7 Jun 2007 15:56:22 +0530
From: "Eric Nygma" <profoundmystery@gmail.com>
To: users@activemq.apache.org
Subject: activemq examples query :EmbeddedBroker
MIME-Version: 1.0
Content-Type: multipart/alternative;
	boundary="----=_Part_18476_2026723.1181211982072"

------=_Part_18476_2026723.1181211982072
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: 7bit
Content-Disposition: inline

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.

------=_Part_18476_2026723.1181211982072--