You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by topsweep1506 <to...@yahoo.co.uk> on 2012/11/19 11:25:36 UTC
help: ruby listener/publisher
Hi im new to activemq and using ruby ive got everything sorted out scripts
are all working but ive hit a problem with the ruby listener.rb and ruby
publisher.rb every time i try to run the script for ruby listener i get this
error message
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:165:in
`initialize': No connection could be made because the target machine
actively refused it. - connect(2) (Errno::ECONNREFUSED)
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:165:in
`open'
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:165:in
`block in open_tcp_socket'
from C:/Ruby193/lib/ruby/1.9.1/timeout.rb:54:in `timeout'
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:164:in
`open_tcp_socket'
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:293:in
`open_socket'
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/utils.rb:110:in
`block in socket'
from <internal:prelude>:10:in `synchronize'
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/utils.rb:103:in
`socket'
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/stomp/connection.rb:118:in
`initialize'
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/stomp/connection.rb:141:in
`new'
from
C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/stomp/connection.rb:141:in
`open'
from listener.rb:22:in `<main>'
and im not sure what is happanin or what is wrong also i get same error with
ruby publisher when i run that
Im using activemq 5.7.0, ruby 193, stomp 1.2.6
I hope that makes sense to everyone and thanks for any help
TONY
--
View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: help: ruby listener/publisher
Posted by Torsten Mielke <to...@fusesource.com>.
Hi Tony,
Instead of using the broker: argument to the bin/activemq script, it may be easier to put the broker config into a separate configuration file and reference that file at startup, e.g.
./activemq xbean:file:../conf/my-broker-config.xml
It is easier to further fine tune the broker configuration that way.
You can copy and paste the stomp transport connector definition from activemq-stomp.xml or you can simply run the broker using that configuration file
./activemq xbean:file:../conf/activemq-stomp.xml
Not sure if the broker: argument to the bin/activemq script still works 100%ly correctly.
I just gave it a quick test using
./activemq broker:(tcp://localhost:61613)
and the broker would not startup but raise errors. Using a proper xml configuration file may hence be easier.
Also, there should not be any problem with enabling JMX if you run the broker standalone.
If it runs embedded and the JVM is already JMX enabled, it will register into that JMX context.
Hope this helps,
Torsten Mielke
torsten@fusesource.com
tmielke.blogspot.com
On Nov 20, 2012, at 1:11 PM, topsweep1506 wrote:
> Hi torsten sorry for bein a pain but im gettin stuck with the broker config,
> what i was goin to do was make my own config file using the uri statement
> (broker:(tcp://localhost:61616,network:static:tcp://remotehost:61616)?persistent=false&useJmx=false)
> without using the jmx as i think thats were im getting the problems with
> java
>
> Only problem is im not sure how to do it, if i run the conf\activemq.xml
> broker file it takes me to a explorer window and thats it
>
> And how would i configure the uri statement to get a stomp listener on port
> 61618
>
> Sorry for all the questions
>
> Thanks Tony
Re: help: ruby listener/publisher
Posted by Torsten Mielke <to...@fusesource.com>.
Hi Tony,
As I mentioned in my previous email, this error is generally thrown if the port (61618 in your example) is already in use by another process.
Stop your broker and run
netstat -an | grep 61618
and if you see something like this line being printed
tcp4 0 0 *.61618 *.* LISTEN
then its the proof that this port is already in use.
Only one process can use an individual port on a machine.
Find out what application uses this port (the tools to use depend on the OS used) and quit or reconfigure that application to use a different port.
Alternatively change your broker configuration to use another free port other than 61618.
Also, is the hostname datafeeds.networkrail.co.uk the correct hostname for this machine?
Does the broker startup correctly when using stomp://localhost:61618 ? If so, then your machine name datafeeds.networkrail.co.uk could be incorrect.
Torsten Mielke
torsten@fusesource.com
tmielke.blogspot.com
On Nov 22, 2012, at 5:15 AM, topsweep1506 wrote:
> Hi Torsten
>
> Here are a few of the error messages ive been recieving when running
> activemq-stomp-my.xml (all i done to the default file was change the port
> and address to <transportConnector name="stomp"
> uri="stomp://datafeeds.networkrail.co.uk:61618"/> )
>
> ERROR | Failed to load: URL
> [file:/c:/apache-activemq-5.7.0/conf/activemq-stomp-my.xml], reason: Error
> creating bean with name 'org.apache.activemq.xbean.XBeanBrokerService#0'
> defined in URL [file:/c:/apache-activemq-5.7.0/conf/activemq-stomp-my.xml]
> : Invocation of init method failed; nested exception is java.io.IOException:
> Transport Connector could not be registered in JMX: Failed to bind to server
> socket: stomp://datafeeds.networkrail.co.uk:61618 due to:
> java.net.BindException: Cannot assign
> requested address: JVM_Bind
>
> That is the main error message that appears
>
> TONY
Re: help: ruby listener/publisher
Posted by topsweep1506 <to...@yahoo.co.uk>.
Hi Torsten
Here are a few of the error messages ive been recieving when running
activemq-stomp-my.xml (all i done to the default file was change the port
and address to <transportConnector name="stomp"
uri="stomp://datafeeds.networkrail.co.uk:61618"/> )
ERROR | Failed to load: URL
[file:/c:/apache-activemq-5.7.0/conf/activemq-stomp-my.xml], reason: Error
creating bean with name 'org.apache.activemq.xbean.XBeanBrokerService#0'
defined in URL [file:/c:/apache-activemq-5.7.0/conf/activemq-stomp-my.xml]
: Invocation of init method failed; nested exception is java.io.IOException:
Transport Connector could not be registered in JMX: Failed to bind to server
socket: stomp://datafeeds.networkrail.co.uk:61618 due to:
java.net.BindException: Cannot assign
requested address: JVM_Bind
That is the main error message that appears
TONY
--
View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540p4659665.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: help: ruby listener/publisher
Posted by topsweep1506 <to...@yahoo.co.uk>.
Ive even got a pdf file here telling me how to do it but following these
instructions dosnt work either just wish it was as easy as it says in the
pdf file lol
In the pdf file these is the way it says to do it
6.3.3 Configure the broker
Check that the the Stomp connector is present in the broker configuration
file (in InstallDir/conf/activemq.xml) as follows:
<beans>
...
<transportConnectors>
...
<transportConnector name="stomp"
uri="stomp://datafeeds.networkrail.co.uk:61618"/>
</transportConnectors>
...
</beans>
Run the default broker by entering the following at a command line:
activemq
The default broker automatically takes its configuration from the default
configuration file.
6.3.5 Run the Ruby listener
To connect the listener tool to the stomp://hostname:port endpoint (Stomp
over TCP), change directory
to ActiveMQInstallDir/example/ruby and enter the following command:
ruby listener.rb
6.3.6 Run the Ruby publisher
To connect the publisher tool to the stomp://hostname:port endpoint (Stomp
over TCP), change
directory to ActiveMQInstallDir/example/ruby and enter the following
command:
ruby publisher.rb
If only it was that easy but im not giving up yet
TONY
--
View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540p4659622.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: help: ruby listener/publisher
Posted by Torsten Mielke <to...@fusesource.com>.
Hi Tony
> Hi
>
> I seem to be gettin somewere now ive got the default brokers running now
> (activemq.xml/activemq-stomp.xml) but when i try to configure them to what i
> want they are returning error messages
> When i try and change the transport connector host/port from the default to
> what i want in activemq-stomp.xml and run the xml file i get error messages
> saying
>
> Address allready in use
> failed to bind to server socket
> cannot assign requested address
> transport connector couldnt be registered in JMX
Some other application seem to already use that port in question. Shut down the broker and run netstat -an | grep <port you want the broker to use>.
A snippet from the brokers logging output with the error message would also be useful.
But bottom line is that this port seems to be in use by some other application already.
Either quit and reconfigure that other application or assign a different free port number to your JMS broker.
>
> I got all them from just changing the host and port of the activemq-stomp
> file and when i put it backk to default it works no problems
Yes, makes sense, see comment above.
> THANKS
>
> TONY
>
Torsten Mielke
torsten@fusesource.com
tmielke.blogspot.com
Re: help: ruby listener/publisher
Posted by topsweep1506 <to...@yahoo.co.uk>.
Hi
I seem to be gettin somewere now ive got the default brokers running now
(activemq.xml/activemq-stomp.xml) but when i try to configure them to what i
want they are returning error messages
When i try and change the transport connector host/port from the default to
what i want in activemq-stomp.xml and run the xml file i get error messages
saying
Address allready in use
failed to bind to server socket
cannot assign requested address
transport connector couldnt be registered in JMX
I got all them from just changing the host and port of the activemq-stomp
file and when i put it backk to default it works no problems
THANKS
TONY
--
View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540p4659610.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: help: ruby listener/publisher
Posted by Torsten Mielke <to...@fusesource.com>.
You seem to be passing this argument to the activemq script:
xbean:file:c:\apache-activemq-5.7.0\conf\activemq-stomp-my.xml
These \ characters cause problems on Windows shells.
Instead try using
xbean:file:/c:/apache-activemq-5.7.0/conf/activemq-stomp-my.xml
or a variation of this.
Torsten
On Nov 20, 2012, at 4:17 PM, topsweep1506 wrote:
> Hi thorsten
>
> ive done what u told me with the broker file and the activemq-stomp.xml and
> im getting these errors which i think are java related
>
> Warning: JAVA_HOME environment variable is not set.
>
> Java Runtime: Oracle Corporation 1.7.0_09 C:\Program Files\Java\jre7
> Heap sizes: current=1004928k free=994439k max=1004928k
> JVM args: -Dcom.sun.management.jmxremote -Xms1G -Xmx1G
> -Djava.util.logging.config.file=logging.properties
> -Dactivemq.classpath=c:\apache-activemq-5.7.0\bin\..\conf;c:\apache-activemq-5.7.0\bin\../conf;c:\apache-activemq-5.7.
> emq.home=c:\apache-activemq-5.7.0\bin\..
> -Dactivemq.base=c:\apache-activemq-5.7.0\bin\..
> -Dactivemq.conf=c:\apache-activemq-5.7.0\bin\..\conf
> -Dactivemq.data=c:\apache-activemq-5.7.0\bin\..\data
> -Djava.io.tmpdir=c:\apache-active
> mp
> Extensions classpath:
>
> [c:\apache-activemq-5.7.0\bin\..\lib,c:\apache-activemq-5.7.0\bin\..\lib\camel,c:\apache-activemq-5.7.0\bin\..\lib\optional,c:\apache-activemq-5.7.0\bin\..\lib\web,c:\apache-activemq-5.7.0\bin\..\lib\extra]
> ACTIVEMQ_HOME: c:\apache-activemq-5.7.0\bin\..
> ACTIVEMQ_BASE: c:\apache-activemq-5.7.0\bin\..
> ACTIVEMQ_CONF: c:\apache-activemq-5.7.0\bin\..\conf
> ACTIVEMQ_DATA: c:\apache-activemq-5.7.0\bin\..\data
> ERROR: java.net.URISyntaxException: Illegal character in opaque part at
> index 13: xbean:file:c:\apache-activemq-5.7.0\conf\activemq-stomp-my.xml
> java.net.URISyntaxException: Illegal character in opaque part at index 13:
> xbean:file:c:\apache-activemq-5.7.0\conf\activemq-stomp-my.xml
> at java.net.URI$Parser.fail(Unknown Source)
> at java.net.URI$Parser.checkChars(Unknown Source)
> at java.net.URI$Parser.parse(Unknown Source)
> at java.net.URI.<init>(Unknown Source)
> at
> org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:85)
> at
> org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57)
> at
> org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:148)
> at
> org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57)
> at
> org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:90)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
> at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
> at java.lang.reflect.Method.invoke(Unknown Source)
> at org.apache.activemq.console.Main.runTaskClass(Main.java:262)
> at org.apache.activemq.console.Main.main(Main.java:115)
>
> Im not sure whats goin on though or if its easier i could send u the 2 files
> to see were im goin wrong
>
> TONY
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540p4659591.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Torsten Mielke
torsten@fusesource.com
tmielke.blogspot.com
Re: help: ruby listener/publisher
Posted by topsweep1506 <to...@yahoo.co.uk>.
Hi thorsten
ive done what u told me with the broker file and the activemq-stomp.xml and
im getting these errors which i think are java related
Warning: JAVA_HOME environment variable is not set.
Java Runtime: Oracle Corporation 1.7.0_09 C:\Program Files\Java\jre7
Heap sizes: current=1004928k free=994439k max=1004928k
JVM args: -Dcom.sun.management.jmxremote -Xms1G -Xmx1G
-Djava.util.logging.config.file=logging.properties
-Dactivemq.classpath=c:\apache-activemq-5.7.0\bin\..\conf;c:\apache-activemq-5.7.0\bin\../conf;c:\apache-activemq-5.7.
emq.home=c:\apache-activemq-5.7.0\bin\..
-Dactivemq.base=c:\apache-activemq-5.7.0\bin\..
-Dactivemq.conf=c:\apache-activemq-5.7.0\bin\..\conf
-Dactivemq.data=c:\apache-activemq-5.7.0\bin\..\data
-Djava.io.tmpdir=c:\apache-active
mp
Extensions classpath:
[c:\apache-activemq-5.7.0\bin\..\lib,c:\apache-activemq-5.7.0\bin\..\lib\camel,c:\apache-activemq-5.7.0\bin\..\lib\optional,c:\apache-activemq-5.7.0\bin\..\lib\web,c:\apache-activemq-5.7.0\bin\..\lib\extra]
ACTIVEMQ_HOME: c:\apache-activemq-5.7.0\bin\..
ACTIVEMQ_BASE: c:\apache-activemq-5.7.0\bin\..
ACTIVEMQ_CONF: c:\apache-activemq-5.7.0\bin\..\conf
ACTIVEMQ_DATA: c:\apache-activemq-5.7.0\bin\..\data
ERROR: java.net.URISyntaxException: Illegal character in opaque part at
index 13: xbean:file:c:\apache-activemq-5.7.0\conf\activemq-stomp-my.xml
java.net.URISyntaxException: Illegal character in opaque part at index 13:
xbean:file:c:\apache-activemq-5.7.0\conf\activemq-stomp-my.xml
at java.net.URI$Parser.fail(Unknown Source)
at java.net.URI$Parser.checkChars(Unknown Source)
at java.net.URI$Parser.parse(Unknown Source)
at java.net.URI.<init>(Unknown Source)
at
org.apache.activemq.console.command.StartCommand.runTask(StartCommand.java:85)
at
org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57)
at
org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand.java:148)
at
org.apache.activemq.console.command.AbstractCommand.execute(AbstractCommand.java:57)
at
org.apache.activemq.console.command.ShellCommand.main(ShellCommand.java:90)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.apache.activemq.console.Main.runTaskClass(Main.java:262)
at org.apache.activemq.console.Main.main(Main.java:115)
Im not sure whats goin on though or if its easier i could send u the 2 files
to see were im goin wrong
TONY
--
View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540p4659591.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: help: ruby listener/publisher
Posted by Torsten Mielke <to...@fusesource.com>.
It seems to be necessary to fully escape the () in the broker command, e.g.
./activemq console broker:\\\(tcp://localhost:61613\\\)
It should then startup.
On Nov 20, 2012, at 1:11 PM, topsweep1506 wrote:
> Hi torsten sorry for bein a pain but im gettin stuck with the broker config,
> what i was goin to do was make my own config file using the uri statement
> (broker:(tcp://localhost:61616,network:static:tcp://remotehost:61616)?persistent=false&useJmx=false)
> without using the jmx as i think thats were im getting the problems with
> java
>
> Only problem is im not sure how to do it, if i run the conf\activemq.xml
> broker file it takes me to a explorer window and thats it
>
> And how would i configure the uri statement to get a stomp listener on port
> 61618
>
> Sorry for all the questions
>
> Thanks Tony
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540p4659572.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Torsten Mielke
torsten@fusesource.com
tmielke.blogspot.com
Re: help: ruby listener/publisher
Posted by topsweep1506 <to...@yahoo.co.uk>.
Hi torsten sorry for bein a pain but im gettin stuck with the broker config,
what i was goin to do was make my own config file using the uri statement
(broker:(tcp://localhost:61616,network:static:tcp://remotehost:61616)?persistent=false&useJmx=false)
without using the jmx as i think thats were im getting the problems with
java
Only problem is im not sure how to do it, if i run the conf\activemq.xml
broker file it takes me to a explorer window and thats it
And how would i configure the uri statement to get a stomp listener on port
61618
Sorry for all the questions
Thanks Tony
--
View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540p4659572.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: help: ruby listener/publisher
Posted by Torsten Mielke <to...@fusesource.com>.
Hi Tony,
The conf/ folder contains a couple of different broker configurations for illustration purposes.
If you run the broker using bin/activemq, it will by default use the configuration in conf/activemq.xml.
So it is this broker config file that you need to change (or supply a different configuration to be used at startup using the xbean:file: argument).
Upon startup the broker should print out that it created a stomp listener on port 61618.
In your ruby clients you need to ensure that they connect to the url stomp://datafeeds.networkrail.co.uk:61618 and not to some perhaps hardcoded default url.
The connection should then work.
Hope this helps,
Torsten Mielke
torsten@fusesource.com
tmielke.blogspot.com
On Nov 19, 2012, at 9:04 PM, topsweep1506 wrote:
> Hi im using the activemq broker ive added this to the conf\activemq.xml file
> or do i add this to the conf\activemq-stomp.xml?
>
> <beans>
> ...
> <transportConnectors>
> ...
> <transportConnector name="stomp"
> uri="stomp://datafeeds.networkrail.co.uk:61618"/>
> </transportConnectors>
> ...
> </beans>
>
> i havnt changed anything in the ruby listener/producer rb files
>
> TONY
Re: help: ruby listener/publisher
Posted by topsweep1506 <to...@yahoo.co.uk>.
Hi im using the activemq broker ive added this to the conf\activemq.xml file
or do i add this to the conf\activemq-stomp.xml?
<beans>
...
<transportConnectors>
...
<transportConnector name="stomp"
uri="stomp://datafeeds.networkrail.co.uk:61618"/>
</transportConnectors>
...
</beans>
i havnt changed anything in the ruby listener/producer rb files
TONY
--
View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540p4659547.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: help: ruby listener/publisher
Posted by Torsten Mielke <to...@fusesource.com>.
What broker url did you specify?
Assuming you are talking the stomp protocol, make sure the broker configuration starts a stomp transport listener, typically on port 61613. Use the same host:port in your ruby client.
Torsten Mielke
torsten@fusesource.com
tmielke.blogspot.com
On Nov 19, 2012, at 11:25 AM, topsweep1506 wrote:
> Hi im new to activemq and using ruby ive got everything sorted out scripts
> are all working but ive hit a problem with the ruby listener.rb and ruby
> publisher.rb every time i try to run the script for ruby listener i get this
> error message
>
>
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:165:in
> `initialize': No connection could be made because the target machine
> actively refused it. - connect(2) (Errno::ECONNREFUSED)
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:165:in
> `open'
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:165:in
> `block in open_tcp_socket'
> from C:/Ruby193/lib/ruby/1.9.1/timeout.rb:54:in `timeout'
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:164:in
> `open_tcp_socket'
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/netio.rb:293:in
> `open_socket'
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/utils.rb:110:in
> `block in socket'
> from <internal:prelude>:10:in `synchronize'
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/connection/utils.rb:103:in
> `socket'
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/stomp/connection.rb:118:in
> `initialize'
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/stomp/connection.rb:141:in
> `new'
> from
> C:/Ruby193/lib/ruby/gems/1.9.1/gems/stomp-1.2.6/lib/stomp/connection.rb:141:in
> `open'
> from listener.rb:22:in `<main>'
>
> and im not sure what is happanin or what is wrong also i get same error with
> ruby publisher when i run that
>
> Im using activemq 5.7.0, ruby 193, stomp 1.2.6
>
> I hope that makes sense to everyone and thanks for any help
>
> TONY
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/help-ruby-listener-publisher-tp4659540.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.