Hello,
I am trying to consume messages off an ActiveMQ queue (ActiveMQ 5.x)
sent by a ruby STOMP client. The messages are being sent, and I can
see them on the ActiveMQ web portal. The message text contains a
string, which I also see in the portal.
However, when I receive the message in
Yeah, the web console is terrible. I don't trust it all anymore. Which kind
of sucks because reported numbers like pending count, number of consumers,
etc are nice to know.
Sigh, I'll try testing it again with a test queue and see if the load
balancing is happening correctly.
Thanks for the help
I don't see anything obviously wrong with the config files. I
normally give each networkConnector a unique name attribute, but I
don't think that would cause it to not work. I don't typically use
the Web console, though (I think issues like the negative message
count are known) -- to test it "the
Actually I have refined my question further:
There would be a queue that has messages
sitting on it. This queue has a listener that listens for messages, picks up
a certain message (FIFO perhaps), and sends it off to a different queue
(channel) based on some information in a header field that iden
Actually I have refined my question further:
There would be a queue that has messages
sitting on it. This queue has a listener that listens for messages, picks up
a certain message (FIFO perhaps), and sends it off to a different queue
(channel) based on some information in a header field that iden
Joe Fernandez wrote:
Ben,
I just ran a quick test with my 5.1 setup and everything worked as expected.
With the networkConnector below, only messages destined for queues with a
prefix of "Q." were excluded from being forwarded and only messages destined
for topics with a prefix of "local." were
I rebooted queue1 and looked in the data/activemq.log file and saw the
following line:
2008-10-13 13:55:45,311 [EMAIL PROTECTED] INFO DemandForwardingBridge
- Network connection between vm://queue1#0 and
tcp:///10.17.48.92:61616(queue2) has been established.
Does this mean that it's wor
Here they are:
http://www.nabble.com/file/p19962668/queue1.xml queue1.xml
http://www.nabble.com/file/p19962668/queue2.xml queue2.xml
Thanks,
-- Joel
ammulder wrote:
>
> Could you post the config files for both servers just for a sanity check?
>
> Thanks,
> Aaron
>
>
--
View this
Could you post the config files for both servers just for a sanity check?
Thanks,
Aaron
On Mon, Oct 13, 2008 at 4:15 PM, jpoloney <[EMAIL PROTECTED]> wrote:
>
> Yes, I can telnet into the IP addresses from both machines. So, queue1 can
> telnet into queue2 and queue2 and telnet into queue1.
On Mon, Oct 13, 2008 at 1:24 PM, ilango_g <[EMAIL PROTECTED]> wrote:
>
> Hi
> I have the following scenario: There would be a queue that has messages
> sitting on it. This queue has a listener that listens for messages and
> routes a certain message to a different queue (channel). So the queue acts
Hi
I have the following scenario: There would be a queue that has messages
sitting on it. This queue has a listener that listens for messages and
routes a certain message to a different queue (channel). So the queue acts
as a Content-Based Router that examines the message content and routes the
me
Yes, I can telnet into the IP addresses from both machines. So, queue1 can
telnet into queue2 and queue2 and telnet into queue1. When I telnet in, I
can see messages going across and various output and stuff.
-- Joel
bsnyder wrote:
>
> Can you see the ActiveMQ port from each machine via ping a
Ben,
I just ran a quick test with my 5.1 setup and everything worked as expected.
With the networkConnector below, only messages destined for queues with a
prefix of "Q." were excluded from being forwarded and only messages destined
for topics with a prefix of "local." were excluded.
On Mon, Oct 13, 2008 at 12:35 PM, jpoloney <[EMAIL PROTECTED]> wrote:
>
> It is set to "queue2". All of the properties are set to what you would think
> they are (for each queue). I double checked again and there aren't any
> mistakes.
>
> Thoughts?
Can you see the ActiveMQ port from each machine
It is set to "queue2". All of the properties are set to what you would think
they are (for each queue). I double checked again and there aren't any
mistakes.
Thoughts?
Joe Fernandez wrote:
>
> Make sure that your brokerName property for Queue 2 is set to "queue2" and
> not "queue1".
>
> dat
On Mon, Oct 13, 2008 at 12:04 PM, ilango_g <[EMAIL PROTECTED]> wrote:
>
> Hi
> Is this MessageListener like a helper class (singleton perhaps) that you can
> call when a servlet is init() ed?
Yes, that's one area where it is used in ActiveMQ.
Bruce
--
perl -e 'print unpack("u30","D0G)[EMAIL
PRO
Hi
Is this MessageListener like a helper class (singleton perhaps) that you can
call when a servlet is init() ed?
thanks
ilango
Ramesh Mandaleeka wrote:
>
> Hi,
>
> We are using multiple reply queues and more or less the data format is
> same in all the reply queues. Is there a away to create
Joe Fernandez wrote:
See the following JIRA
https://issues.apache.org/activemq/browse/AMQ-1629
Joe
Get a free ActiveMQ user guide @ http://www.ttmsolutions.com
That JIRA claims the fix version is 5.1.0. My issue was with 5.1.0.
Should I take that to mean
that the fix was released as part
See the following JIRA
https://issues.apache.org/activemq/browse/AMQ-1629
Joe
Get a free ActiveMQ user guide @ http://www.ttmsolutions.com
Benjamin April wrote:
>
>
> Greetings,
>
> I have 2 ActiveMQ nodes (both 5.1.0). They are linked via static TCP
> networkConnector statements:
>
>
On Mon, Oct 13, 2008 at 8:54 AM, Eddie Yee <[EMAIL PROTECTED]> wrote:
> Hi Bruce,
>
> I looked at the configuration, but it appears I need to download
> jetty-plus-6.1.4.jar. When looking on the mortbay.org site, I don't see any
> references to JettyPlus on their download site:
> http://docs.cod
Greetings,
I have 2 ActiveMQ nodes (both 5.1.0). They are linked via static TCP
networkConnector statements:
[host-1]
[host-2]
Everything works fine. If Host-2 has a subscriber on topic foo and
someone sends a message to topic foo on host-1 the subscriber gets a copy.
When I add the
Thanks for testing this. I also saw your follow up reply where the
maxInactivityDuration option solved the zombie issue. Looking at the wire
format page you linked, you are correct. The option should be turned on by
default. I will log a JIRA to have it turned on to 30 seconds by default.
Best,
Hi Bruce,
I looked at the configuration, but it appears I need to download
jetty-plus-6.1.4.jar. When looking on the mortbay.org site, I don't see any
references to JettyPlus on their download site:
http://docs.codehaus.org/display/JETTY/Downloading+Jetty
When I google for it, I find a link
On Wed, Oct 1, 2008 at 1:42 PM, Ramesh Mandaleeka <[EMAIL PROTECTED]> wrote:
>
> Hi,
>
> We are using multiple reply queues and more or less the data format is same
> in all the reply queues. Is there a away to create a MessageListener with
> out mentioning the destination name?
MessageListeners a
On Fri, Oct 3, 2008 at 11:49 AM, jmychasiw <[EMAIL PROTECTED]> wrote:
>
> Greetings:
>We are currently evaluating ActiveMq 5.x
>
>We are trying to decide between AMQMessageStore and jdbc persistence to
> Oracle. The documentation seems to advocate for AMQMessageStore over jdbc.
> Our projec
On Tue, Oct 7, 2008 at 11:25 AM, devdev <[EMAIL PROTECTED]> wrote:
>
> Thank you Bruce for the suggestion. I've looked at Camel and it's quite
> interesting. However in my scenario, the i am dequeueing from one activemq
> instance and pushing the message into another activemq queue. Both activem
On Tue, Oct 7, 2008 at 5:03 PM, activemqny <[EMAIL PROTECTED]> wrote:
>
> Can you explain why after ALL messages have been delivered to consumer,
> memory usage stays at 100%?
I do notice that every thread in the TryJmsClient does not close any
of the resources it creates (i.e., connection, sessio
I don't think so, I created the session already ThreadLocal since it is known
to be thread-unsafe and the problem was still there..
-Original Message-
From: Joe Fernandez [mailto:[EMAIL PROTECTED]
Sent: maandag 13 oktober 2008 13:06
To: users@activemq.apache.org
Subject: Re: Concurrent
Sessions are single-threaded. So could the issue be related more to your use
of sessions?
Joe
Get a free ActiveMQ user guide @ http://www.ttmsolutions.com
Steven Van Loon-2 wrote:
>
> Hi all,
>
> Is anybody aware of possible problems when (re)using a same Connection to
> activeMQ by different
Hi all,
Is anybody aware of possible problems when (re)using a same Connection to
activeMQ by different threads? According to the JMS specification,
implementations should support concurrent use of Connections, so I created one
connection to be used by all consumer / producers.
However, I expe
30 matches
Mail list logo
