Exclusive Lock on a JMS Queue

Folks, We have a task that means that a single process must have exclusive access to the queue for a given period of time. The queue normally would have multiple non-exclusive consumers. Basically I want semantics that close to the Java synchronization semantics, so I acquire a "lock" at which p

NMS: How to avoid receiving my own messages?

Hello, I'm connecting to ActiveMQ 5.0 with the latest SVN version of NMS client. I have one connection with session opened and message consumer listening to the topic. When I'm sending messages to this topic, consumer is receiving these messages. Is it possible to avoid receiving messages wh

problem with blobmessage in activemq 5.0

When i create blobmessage object and print the inputstream, printed NULL, why??? then when i send the message the file not sending, the message sending empty. Please may anybody help me?? Here is code: conn = (ActiveMQConnection)cf.createConnection(); session = (ActiveMQSession

Reordering messages and changing message properties in a queue

Hi, In my system, I have set up a single JMS Queue with multiple consumers listening on the queue based on selectors. However, at times, the queue may need to be re-ordered. Is there a way in which I can re-order all the messages in a queue? Also, I was wondering if there's anyway we can change

Re: Duplicate messages sent to Queue after broker restarts

ryarger wrote: I am running the 5.1 SNAPSHOT from 2/19 (have also used 2/12) and I am noticing that messages are being resubmitted to queues after a broker restart. I have tried persisting to both the AMQ Store and to SQL Server. The issue occurs for both. I am using Spring's DefaultMessageListen

Re: C# NMS questions.

Hi Scott, The connect/reconnect scenario is implementation specific, which means it'll be manual. I've done something similar to what you are trying to do, but the re-connect is quiet since my application doesn't have any user interface. Some applications may not want to re-connect, others may

AUTO_ACKNOWLEDGE, asynchronous consumers, and avoiding duplicate messages

I'm reading over Sun's JMS tutorial and it mentions several times that JMS (and therefore ActiveMQ) can keep out duplicate messages if consumers set their session to AUTO_ACKNOWLEDGE. But I don't see how that's always the case. Consider this timeline: 1. Consumer registers an asynchronous list

Duplicate messages sent to Queue after broker restarts

I am running the 5.1 SNAPSHOT from 2/19 (have also used 2/12) and I am noticing that messages are being resubmitted to queues after a broker restart. I have tried persisting to both the AMQ Store and to SQL Server. The issue occurs for both. I am using Spring's DefaultMessageListenerContainer for

UnsupportedClassVersionError : Unix : ActiveMQ 5.0

Hi Config : ActiveMQ5.0 jdk 1.5 I am trying to run the broker on a unix machine. I am getting the following error. Any help is highly appreciated. Thanks Ind Exception in thread "main" java.lang.UnsupportedClassVersionError: org/apache/activemq/console/Main (Unsupported major.minor version

Re: Some messages can't be receive from the queue?!

I had precisely the same problem with a postgres datastore. Switching to the default kaha store made the problem go away. tuomo wrote: Hello, I have a very strange problem. I'm running a basic instance of AMQ 5.0.0 with connection to a DB2-database. The broker runs in persistent-mode. My prod

Re: C# NMS questions.

> Have you tried to test this scenario? I believe you should get some > exception when connection is broken. Yes, it does...but recovery is manual... ie. Upon failure, I have to start a timer, and try and reconnect, upon success, I then have to recreate my session and all my consumers, seems cu

Re: Network of Brokers - Broker A talking to Broker B

I've opened the following JIRA against the documentation. https://issues.apache.org/activemq/browse/AMQ-1590 Joe www.ttmsolutions.com rajdavies wrote: > > We do rely on advisories being present for networks to function > correctly at present I'm afraid > > cheers, > > Rob > On 19 Feb

Re: Issue with Windows Binary Zip - Won't open

Turns out I have a hard drive issue on my laptop. I thought it was weird that no one else was having problems. Thanks for the help, Z rajdavies wrote: > > could you try a 5.1 snapshot release ? > > On 19 Feb 2008, at 16:50, Zanderfax wrote: > >> >> 5.0.0.zip from the downloads page. >> >>

Re: Failed to start server after enabling JAAS LoginModule

Hi, I've run into the same problem with a simple authentication plugin once and solved it by removing everything from the config except the broker configuration (jetty and camel context were removed), so if you don't need them you can try it as a quick dirty fix. I didn't have time to investigate

Failed to start server after enabling JAAS LoginModule

Hi, I managed to setup ActiveMQ with JAAS. I understand that I may use LoginContext to authenticate my application with the Server. However, I am having this error when I startup ActiveMQ. - WARN TransportConnection- Failed to add Connection java.lang.SecurityException: User na

Some messages can't be receive from the queue?!

Hello, I have a very strange problem. I'm running a basic instance of AMQ 5.0.0 with connection to a DB2-database. The broker runs in persistent-mode. My producer application puts messages to a single queue. The consumer application receives messages from the same queue. Both the producer and th

Re: ActiveMQ 4 & 5 interoperability?

Hi Rob, Thanks very much for your reply - I'll look into the JMS bridge! Cheers, YMC rajdavies wrote: > > > On 19 Feb 2008, at 10:04, YMC wrote: > >> >> Hi Guys, >> >> We're interested in knowing if the brokers from the 4.x and 5.x >> families >> designed to interoperate? >> >> Cheers, >>