The way our application is set up right now is that:
We have 200 consumers that can process jobs. A message is a single job (400k
of data as noted above). On start up, the consumer connects to the advisory
queue and monitors queue adds & deletes. When it gets a queue add
notification, it starts co
No network issues that I'm aware of. There are firewalls all over the place
around here lol, but they are opened on port 25055 (for our previous
generation distributed app) which is why I configured ActiveMQ to use that
port. ActiveMQ does work, messages are getting through and processed, we
just h
Having lots of stability issues (5.8.0 on Win64 2008 Server 64GB RAM).
Messages are IBytesMessages, typically around 400k. Typically 3 to 4 queues
running at once. 200 consumers. Checked the log and seeing a TON of
exceptions:
1) INFO | jvm 1| 2013/08/26 15:09:32 | WARN | Transport Connecti
Yes, the data directory is restored correctly. Java.exe and Wrapper.exe are
gone from task manager. Old queues randomly appear when I restart. If I try
to delete them manually, I often get an exception in the web console and/or
the delete link does nothing.
--
View this message in context:
http
Man, my install seems corrupt. I stop & start the service (Windows 64) and
old queues randomly pop up. I've deleted the data directory completely.
Java.exe and wrapper.exe are completely gone. Where the heck are you guys
pulling these from???
If I try to delete the queues and topics, the web conso
So my set up is that each producer creates 2 queues (send queue and recv
queue). When a consumer connects, it listens to the advisory queue and
attaches to all the send queues. So for example, a consumer may be watching
10 send queues.
The main work loop is:
for (;;)
{
foreach queue
Wait
Haha :)
Our scenario is that we have 200 consumers connecting to the server. They
listen to the advisory queue so they know when queues are added / removed.
Each producer creates two new queues. A send queue & a recv queue.
When a queue is created, the consumers subscribe to it.
Main work loop
What does it mean when we get this exception? Using C# / NMS. 5.9 Snapshot.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/EXCEPTION-The-Consumer-has-been-Closed-tp4670465.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Having an issue where consumers are not getting messages from the queue for
some reason:
No Of Pending Messages 27
Number of Consumers 181
Messages Enqued 99
Messages Dequed 72
As you can see, I have 181 consumers connected and only submitted 99
messages, but 27 of them didn't get dispatched.
If
We are having issues with messages getting stuck in the queue.
OS: Windows 2008 Server 64-bit
ApacheMQ: 5.8.0 64-bit
Connection String:
failover:(tcp://{0}:{1})?initialReconnectDelay=3500&wireFormat.tightEncodingEnabled=true&nms.PrefetchPolicy.QueuePrefetch=1
java.exe process memory usage gets to
Hmm... I switched the response queue to be a "permanent" queue and it looks
like it doesn't have the same memory leak issue.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Memory-leak-tp4666300p4666412.html
Sent from the ActiveMQ - User mailing list archive at Nabble.co
I am using persistent messages. I have not mucked with any of the backing or
memory options, so thats all stock.
The way I have this working right now is (on the consumer side):
Consumer creates IMessageConsumer on ActiveMQ.Advisory.Queue
Consumer uses Listener += method
when I get a Queue Add a
Hi Christian, here is my complete config. Its pretty standard. FYI: I tried
bumping up the
to 128 mb, and I still get the error. I have producer flow control disabled
as you can see. How do I "check using jmx" in a Windows environ
Any advice on this issue guys?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Memory-leak-tp4666300p4666394.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Basic issue is that on first run, everything works perfectly... on 2nd run,
the consumer hangs responding to the producer (producer created temp queue).
NOTE: I kill the producer in the middle to test recovery...
Will give you a brief summary at first so I don't overload you with info
lol...
* OS
Per a previous thread, it was suggested to me to have each producer create
its own queue so that I can implement a "round-robin the producers" type
scheme... so I'm doing something like:
_destination = SessionUtil.GetDestination(_session, _strQueueName);
_strQueueName is initialized as String.For
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
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
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
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
Ok, I tried setting producer.DeliveryMode = MsgDeliveryMode.NonPersistent; I
have removed the Persistent=false tag from the broker, but I'm still running
out of memory on the broker. Any ideas?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Trying-to-set-up-non-persista
How do I call setDeliveryMode from the C# NMS wrappers? I am using the .NET
wrappers, not the Java directly. Do you have more info on the
forcePersistencyModeBrokerPlugin? I was unable to find anything.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Trying-to-set-up-non
My consumer prefetch is 1 for all consumers. I have 10 consumers right now
for testing, but will ramp up to 400.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Trying-to-set-up-non-persistant-messaging-tp4666127p4666155.html
Sent from the ActiveMQ - User mailing list arc
Here you go. I am only use Queues at this time.
http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframewor
Trying to set up my ActiveMQ to be non persistent so I can get it as fast as
possible. We don't need to re-queue messages if the queue is restarted. As I
have it right now, it takes 50ms for a 1MB send. When I add
persistance="false" to the broker tag, it drops down to 15ms for a 1MB send.
Issue, o
Yeah, its definitely "Toggling" between the two clients. I added debug
messages:
ClientA
Service started... Press [Enter] to exit...
GOT MESSAGE: 4/19/2013 4:32:24 PM
FINISHED MESSAGE: 4/19/2013 4:32:35 PM
GOT MESSAGE: 4/19/2013 4:32:35 PM
FINISHED MESSAGE: 4/19/2013 4:32:45 PM
GOT MESSAGE: 4/19
Here is my ActiveMQ.xml:
http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spri
There is only a single machine involved for testing. Windows 7 PC, so I'm
using the NMS wrappers.
There is one instance of the Producer. It is submitting 1MB IBytesMessages
(about 753 of them). Producer flow control is turned off as show in the XML
snippet above. Everything else in the activemq.xm
I've RTFM'ed :) and I think I've got everything covered, I know this worked
at some point, but for whatever reason, it's no longer working.
I'm using the latest 5.8.0 on Windows 7.
MachineA is running the broker. Only changes to the config are the port #
and turning off producer flow control:
Good call (sort of) :). Turned off producer flow control and it seems like
its not getting stuck anymore. However, now its throwing a few exceptions
when I get to around ~500 messages:
A first chance exception of type 'System.IO.EndOfStreamException' occurred
in mscorlib.dll
Additional information
Using ActiveMQ 5.8 on a Windows 7 PC 8GB of RAM through the C# NMS wrappers.
I have a single queue, configuration is pretty much stock out of the box
except for changing the port to get through the firewall.
I'm submitting messages correctly, but for some reason, after a while (~150
messages), Sen
Is it possible to use ActiveMQConnection from C#? I only have a
Apache.Nms.ActiveMQ.dll and a Apache.Nms.dll. Is there a different DLL I
need to reference?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Purge-policy-not-working-tp4665624p4665639.html
Sent from the Activ
So there is no way to handle this except trying to send the response and
catching the exception? This is not good in my scenario because processing a
message can take up to 1 minute. I can't use TTL because if the queue is
backed up, I do not want messages to die. Only time I want the messages to
d
ceposta wrote
> What version are you using?
>
> How are you seeing that messages are not purged? When the connection goes
> away, the temp destination should go away as well.
I am using 5.8.0 latest. I clear everything out and I have 0 messages and 0
consumers. I run the producer and it generates
I have a producer who posts, say, 1000 messages to the queue and specifies a
temp response queue for the replies. All works correctly, but if I shut down
the producer process before all the replys are processed, I get the
Apache.NMS.InvalidDestinationException from the clients who are responding.
E
Brand new to ActiveMQ and enterprise queues in general, but I am trying this
out for a new project. Working in C#.
Set up 2 console apps. One (AppA) sends 1000 messages to the TEST queue and
then waits for responses. The other one is the "consumer" (AppB). Listens to
the TEST queue and processes m
38 matches
Mail list logo
