Re: Can you help with these exceptions??

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

Re: Can you help with these exceptions??

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

Re: Where are the data files stored?

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:

Can you explain how this part works?

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

Where are the data files stored?

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

Re: EXCEPTION - The Consumer has been Closed

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

Messages not getting dispatched??

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.

Messages Stuck In Queue

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=3500wireFormat.tightEncodingEnabled=truenms.PrefetchPolicy.QueuePrefetch=1 java.exe process memory usage gets to

Re: Memory leak??

Hi Christian, here is my complete config. Its pretty standard. FYI: I tried bumping up the systemUsage memoryUsage memoryUsage limit=64 mb/ /memoryUsage to 128 mb, and I still get the error. I have producer flow control disabled as

Re: Memory leak??

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

Re: Memory leak??

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

Memory leak??

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... *

No IConnectionFactory implementation issue...

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=truejms.useAsyncSend=truejms.useCompression=true

RE: Is this possible with ActiveMQ?

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:

Re: Is this possible with ActiveMQ?

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

RE: Is this possible with ActiveMQ?

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 context:

RE: Is this possible with ActiveMQ?

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

Re: Trying to set up non-persistant messaging...

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

Trying to set up non-persistant messaging...

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, of

Re: Trying to set up non-persistant messaging...

Here you go. I am only use Queues at this time. beans xmlns=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

Producer is blocking...

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),

Re: Producer is blocking...

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

Multiple consumers not consuming

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:

Re: Multiple consumers not consuming

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

Re: Multiple consumers not consuming

Here is my ActiveMQ.xml: beans xmlns=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

Re: Multiple consumers not consuming

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:

Purge policy not working?

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.

Re: Purge policy not working?

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

Re: Purge policy not working?

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

Re: Purge policy not working?

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

Question about Multiple Consumers / Same Queue

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