Re: ConcurrentModificationException while closing consumer

2009-02-09 Thread Rob Davies
didn't see a jira - so created one: https://issues.apache.org/activemq/browse/AMQ-2100 On 9 Feb 2009, at 23:14, bonnyr wrote: Gary, Why would the collection be used in CLIENT_ACK mode then? In our application we've got to work in this mode since there's a processing chain that may take

Re: ConcurrentModificationException while closing consumer

2009-02-09 Thread Rob Davies
Bonny - agreed - looks like that bit of code has never been synchronized - will add a fix ... cheers, Rob Rob Davies http://fusesource.com http://rajdavies.blogspot.com/ On 9 Feb 2009, at 23:14, bonnyr wrote: Gary, Why would the collection be used in CLIENT_ACK mode then? In our applic

Re: ActiveMQ and JNDI provider

2009-02-09 Thread sweetjonnie
gregory.guibert wrote: > > Thank you for the link on OpenDS, it looks great and seems to solve half > my > problem (alignment of data) :-) > ... > When using a jndi.properties file to create an initial context, the file > looks like this: > java.naming.factory.initial = com.sun.jndi.ldap.LdapCtx

ActiveMQ JNDI support only for testing?

2009-02-09 Thread janylj
Hello, I tried ActiveMQ JNDI support. It seems to me only for testing, because the administrative objects are specified in the jndi.properties of client machine. There is no centralized place to manage the ConnectionFactory or Destination. And we could not control who could access them. Is my un

Re: ConcurrentModificationException while closing consumer

2009-02-09 Thread bonnyr
Gary, Why would the collection be used in CLIENT_ACK mode then? In our application we've got to work in this mode since there's a processing chain that may take a while between delivery of the message and its ack, so chaging this mode is not possible for our use case. We're aware of the fact

Re: Can someone point me to an example of using a ConsumerEventSource

2009-02-09 Thread darrickc
That did the trick! Thanks! Dejan Bosanac wrote: > > Hi, > > try starting the ConsumerEvenetSource (ces.start()). > > Cheers > -- > Dejan Bosanac > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > >

Re: Q Consumers stop receiving messages

2009-02-09 Thread sweetjonnie
Gary Tully wrote: > > in transacted mode, who is managing the transaction demarcation? In > other words, where is the session.commit() call? > This is a session based transaction as opposed to an external JTA operation. The COMMIT is, therefore, made against the jms session object. The call

STOMP: broker sends "transformation" header for TextMessage

2009-02-09 Thread mjustin
Hello List, in Stomp, the only way I know to see if a message is a ObjectMessage, or a TextMessage, is to check if it contains a "transformation= ..." header. However, if a subscriber uses the transformation header to tell the broker which transformation the broker should use for object messages

Re: ProducerTool hangs after 312 messages with --messageSize=2000 --messageCount=500

2009-02-09 Thread mjustin
Bill Schuller wrote: > > Do you have a consumer on the destination you are sending to? > Many thanks for your answer! For my test, I use a default installation of ActiveMQ 5.2 or a 5.3 snapshot. There are no other clients, and no consumers. The main problem however that there is a difference

Can I limit the number of ActiveMQ Transport threads?

2009-02-09 Thread Steve Winer
Is there a way to control the number of ActiveMQ transport threads? We are finding over 50 in thread dumps and want to know if we can throttle this number. Steve -- View this message in context: http://www.nabble.com/Can-I-limit-the-number-of-ActiveMQ-Transport-threads--tp21919008p21919008.htm

Re: Problems with acknowledge mode order (STOMP)

2009-02-09 Thread Roger Hoover
Thanks. That works! On Mon, Feb 9, 2009 at 3:10 AM, Dejan Bosanac wrote: > Hi Roger, > > this is the normal behavior of the "client" acknowledgment mode. The broker > acknowledges all messages up to the one you specified. So when you ack > message 3, message 2 is also acked so when you try to a

Re: ProducerTool hangs after 312 messages with --messageSize=2000 --messageCount=500

2009-02-09 Thread Bill Schuller
Do you have a consumer on the destination you are sending to? I¹ll guess that your problem is that your queue size is limited by something like with paging disabled. Once the destination reaches the limit, it blocks the consumer and it times out. Setting the TTL causes the messages to expire, free

Re: Can someone point me to an example of using a ConsumerEventSource

2009-02-09 Thread Dejan Bosanac
Hi, try starting the ConsumerEvenetSource (ces.start()). Cheers -- Dejan Bosanac Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Fri, Feb 6, 2009 at 11:49 PM, darrickc wrote: > > I have an embedded broker

Re: What is the meaning about "Pending Queue Size", "Dispatched Queue Size","Dispatched Counter","Enqueue Counter","Dequeue Counter" in JMS web console, THX!

2009-02-09 Thread Bill Schuller
Pending Queue Size ­ The number of messages in the queue that have yet to be delivered to any client Dispatched Counter ­ The number of message in the queue that have been delivered to a client, but not yet acknowledged Enqueue Counter ­ The number of messages that have been sent to this queue Dequ

Re: ConsumerInfo shows wrong number of consumers

2009-02-09 Thread Dejan Bosanac
Hi, there is currently a known issue that ConsumerInfo shows total number of consumers instead of just those for the specific destination https://issues.apache.org/activemq/browse/AMQ-2099 if you're using advisory messages, you might be hit by this bug. Can you check what consumers JConsole show

Re: Problems with acknowledge mode order (STOMP)

2009-02-09 Thread Dejan Bosanac
Hi Roger, this is the normal behavior of the "client" acknowledgment mode. The broker acknowledges all messages up to the one you specified. So when you ack message 3, message 2 is also acked so when you try to ack it later again you receive an error. The solution for your use case would be to us

Re: Q Consumers stop receiving messages

2009-02-09 Thread Gary Tully
Jonnie, in transacted mode, who is managing the transaction demarcation? In other words, where is the session.commit() call? 2009/2/8 sweetjonnie : > > at least one in the thread mentioned persistence and i wonder if my problem > is related. > > i am newbie/retarded and cannot get my embedded brok

Re: ConcurrentModificationException while closing consumer

2009-02-09 Thread Gary Tully
> I'm not quite able to cause this to happen in a simple test case. Perhaps > this is to do with some > thread timing/scheduling issues in the simple test case vs our application. > Yea, that is fairly typical. > However, are you in a > position to explain what the deliveredMessage collection is u

ConsumerInfo shows wrong number of consumers

2009-02-09 Thread O.Yaromchik
We have consumer on a queue in our project and spring's ScheduledTimerTask which closes, releases reference on it, then creates and starts a new one periodically (ones per 6 hours). When application stays idle for a long time and consumer stays idle too, ConsumerInfo shows number of consumers > 1.

Re: advisoryForConsumed and orignalMessageId == null?

2009-02-09 Thread Gary Tully
Hi Bjørn, I think that may be a copy n' paste error in the documentation. The payload in that advisory message is the original message, so there is really no need for additional properties. You need to do something like: Message msg = advisoryConsumer.receive(1000); ActiveMQMessage

Re: ActiveMQ and JNDI provider

2009-02-09 Thread Gregory Guibert
Thank you for the link on OpenDS, it looks great and seems to solve half my problem (alignment of data) :-) As seen on Joe's Blog, the binding/lookup of any Java Object can be performed on a LDAP server using the LdapCtxFactory provided by Sun. http://joefernandezblog.blogspot.com/ When using a j