Thank you for reply.
Please let me explain background of this question.
I am designing enterprise integration architecture using activemq to
communicate
multiple systems in a company.
Initially, I designed to put queues among systems. But from the point of
view of
flexibility I came to think o
I have 1 machine acting as server / broker and currently 20 VMs acting as
clients. Will eventually ramp up to 400. Producers may submit anywhere from
1 job at a time to thousands. I think we are going to have 1 producer that
runs "full time" as a go-forward process and then any number of producers
Looks like you might be able to use the statistics plugin
It appears that you can query any queue and find out how many messages are
in it.
So if you can use fixed queue names this should work.
http://activemq.apache.org/statisticsplugin.html
If your clients are all threads so you have a master process reading the
add/del sounds OK.
If you have to restart your client it sends a message to the master to send
all current jobs to you so you can crank off all the threads.
Then add/del works after that.
You'll want to think this through care
Hmm... one queue for each producer...
Hmm... guess I would need a "System Queue" that gets "queue created" /
"queue deleted" notifications? that'll send the list of queues to the
clients? or is there some built in mechanism for that? Keep in mind I'm
using C# / NMS.
--
View this message in con
You have another problem with priorities. If the priorities swamp the
system the low priority ones will never fire so you just reverse the problem
of starving the low priority.
Use one queue for each producer.
You just have to communicate the queue names to the consumers if your
producers are dy
I understand we have the 9 priorities... so my original plan to intersperse
the messages was to pick a random priority between 0 & 9 and assign that to
the message. In the long term, that should be an even distribution among
producers. My boss however complained that probably 1 ProducerB message wi
There can be any numbers of producers. I guess the boss just some how wants
the guy who has a few jobs to do to jump ahead in the line. Sure you can say
that on the whiteboard lol, but in practice...
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Is-this-possible-with-A
On 04/25/2013 04:59 PM, SledgeHammer wrote:
I understand the concept of a queue :)... first in, first out... I also
understand that we have 7 or so message priorities to work with. However, my
situation is where a message represents a "job". So we can have a situation
where ProducerA will submit
Two queues.
-Original Message-
From: SledgeHammer [mailto:gro...@firstam.com]
Sent: Thursday, April 25, 2013 4:00 PM
To: users@activemq.apache.org
Subject: Is this possible with ActiveMQ?
I understand the concept of a queue :)... first in, first out... I also
understand that we have 7
I understand the concept of a queue :)... first in, first out... I also
understand that we have 7 or so message priorities to work with. However, my
situation is where a message represents a "job". So we can have a situation
where ProducerA will submit 100,000 jobs and then ProducerB will come alon
Get this error on the following line of code:
IConnectionFactory factory = new NMSConnectionFactory(connectUri);
Error:
No IConnectionFactory implementation found for connection URI:
activemq:tcp://localhost:25055?wireFormat.tightEncodingEnabled=true&jms.useAsyncSend=true&jms.useCompression=true
I'm trying to figure out this behavior and what I may be doing wrong.
Topic is running on 5.7.0 broker
Multi-threaded consumer on a topic using this connection
tcp\://10.2.100.209\:61616?keepAlive=true,jms.prefetchPolicy.all=0
I'm testing my app under 2 different machines so I have 2 diff
>Is your producer blocking be cause its being flow controlled. You
>aren't acking the messages so space won't be free in memory usage until
>you do.
>
I may be missing something but I do not have any problem producing the 1000
messages to the queue.
My problem is consuming all these messages. Y
On 04/25/2013 07:00 AM, erngarfen wrote:
Hi all,
I've been struggling with this for a while now, but still can't get my
client to receive all the messages from a queue. I'm using ActiveMQ 5.8.0 as
the broker and ActiveMQ-CPP for the client (see simple test code below). At
the broker I have a que
Hi all,
I've been struggling with this for a while now, but still can't get my
client to receive all the messages from a queue. I'm using ActiveMQ 5.8.0 as
the broker and ActiveMQ-CPP for the client (see simple test code below). At
the broker I have a queue filled with 1000 messages (done from a s
Hi all,
Thanks for all your concerns and considerations. Yesterday I've made a
thread dump and as vaguely expected it was the main thread which was waiting
for a System.in.read() call that was requesting the call. For now I've
replaced it with
InputStreamReader reader = ne
17 matches
Mail list logo
