Re: High message frequency causes ActiveMQ to freeze

2008-01-17 Thread Rob Davies
looks like you are creating transacted sessions and not calling commit - is that you mean to do ? On Jan 18, 2008, at 6:59 AM, Olivier Bigard wrote: Hello, We had the same problem with ActiveMQ 5.0.0. Yesterday we downloaded the last 5.1 SNAPSHOT and the message disappeared, but ActiveMQ i

Re: High message frequency causes ActiveMQ to freeze

2008-01-17 Thread Rob Davies
It looks like you've hit flow control - you might want to disable it - see here: http://activemq.apache.org/producer-flow-control.html cheers, Rob On Jan 18, 2008, at 6:59 AM, Olivier Bigard wrote: Hello, We had the same problem with ActiveMQ 5.0.0. Yesterday we downloaded the last 5.1 SNA

RE: High message frequency causes ActiveMQ to freeze

2008-01-17 Thread Olivier Bigard
Hello, We had the same problem with ActiveMQ 5.0.0. Yesterday we downloaded the last 5.1 SNAPSHOT and the message disappeared, but ActiveMQ is still frozen after some messages... I put a message in the forum with our Java code. We are running ActiveMQ on Solaris platform with JDK 1.5.0_07. Can a

ActiveMQ 5: install as windows service does not work

2008-01-17 Thread ander.b
I'm trying to setup ActiveMQ 5 as a windows service. The service is created successfully but immediately shuts down after being started. Has anyone successfully got ActiveMQ5 installed as a windows service? The following is the contents from my wrapper.log file with the debug option set to 'true'

Re: Cannot synchronously receive a message when a MessageListener is set

2008-01-17 Thread Jonas Lim
Hi Jean, A MessageListener should only be set if you are using an asynchronous consumer, you will need to comment out "subscriber.setMessageListener(ml);" in your code if you're going to be using a synchronous consumer (ie. consumer.receive) which looks to be the case in your sample code. afa

Re: Slave automatically switch to Master even though Master is up

2008-01-17 Thread MQ Newbie
I find it weird too. The configuration of the database are the same for both. I have tried replacing the default mysql connector with the one provided by data direct. But the same problem occured but now with additional warning: Database driver NOT recognized James.Strachan wrote: > > On 07/01

Cannot synchronously receive a message when a MessageListener is set

2008-01-17 Thread JS75
Dear All: I tried to receive message from topic, however, I got exception below. [java] [java] javax.jms.IllegalStateException: Cannot synchronously receive a message when a MessageListener is set [java] [java] at org.apache.activemq.ActiveMQSession.checkMessageListener

How to determine message location in a queue

2008-01-17 Thread Rob Bugh
What is the best way to determine (to the extent that this makes sense) a message's position in a queue? Assuming messages represents a long running tasks and so the queue is depleted at a rather slow pace and the messages are removed from the queue in the same order as they are added, I would l

Re: User vs Developer forums?

2008-01-17 Thread Bruce Snyder
On Jan 17, 2008 12:35 PM, DavidShaw <[EMAIL PROTECTED]> wrote: > > I am looking to embed an ActiveMQ JMS queue into an existing application we > have developed. Is the developer forum for people developing ActiveMQ > itself or for people writing software that utilizes ActiveMQ? The user mailing l

Re: User vs Developer forums?

2008-01-17 Thread Hadrian Zbarcea
You are correct: the dev list is for activemq development. You're probably better off using the users list. No penalty though if you get them mixed up :). Thanks for using ActiveMQ, Hadrian On Jan 17, 2008, at 2:35 PM, DavidShaw wrote: I am looking to embed an ActiveMQ JMS queue into a

User vs Developer forums?

2008-01-17 Thread DavidShaw
I am looking to embed an ActiveMQ JMS queue into an existing application we have developed. Is the developer forum for people developing ActiveMQ itself or for people writing software that utilizes ActiveMQ? -- View this message in context: http://www.nabble.com/User-vs-Developer-forums--tp1493

Re: NegativeArraySizeException in Unmarshal

2008-01-17 Thread TOPPER_HARLEY
Thanks for the reply, but I dont think thats our issue. We are still on 4.1.1 and dont use persistent messaging at all. Thanks for the input though... dmarks wrote: > > "Has anyone seen this before or know why it might be happening?" > > We have seen this happenand think it may be related

Re: NegativeArraySizeException in Unmarshal

2008-01-17 Thread dmarks
"Has anyone seen this before or know why it might be happening?" We have seen this happenand think it may be related to persisted messages generated from 4.1.1 having problems once 5.0.0 was brought up. Simply clearing out the datastore (we didn't need to save those messages) fixed our proble

Re: MessageAuthorizationPolicy does not work??

2008-01-17 Thread James Strachan
On 17/01/2008, jvr <[EMAIL PROTECTED]> wrote: > > > James.Strachan wrote: > > > > On 17/01/2008, jvr <[EMAIL PROTECTED]> wrote: > >> > >> > >> pplive wrote: > >> > > >> > BrokerService service=BrokerFactory.createBroker(new > >> > URI("xbean:activemq.xml")); > >> > servi

Re: MessageAuthorizationPolicy does not work??

2008-01-17 Thread jvr
James.Strachan wrote: > > On 17/01/2008, jvr <[EMAIL PROTECTED]> wrote: >> >> >> pplive wrote: >> > >> > BrokerService service=BrokerFactory.createBroker(new >> > URI("xbean:activemq.xml")); >> > service.setMessageAuthorizationPolicy(new >> > MyMessageAuthorizationPol

Re: MessageAuthorizationPolicy does not work??

2008-01-17 Thread James Strachan
On 17/01/2008, jvr <[EMAIL PROTECTED]> wrote: > > > pplive wrote: > > > > BrokerService service=BrokerFactory.createBroker(new > > URI("xbean:activemq.xml")); > > service.setMessageAuthorizationPolicy(new > > MyMessageAuthorizationPolicy()); > > > > am I worong ?? > > >

RE: High message frequency causes ActiveMQ to freeze

2008-01-17 Thread Juergen.Schumacher
Hello, ok, attaching the source code file does apparently not work here. So here are the relevant code parts from the producer and processor classes, which create the connections to ActiveMQ and the messages. Sorry for the trouble... Regards, Jürgen Schumacher Procucer.java

High message frequency causes ActiveMQ to freeze

2008-01-17 Thread Juergen.Schumacher
Hello, I am currently doing some stress tests with ActiveMQ 5. I have searched the mailing list archive for similar reports, but they always seemed to resolve to something like "it's fixed in the latest snapshot", which definitely did not help in my case. My test setup is as follows: - 1 comp

Re: MessageAuthorizationPolicy does not work??

2008-01-17 Thread James Strachan
On 21/08/2007, pplive <[EMAIL PROTECTED]> wrote: > > BrokerService service=BrokerFactory.createBroker(new > URI("xbean:activemq.xml")); > service.setMessageAuthorizationPolicy(new > MyMessageAuthorizationPolicy()); > > am I worong ?? That looks right to me. -- Jam