Re: Testing against ActiveMQ with JMeter: how to set JMSPriority and JMSExpiration, values cannot be seen in Broker

2014-05-16 Thread artnaseef
As per the JMS specification, several headers, including JMSPriority, are set on send() by the JMS provider (ActiveMQ). This means that values specified by clients are overwritten. Here's the spec; see section 3.4.11, How Message Header Values are Set:

Re: Use message selectors against messages on disk

2014-05-16 Thread Hiram Chirino
Using selector should work regardless if the message is on disk or in memory.. If it's not then it's a bug. Do you have a test case showing it's broken? On Tue, May 13, 2014 at 12:28 PM, Benjamin Jansen bjansen-activ...@w007.org wrote: Hello, In ActiveMQ 5.x (I have tried 5.6.0 and 5.9.1), is

Re: MQTT to JMS conversion results in null message body.

2014-05-16 Thread coolboy
I see a similar behavior with HTTP too. I do a HTTP GET with a timeout of 30s on a topic string say, a.b.c. And, from a mosquitto_pub client, I do a publish with/without retain flag to a/b/c. I get a HTTP STATUS 200 OK, but, the message body is null. What is going on ? -- View this

Re: How to close consumer from broker service embedded

2014-05-16 Thread Christian Posta
kind of curious, why? you'd need to build your own callback/control bus for that... apache camel is a good option for doing that.. that way you can detect events and then make decisions to determine whether a consumer should close.. On Tue, May 13, 2014 at 12:51 AM, xita-de

Re: ActiveMQ-CPP MessageNotReadableException

2014-05-16 Thread Timothy Bish
On 05/07/2014 05:22 AM, spam trap wrote: I need to display the complete message sent from an application in debugging mode. However I get the MessageNotReadableException thrown when trying to access the body. Is there a way of making the message readable or otherwise displaying the body? Can

Re: ActiveMQ 5.9.1 and Camel HTTP component

2014-05-16 Thread Peter Hicks
On 10/05/14 11:09, Peter Hicks wrote: I am not sure if this is an ApacheMQ or a Camel question, but I'm experiencing the following issue in AMQ, so it's probably a good place to start. Follow-up for anyone interested - ActiveMQ doesn't include the HTTP client library by default, and it

ActiveMq 5.9.0 Settings

2014-05-16 Thread vilas_tadoori
Dear Listers,We are sending a file that is 100MB to the ActivemQ queues, are there any settings on activemq that we need to take care of before doing this.ThanksVilas -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMq-5-9-0-Settings-tp4681141.html Sent from the

Testing against ActiveMQ with JMeter: how to set JMSPriority and JMSExpiration, values cannot be seen in Broker

2014-05-16 Thread Tom_Z
Hi, I try to run priority focussed tests with JMeter 2.11 against ActiveMQ 5.8 and some queues defined in the broker xml config. I successfully managed to push messages into the queues by the JMeter-Samplers JMS-Point-Point and also JMS-Publisher. With both samplers I do set JMS properties

Re: activemq-client does not close properly connections to the broker

2014-05-16 Thread artnaseef
The EOF exception does mean the client closed the socket without properly shutting down the ActiveMQ Connection. From the client log snippet posted, it's unclear what's causing the same. Is it possible to attach a debugger to the client and put a break-point at the point the disconnect occurs?

Re: Use message selectors against messages on disk

2014-05-16 Thread Timothy Bish
On 05/13/2014 12:28 PM, Benjamin Jansen wrote: Hello, In ActiveMQ 5.x (I have tried 5.6.0 and 5.9.1), is it possible to use JMS message selectors against in-flight messages that have been put on disk? Based on my experimentation, it appears not, but I wanted to double-check, since I've found

Re: Request / Reply in Network of Brokers

2014-05-16 Thread lacigas
We have Network TTL=10 and decreaseNetworkConsumerPriority not set (so it defaults to false) So I'm going to try with decreaseNetworkConsumerPriority = true. Thanks for your help. Regards Laci On 08.05.2014 05:17, artnaseef [via ActiveMQ] wrote: Is this with the default Network TTL setting of

Re: ActiveMq - 5.9- Loadtest JMSException when passing a huge file

2014-05-16 Thread Timothy Bish
On 05/13/2014 10:28 AM, vilas_tadoori wrote: Dear Listers, We have written a loader class to test the load on the ActiveMq queues. The queue number size is 7. When we are passing files upto 100MB it works fine and sends the data to the ActiveMQ queues. When we are passing a file above 100 MB

ActiveMQ 5.9.1 and Camel HTTP component

2014-05-16 Thread Peter Hicks
All, I am not sure if this is an ApacheMQ or a Camel question, but I'm experiencing the following issue in AMQ, so it's probably a good place to start. There are several web servers I need to retrieve a single XML file from, every 30 seconds. I want to publish this XML data on a topic for

Re: Use message selectors against messages on disk

2014-05-16 Thread Christian Posta
Message selectors are applied to messages cached in memory, not on disk. On Tue, May 13, 2014 at 9:28 AM, Benjamin Jansen bjansen-activ...@w007.org wrote: Hello, In ActiveMQ 5.x (I have tried 5.6.0 and 5.9.1), is it possible to use JMS message selectors against in-flight messages that have

Trouble setting up ReplicatedLevelDB / zookeeper for AMQ 5.9.1

2014-05-16 Thread smartin
I've been banging my head against the wall for a few hours trying to get this going, but am unable to see where the issue is. I'm trying to setup a 3 broker / 3 zookeeper node config. Zookeeper start fine on all three servers, but when I start ActiveMQ on the master node I get the following in

Re: Trouble setting up ReplicatedLevelDB / zookeeper for AMQ 5.9.1

2014-05-16 Thread smartin
Ok, so after deleting everything in the data dirs, it starts up now. Maybe something was corrupt (?) I'll keep this post here for future users with the same issue. -- View this message in context:

Re: can someone please fix a typo (apache-karaf features-core.xml)

2014-05-16 Thread Claus Ibsen
Hi That is not a typo, that is a version range, saying Spring 3.1 ... 3.9 is accepted. And the spring feature comes out of the box in Karaf, so its there you should look for the problem. On Sat, May 10, 2014 at 12:55 AM, Geurt Schimmel gschim...@schubergphilis.com wrote: karaf@root

Re: Connecting to Master/Slave from client libs (MQTT, STOMP etc.) and failover

2014-05-16 Thread Hiram Chirino
On Wed, May 14, 2014 at 4:12 PM, paddycarman paddy.car...@gmail.com wrote: Hi All, In a Master/Slave setup AFAIK, the individual brokers have different IP addresses. Let's say that a device would like to connect to a Master/Slave setup using a client lib (say MQTT). How do we do failover in

Activemq oracle AQ slow consumer

2014-05-16 Thread noodles
We use camel to route messages to oracle AQ, camel is running inside Activemq. Problem is that oracle consumes messages very slow and therefore the producer get's slow, hear is the flow: producer (external Java application) --- activemq (VirtuelTopic.x) -- activemq (Consumer.xx.VirtuelTopic.x)

ActiveMQ mqtt broker queuing and not publishing topics when clean session set to false

2014-05-16 Thread Jassi
Using broker as ActiveMQ 5.9.0 and Client - Paho Java. Setting clean session as false as I need messages sent when client is offline. Getting messages sent when clent is offline but when client is online messages are queued and not sent from ActiveMQ. Messages which are sent when client is

Re: Use message selectors against messages on disk

2014-05-16 Thread Tom_Z
Hi Christian, Hi Tim, ceposta wrote Message selectors are applied to messages cached in memory, not on disk. Does this also apply to the JMSXMessageGroupID which has some special meaning and therefore handling? If a client consumes messages of a dedicated group, the broker will only

Re: Broker Hangs after some time - or does nothing.

2014-05-16 Thread rgooduru
Are you able to find the cause of this issue, I am facing same issue with 5.9.1. We are using 5.9.1 with leveldb, everything worked properly in our QA but when we migrate to prod we had seen the same behavoir you were describing. I was unable to capture number of connections or heap size etc

Activemq on Docker

2014-05-16 Thread Noel OConnor
Hi, I'm trying to get activemq working on a Docker container. I've got the basic install going and I'm now trying to configure multicast discovery so that multiple containers can be connected together. I've turned on the multicast discovery and the containers are trying to connect. However the two