Re: Getting ActiveMQObjectMessage instead of TextMessage

2013-09-27 Thread javaG
The code is very similar to that given by activemq: http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html The only thing different in my code is that I use: replyConsumer.receive(1) to receive the reply instead of implementing MessageListener on producer side. On th

suggestion/feature request: prompt before allowing a purge/delete from the UI

2013-09-27 Thread Roger Pack
Hello. I've noticed that on pages like this: http://hostname:8161/admin/queues.jsp there are little "purge" and "delete" links there. It also seems that, once you click one, there is no going back. It immediately happily purges or deletes that queue for you. I'll tell you what happens here at

Re: Did I turn off producer flow control correctly?

2013-09-27 Thread someword
I have taken some thread dumps on the hub and broker. The first thread dump occurs before the execution of the process which exhibits the blocking behavior. The remaining thread dumps are taken while the application is still running but blocked. The hub thread dumps are at http://pastebin.com/sh

Re: Did I turn off producer flow control correctly?

2013-09-27 Thread Christian Posta
Well, not sure. I would review the test case to make sure it's set up exactly the way you guys have it. The goal is to get the test case to lock up somehow so that it doesn't reach "making progress 99" Or you could take some time-series (3-4 snapshots) of the broker's threads (both brokers) so tha

Re: Did I turn off producer flow control correctly?

2013-09-27 Thread someword
Blarhg! My prior post was out of order. Thanks! The updated test runs to completion I do see this which happened last time to (just this one occurrence during the test run) making progress 0 You had an issue sending back messages! making progress 1 The test run summary looks clean though

Re: Did I turn off producer flow control correctly?

2013-09-27 Thread someword
Thanks! The updated test runs to completion I do see this which happened last time to (just this one occurrence during the test run) making progress 0 You had an issue sending back messages! making progress 1 The test run summary looks clean though Tests run: 1, Failures: 0, Errors: 0, Skipped:

Re: Did I turn off producer flow control correctly?

2013-09-27 Thread Christian Posta
Fixed, take a look now. On Fri, Sep 27, 2013 at 9:45 AM, someword wrote: > The mvn clean install -Dtest=false -DfailIfNoTests=false failed with this > error http://pastebin.com/mHbPfuKL . However it appears that this didn't > hamper the test suite from running? > > Running mvn test > -Dtest=o

Re: Did I turn off producer flow control correctly?

2013-09-27 Thread someword
The mvn clean install -Dtest=false -DfailIfNoTests=false failed with this error http://pastebin.com/mHbPfuKL . However it appears that this didn't hamper the test suite from running? Running mvn test -Dtest=org.apache.activemq.usecases.TwoBrokerReqeustReplyStompTempDestTest produced these resu

Re: activemq deadlocks when publisher tries to commit

2013-09-27 Thread Johan Edstrom
PFC will hit once you reach a high water mark on the store settings anyways. Depending on your use-case and whatnot else, it might possibly be a better solution to re-think the design or drastically increase memory limits. /je On Sep 27, 2013, at 10:31 AM, ariskk wrote: > Just to explain what I

Re: activemq deadlocks when publisher tries to commit

2013-09-27 Thread ariskk
Just to explain what I want to do better: I want to publish messages continiously. The consumer might run or not (it can run say once per day). In the mean time I might have collected GB of published data. -- View this message in context: http://activemq.2283324.n4.nabble.com/activemq-deadloc

Re: activemq deadlocks when publisher tries to commit

2013-09-27 Thread ariskk
Thanks, when I modify the policy to I get (after a while) javax.jms.IllegalStateException: The Session

Re: ActiveMQ, Camel, RedeliveryDelay configuration is not used, immediate redlivery instead.

2013-09-27 Thread Christian Posta
Can you put together a small stand-alone unit test that can reproduce this and I can take a look? On Thu, Sep 26, 2013 at 1:19 PM, eschor...@sendmail.com < eschor...@sendmail.com> wrote: > Hello, > > We are using a Camel/ActiveMQ/Spring configuration. We have setup a > persistent queue backed by

Re: activemq deadlocks when publisher tries to commit

2013-09-27 Thread Christian Posta
Looks like producer flow control... http://activemq.apache.org/producer-flow-control.html On Fri, Sep 27, 2013 at 4:16 AM, ariskk wrote: > This occures rarelly (once per day) and creates problems on our production > servers. When we publish a rather big message (~1MB) using the vm protocol, > t

Re: Statistics Plugin for ActiveMQ broker

2013-09-27 Thread Christian Posta
Inline... On Fri, Sep 27, 2013 at 7:47 AM, Steven Turner wrote: > Hey Christian, > > I have some questions regarding StatisticsBroker -- > 1. We are calculating subscriber stats in the class, Why not publisher > Stats > ? > Not sure I understand this.. > 2. Can you please tell me the overhead

Re: standard jms code can not receive message from queue

2013-09-27 Thread Christian Posta
You must not rely on receiveNoWait to always return a message. What the method does is check whether any messages have been dispatched to the consumer AND are *waiting on the consumer's prefetch* This is not the case in your test above as it takes a few cycles for the broker to dispatch over your n

Re: ActiveMQ 5.8 mysql persistency - 'MSG' column type BLOB instead of LONGBLOB ,

2013-09-27 Thread Alin
Thanks, it worked! This is what i have on my side in case anyone else will stumble over this issues: http://activemq.apache.org/schema/core";>

Re: Statistics Plugin for ActiveMQ broker

2013-09-27 Thread Steven Turner
Hey Christian, I have some questions regarding StatisticsBroker -- 1. We are calculating subscriber stats in the class, Why not publisher Stats ? 2. Can you please tell me the overhead for collecting stats, would it have big impact on performance of ActiveMQ. 3. Is StatisticsBroker class thread s

Re: NIO transport performance for ActiveMQ

2013-09-27 Thread Christian Posta
Maybe google will turn up something. Your best bet is to run the benchmarks yourself on your own hardware and profile. That will give you the best indications. On Fri, Sep 27, 2013 at 7:37 AM, johnbing wrote: > Hey, > Thanks for the link. Can you please provide me any link which compare NIO >

Re: JMS activemq protocol conversion that supports the message properties

2013-09-27 Thread Christian Posta
Take a look at STOMP protocol. It does a conversion which honors properties in the message. On Fri, Sep 27, 2013 at 1:12 AM, tcarlyle wrote: > We have a software agent that uses JMS to publish messages to an Activemq > topic. Part of the relevant information of those jms messages are set as > "

Re: standard jms code can not receive message from queue

2013-09-27 Thread zbc
please run following test: *package com.conceptwave.servicedesigner; import java.util.Hashtable; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueReceiver; import java

Re: NIO transport performance for ActiveMQ

2013-09-27 Thread johnbing
Hey, Thanks for the link. Can you please provide me any link which compare NIO vs TCP transport in terms of throughput and number of threads. It will be a big help. Thanks, John On Thu, Sep 26, 2013 at 6:53 PM, ceposta [via ActiveMQ] < ml-node+s2283324n4671852...@n4.nabble.com> wrote: > You can

Re: Query about ActiveMQ connection id and client id format

2013-09-27 Thread Christian Posta
On Wed, Sep 25, 2013 at 11:35 PM, Steven Turner wrote: > Hi ActiveMQ team, > > Could somebody please help me understand the format of ActiveMQ connection > id and client id. For example, I see this line in broker logs. > > 20130926 11:52:52:284 IST (ActiveMQ Transport: > tcp:///10.240.170.64:40739

Re: Getting ActiveMQObjectMessage instead of TextMessage

2013-09-27 Thread Christian Posta
Post your client code. On Thu, Sep 26, 2013 at 9:35 PM, javaG wrote: > I have a consumer client and producer client. Producer client sends message > to producer client via a queue and using request/reply message pattern. So > producer is blocked until a reply comes back from consumer. Most of t

Re: SOAP over JMS fails with AMQ 5.8.0 and AMQ-4312 patch

2013-09-27 Thread matteor
I tried with the latest snapshot (apache-activemq-5.9-20130919.101342) and everything worked fine. So I think something is missing in the uploaded patch for AMQ-4312. Does anyone have a clue about what it could be missing from the patch? What AMQ packages could be involved? Maybe I could try a dif

activemq deadlocks when publisher tries to commit

2013-09-27 Thread ariskk
This occures rarelly (once per day) and creates problems on our production servers. When we publish a rather big message (~1MB) using the vm protocol, the publisher deadlocks here: prio=10 tid=0x7f2f5008c000 nid=0x1880 waiting on condition [0x7f303acd9000] java.lang.Thread.State: WAIT

JMS activemq protocol conversion that supports the message properties

2013-09-27 Thread tcarlyle
We have a software agent that uses JMS to publish messages to an Activemq topic. Part of the relevant information of those jms messages are set as "StringProperties" or "IntProperties" in the message by the JMS agent. However, I need to subscribe to the activemq topics from Android and there is no

Re: Apollo subscribing with selector does not consume existing messages

2013-09-27 Thread Hiram Chirino
Awesome. Thanks for the update! On Thu, Sep 26, 2013 at 9:55 PM, AlexP wrote: > Hey, thanks for the reply. We debugged this further and it actually turned > out to be an issue with a PHP stomp implementation we were using. > Apparently, when building the SEND FRAME, the PHP implementation was p

ActiveMQ, Camel, RedeliveryDelay configuration is not used, immediate redlivery instead.

2013-09-27 Thread eschor...@sendmail.com
Hello, We are using a Camel/ActiveMQ/Spring configuration. We have setup a persistent queue backed by Kaha, and transactional configuration using org.springframwork.jms.connection.JmsTransactionManager. We are trying to get the exception/re-delivery working correctly, and find that while the max