Start/Stop Consumer and duplicate message is received.

Hi, I'm using the following version apache-activemq-5.1-20080208.142256-20.zip I have like 500 messages pending in the broker and I have the following consumer: public void run() { //Create a connection Connection conn = null;

Re: Subscriber hangs when broker shutsdown

activemqnewbie wrote: All, After i shutdown my broker,i see my subscriber doen't shutsdown but hangs and doen't consumes any messages when i restart broker and publish message. I have to manually shutdown and restart the subscriber to consume messages.. I get below exception

Re: How to delete/remove the exampleA topic ?

I found the following information from another thread and it works: Hi, You can disable advisory support in your broker config file : broker brokerName=localhost useJmx=true advisorySupport=false Regards, Jonas wha wrote: Hi, I'm very new to activeMQ. I can't figure

Subscriber hangs when broker shutsdown

All, After i shutdown my broker,i see my subscriber doen't shutsdown but hangs and doen't consumes any messages when i restart broker and publish message. I have to manually shutdown and restart the subscriber to consume messages.. I get below exception ERROR2008/02/11 15:42:14.89318587569

Re: SQL Exception: The resulting value is outside the range for the data type INTEGER

Check the last_acked_id column value in activemq_acks table. Ack id might be too large for integer column. I had similar issue with selector column,alterd the table (column size) Stefan Arentz-2 wrote: Has anyone seen this one before? It looks like something internal to ActiveMQ's JDBC

Re: Problems with activemq on OS X 10.5.1

Hi, I was wondering if anyone had any ideas on this issue? It would be most appreciated. Gordon. Gordon Heydon wrote: I keep on getting a java.lang.NullPointerException at org.apache.activemq.network.DemandForwardingBridgeSupport.configureMessage(DemandForwardingBridgeSupport.java:545)

Re: Active MQ Client crash

Hi, After reading the documentation and the pthread code, I see what's going on, though I do think the pthread attribute and instance could be set to 0 in the Thread constructor. I definitely think there is a problem with my code which I'm trying to narrow down. Is there any way to

vm and activemq-data location

I'm completely new to the activemq, so I guess my question is basic. I am using activemq for JUnit testing. Therefore, I set to run it in vm mode since JUnit is ran by third party product that executes unit tests for entire application on separate machine regulary. So, there is no need to keep

Priority queue/semantics of consumer priority

I want to implement a priority queue (message delivery ordered by priority) and am trying to figure out what consumer priority means. After looking over the documentation ( http://activemq.apache.org/consumer-priority.html) and these email threads, the semantics of consumer priority are still not

Subscriber hangs when broker shutsdown

All, After i shutdown my broker,i see my subscriber doen't shutsdown but hangs and doen't consumes any messages when i restart broker and publish message. I have to manually shutdown and restart the subscriber to consume messages.. I get below exception ERROR2008/02/11 15:42:14.89318587569

How to delete/remove the exampleA topic ?

Hi, I'm very new to activeMQ. I can't figure out how to remove the exampleA queue or the ActiveMQ.Advisory.Consumer.Queue.example.A topic. Every time I delete it from the web admin interface it comes back. I don't know where to go or look to make it stop. Something is constantly publishing

Re: SQL Exception: The resulting value is outside the range for the data type INTEGER

Check the last_acked_id column value in activemq_acks table. Ack id might be too large for integer column. I had similar issue with selector column,alterd the table (column size) Stefan Arentz-2 wrote: Has anyone seen this one before? It looks like something internal to ActiveMQ's JDBC

Re: Unable to comile C++ client on VC++ 2003

I'm also getting these errors. Has anyone found a solution? [EMAIL PROTECTED] wrote: Hi, I tried to compile the C++ client on VC++ 2003. I had to change the version of VC++ in .sln and .vcproj to make it loaded by VC++ 2003. When I compiled it, I got quick a few errors. Example:

Re: High message rate research

I guess my first message was too long, but that's alright, I ended up getting the answers I needed. I figured I should let you guys in on the results of my testing. The summary of my initial write up is that my main requirement is message throughput per host, so that is what my testing has been

Consumer not consuming messages

I'm running a very basic instance of AMQ 5.0.0: just the supplied sample configuration, starting the broker with bin\activemq. My client application (Java SE) produces and consumes messages on a single queue. Both the producer and the consumer use the

Re: Start/Stop Consumer and duplicate message is received.

I'd say your problem is due to the session running in auto-ack mode (so after the onMessage method completes) and your manual ack. I think ActiveMQ might just ignore your call to acknowledge() and wait for the method to complete. Since the 5 second sleep is inside the onMessage-method it'll assume

Re: Inactivity monitor exception is closing connection.

Thanks for your fast reply, Rob. I tried activeMQ 5.1. The connection alive time is longer than 5.0 version that I used before. But it still closes the connection after some while. I attach the exception logs below. Is there any configuration value for idle timeout? - 18:34:04,249 DEBUG

Re: High message rate research

Hi Joe, I didn't pay too much attention to message size. In production our messages are 34 bytes plus some headers. For this testing the average ended up being 26 bytes. While testing the standalone broker, yes it was a completely default configuration. For the embedded brokers, I did not use

Re: Active MQ Client crash

Refer to this tutorial on pthreads attributes, our code usage is correct: http://www.cs.cf.ac.uk/Dave/C/node30.html Also see O'Reilly's Pthreads Programming book, pages 113-115. On Fri, 2008-02-08 at 07:17 -0800, TheOnlyDan wrote: Hi, I'm fairly new to the ActiveMQ API. I have 2 C++

Re: High message rate research

Hi Sean, Curious to know the average message size used and whether you used the default broker configuration? Thanks, Joe www.ttmsolutions.com Sean Bastille-2 wrote: I guess my first message was too long, but that's alright, I ended up getting the answers I needed. I figured I should let

Re: Active MQ Client crash

Hi, I'll try but my applications are a bit complex. Cutting them down to a clean example might take some time. The pthread issue though is easy to notice when reading the code. Cheers, Dan. -- View this message in context:

Re: Consumer not consuming messages

On 11/02/2008, Jeroen van Bergen [EMAIL PROTECTED] wrote: I'm running a very basic instance of AMQ 5.0.0: just the supplied sample configuration, starting the broker with bin\activemq. My client application (Java SE) produces and consumes messages on a single queue. Both the producer and the

Cannot get unit test to pass....

Hi, I am trying to use ActiveMQ to do 'quick easy' unit testing for JMS message listeners. So far, no luck. I've tried to reduce my problem as small as possible to pinpoint the problem. Here is the code: public class SimpleActiveMQTest { private ConnectionFactory factory; private

Re: Cannot get unit test to pass....

I think you might have hit a real common gotcha... http://activemq.apache.org/i-am-not-receiving-any-messages-what-is-wrong.html On 11/02/2008, David Siefert [EMAIL PROTECTED] wrote: Hi, I am trying to use ActiveMQ to do 'quick easy' unit testing for JMS message listeners. So far, no luck.

Re: Old unexpired messages not delivered; new messages are

Hi We once had the same issue (also with 4.1.1) and then discovered that the messages were assigned to some consumer that basically crashed but was still connected to the broker. Since 1000 messages is the default prefetch size for a queue this might also be your problem. In JMX you can see the

Re: Consumer not consuming messages

LOL! I had just finished writing a test that uses a QueueBrowser and had the same problem, so based on the prior issue I posted I put in a start() connection and it worked. On Feb 11, 2008 9:12 AM, James Strachan [EMAIL PROTECTED] wrote: On 11/02/2008, Jeroen van Bergen [EMAIL PROTECTED]