Re: Queue/Message Fairness as oppose to Client Fairness

2012-08-08 Thread tapan.thapa
Hello Gtully, I am sorry but still it is not working as expected. Any other solutions if possible. If this can not be achieved with ActiveMQ than can you suggest something else. Thanks for your prompt support. Regards Tapan Thapa -- View this message in context: http://a

null BROKER_NAME to be expected?

2012-08-08 Thread Gaurav Sharma
In the ACTIVEMQ_LOCK table, is the null value in BROKER_NAME to be expected? I read some old threads about this but couldn't find a definitive answer from one of the committers. While it is a minor inconvenience for us, at runtime, without scanning logs of the broker machines, there is a no way to

Question about REST and to subscribing Topics

2012-08-08 Thread Chris Williams
Is it possible to configure ActiveMQ so I can "subscribe" to a jms topic persistently using the REST HTTP protocol? I would like to create a program that uses Apache HttpClient to connect to a REST based ActiveMQ URL that is tied to a topic and receive any message that is published. Most of the e

Re: Upgrading 5.5.1->5.6.0 - Core Libraries

2012-08-08 Thread Greg Thomas
On 8 August 2012 20:14, sub3 wrote: ... > Is there different library I should be using to get back down to the 'core' > activemq libraries and dependencies? Have a look at http://mail-archives.apache.org/mod_mbox/activemq-users/201206.mbox/%3CCA+GjePWRZn-ZgY0=eg3bjmi8zxqhnyya36us7fmk684eh_c...@m

Upgrading 5.5.1->5.6.0 - Core Libraries

2012-08-08 Thread sub3
Hi, I have a system with an embedded broker. I use the activemq-core & a few other jars (pulled in via maven pom file). I am trying to upgrade from 5.5.1->5.6.0, which I thought was just a maintenance release. But after inspecting and upgrading, I am noticing a lot more to this. The dependencie

Re: Queue/Message Fairness as oppose to Client Fairness

2012-08-08 Thread Gary Tully
What you want goes against the grain a bit, the broker wants to dispatch messages as fast as it can for each destination. Using lazyDispatch=true will reduce the queue dispatch loop to what can be immediately sent, so when that is combined with a low prefetch, eg prefetch=1, the minimum number of

Re: Queue/Message Fairness as oppose to Client Fairness

2012-08-08 Thread tapan.thapa
Hello, Thanks for the suggestion however i tried with php stomp 1.0 as well as with Java client and both are not working as expected. PHP Client: PHP consumer get all messages from first queue than second queue and so on. Java Client: Java client is good as it receives 3-4 messages per queue in

Re: activemq cannot recieve any message everytime from a queue while the queue has enough message pending

2012-08-08 Thread Gary Tully
Maybe compare your code/use case to some of the many unit tests in the org/apache/activemq package. All of those tests work and they may provide an insight. Here is one example: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JMSConsumerTest.java?view=m

Re: Queue/Message Fairness as oppose to Client Fairness

2012-08-08 Thread Gary Tully
remove optimizedDispatch, leave it at the default false, otherwise the send thread is used to dispatch messages. On 8 August 2012 09:14, tapan.thapa wrote: > Hello, > > I have tested this functionality with ActiveMQ 5.6.0 and Java driver as > well. > > Java driver is still better and receiving me

Re: Trasport Listener for embedded broker network connectors

2012-08-08 Thread Gary Tully
A network connector is quite different, as it keeps a connection and producer open and funnels all messages over that single producer when there are local messages and remote demand. I think making use of message advisories will help your use case. You can subscribe to the Producer advisory topic

Re: Queue/Message Fairness as oppose to Client Fairness

2012-08-08 Thread tapan.thapa
Hello, I have tested this functionality with ActiveMQ 5.6.0 and Java driver as well. Java driver is still better and receiving message from all the queues but not at the configured value. I have configured maxIterationsPerRun="1" however java consumer is receiving almost 20 sometime 10 message fr

RE: UndeclaredThrowableException while calling getQueue() and removeQueue() at the same time(by use RemoteJMXBrokerFacade)

2012-08-08 Thread rolandpeng
yes, I’ve resolved it by calling specific destination with jmx on my own. ObjectName objectNameRequest = new ObjectName( "org.apache.activemq:BrokerName=mqs,Type=Queue,Destination=" + queueName.replace(":", "_")); queueViewMbean=(QueueViewMBean)jmxB