AMQ fails if remote broker is not started: via Camel using STOMP and MQTT

2016-04-13 Thread will1
We are currently establishing a broker to broker connection to a remote
RabbitMQ server using the STOMP and MQTT protocols. This works fine with
AMPQ however with STOMP and MQTT, if the remote RabbitMQ server is down and
we bounce the AMQ server it either does not start up or fails very shortly
afterwards.

Is this expected or is there any additional configuration we require?

We are using the following:
AMQ - 5.10.0
camel - 2.17
RabbitMQ - 3.5.0

This runs on: 
Linux 6.4

In terms of CAMEL route configuration we have the following:

  
  




>:<>&login=&passcode=&
host=<> "/>
 


In terms of logging we have the following for STOMP:

[DEBUG] 2016-04-08 11:52:41,368 org.apache.camel.impl.DefaultComponent
createEndpoint -Creating endpoint
uri=[activemq://topic://myTopic?clientId=3&durableSubscriptionName=stompbroker],
path=[topic://myTopic]
[DEBUG] 2016-04-08 11:52:41,384 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: clientId on bean:
org.apache.activemq.camel.component.ActiveMQConfiguration@4bd6d546 with
value: 3
[DEBUG] 2016-04-08 11:52:41,387 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: durableSubscriptionName on bean:
org.apache.activemq.camel.component.ActiveMQConfiguration@4bd6d546 with
value: stompbroker
[DEBUG] 2016-04-08 11:52:41,396 org.apache.camel.spring.SpringCamelContext
getEndpoint
-activemq://topic://myTopic?clientId=3&durableSubscriptionName=stompbroker
converted to endpoint:
Endpoint[activemq://topic://myTopic?clientId=3&durableSubscriptionName=stompbroker]
by component: org.apache.activemq.camel.component.ActiveMQComponent@cdf3d70
[DEBUG] 2016-04-08 11:52:41,451
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer
-Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=endpoints,name="activemq://topic://myTopic\?clientId=3&durableSubscriptionName=stompbroker"
[DEBUG] 2016-04-08 11:52:41,459 org.apache.camel.spring.SpringCamelContext
getComponent -Using ComponentResolver:
org.apache.camel.impl.DefaultComponentResolver@7a0598d5 to resolve component
with name: stomp
[DEBUG] 2016-04-08 11:52:41,462
org.apache.camel.impl.DefaultComponentResolver resolveComponent -Found
component: stomp in registry: null
[DEBUG] 2016-04-08 11:52:41,466
org.apache.camel.impl.DefaultComponentResolver resolveComponent -Found
component: stomp via type: org.apache.camel.component.stomp.StompComponent
via: META-INF/services/org/apache/camel/component/stomp
[DEBUG] 2016-04-08 11:52:41,473
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer
-Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=components,name="stomp"
[DEBUG] 2016-04-08 11:52:41,478 org.apache.camel.impl.DefaultComponent
createEndpoint -Creating endpoint
uri=[stomp://queue:logs?brokerURL=ssl%3A%2F%2F%3A61613&host=mytest&login=&passcode=],
path=[queue:logs]
[DEBUG] 2016-04-08 11:52:41,485 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: brokerURL on bean:
org.apache.camel.component.stomp.StompConfiguration@4beeb8a4 with value:
ssl://:61613
[DEBUG] 2016-04-08 11:52:41,493 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: host on bean:
org.apache.camel.component.stomp.StompConfiguration@4beeb8a4 with value:
mytest
[DEBUG] 2016-04-08 11:52:41,496 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: login on bean:
org.apache.camel.component.stomp.StompConfiguration@4beeb8a4 with value:

[DEBUG] 2016-04-08 11:52:41,504 org.apache.camel.util.IntrospectionSupport
setProperty -Configured property: passcode on bean:
org.apache.camel.component.stomp.StompConfiguration@4beeb8a4 with value:

[DEBUG] 2016-04-08 11:52:41,516 org.apache.camel.spring.SpringCamelContext
getEndpoint
-stomp://queue:logs?brokerURL=ssl%3A%2F%2F%3A61613&host=mytest&login=&passcode=
converted to endpoint:
Endpoint[stomp://queue:logs?brokerURL=ssl%3A%2F%2F%3A61613&host=mytest&login=&passcode=]
by component: org.apache.camel.component.stomp.StompComponent@27d74a21
[DEBUG] 2016-04-08 11:52:41,521
org.apache.camel.management.DefaultManagementAgent registerMBeanWithServer
-Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=endpoints,name="stomp://queue:logs\?brokerURL=ssl%3A%2F%2F%3A61613&host=mytest&login=&passcode="
[INFO] 2016-04-08 11:52:41,641 org.apache.camel.spring.SpringCamelContext
doStop -Apache Camel 2.17.0 (CamelContext: camel-1) is shutting down
[DEBUG] 2016-04-08 11:52:41,645
org.apache.camel.impl.DefaultAsyncProcessorAwaitManager doStop -Shutting
down with no inflight threads.
[DEBUG] 2016-04-08 11:52:41,648
org.apache.camel.support.TimerListenerManager removeTimerListener -Removed
TimerListener:
org.apache.camel.management.mbean.ManagedCamelContext@2b2b1e58
[DEBUG] 2016-04-08 11:52:41,652
org.apache.camel.management.DefaultManagementAgent unregister -Unregistered
MBean with ObjectName:
org.apache.camel:context=camel-1,type=cont

Message Redelivery in STOMP client using NACK

2016-04-13 Thread xabhi
Hi,

Will ActiveMQ redeliver the message for which the STOMP client sent a NACK
frame?

I found this ActiveMQ page(
http://activemq.apache.org/how-do-i-unack-the-message-with-stomp.html
  )
but not sure that it explains the behavior correctly since we have NACK in
STOMP protocol to say that message was not consumed.

Could someone from ActiveMQ dev confirm the exact behavior as the STOMP
specification also says that the behavior is server specific and I didn't
find any documentation in ActiveMQ wiki

Thanks,
Abhishek



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Message-Redelivery-in-STOMP-client-using-NACK-tp4710711.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


RE: Monitoring ActiveMQ

2016-04-13 Thread Vishwakarma, Chhaya
Thanks,

Can you please provide some more detaiuls about it ? documentation ? how to use 
it ?

Also I need alerting how that can be achieved any suggestions ?


Regards,
Chhaya Vishwakarma
Data Engineer, Think Big Solution Center - India
Think Big
chhaya.vishwaka...@thinkbiganalytics.com

Desk: +91 2261178196
Cell:   +91 7045306767


-Original Message-
From: barry.barn...@wellsfargo.com [mailto:barry.barn...@wellsfargo.com] 
Sent: 11 April 2016 17:48
To: users@activemq.apache.org; users@activemq.apache.org
Subject: RE: Monitoring ActiveMQ

RHQ is a good tool!



Regards,

Barry Barnett
Enterprise Queuing Services | QS4U
Cell: 803-207-7452


-Original Message-
From: Vishwakarma, Chhaya 
[chhaya.vishwaka...@thinkbiganalytics.com]
Sent: Monday, April 11, 2016 07:10 AM Central Standard Time
To: users@activemq.apache.org
Subject: Monitoring ActiveMQ


Hi All,

I have ingestion pipeline source --> ActiveMQ --> Storm --> HDFS. Now I want to 
monitor ActiveMQ queue so as to detect failures and send email to concerned 
person.

I haven't used it before so I'm looking at options that can be used for 
monitoring these queues.

Can somebody suggest suitable tools ?

Regards,

Chhaya



Re: Monitoring ActiveMQ

2016-04-13 Thread Quinn Stevenson
I’ve used Splunk a few times with my customers - it was pretty easy to get 
going.

I’ve used Splunk scripted inputs to pull data from the ActiveMQ Statistics 
plugin, and I’ve also pushed data directly to Splunk from ActiveMQ via Camel.

> On Apr 13, 2016, at 5:46 AM, Vishwakarma, Chhaya 
>  wrote:
> 
> Thanks,
> 
> Can you please provide some more detaiuls about it ? documentation ? how to 
> use it ?
> 
> Also I need alerting how that can be achieved any suggestions ?
> 
> 
> Regards,
> Chhaya Vishwakarma
> Data Engineer, Think Big Solution Center - India
> Think Big
> chhaya.vishwaka...@thinkbiganalytics.com
> 
> Desk: +91 2261178196
> Cell:   +91 7045306767
> 
> 
> -Original Message-
> From: barry.barn...@wellsfargo.com [mailto:barry.barn...@wellsfargo.com] 
> Sent: 11 April 2016 17:48
> To: users@activemq.apache.org; users@activemq.apache.org
> Subject: RE: Monitoring ActiveMQ
> 
> RHQ is a good tool!
> 
> 
> 
> Regards,
> 
> Barry Barnett
> Enterprise Queuing Services | QS4U
> Cell: 803-207-7452
> 
> 
> -Original Message-
> From: Vishwakarma, Chhaya 
> [chhaya.vishwaka...@thinkbiganalytics.com]
> Sent: Monday, April 11, 2016 07:10 AM Central Standard Time
> To: users@activemq.apache.org
> Subject: Monitoring ActiveMQ
> 
> 
> Hi All,
> 
> I have ingestion pipeline source --> ActiveMQ --> Storm --> HDFS. Now I want 
> to monitor ActiveMQ queue so as to detect failures and send email to 
> concerned person.
> 
> I haven't used it before so I'm looking at options that can be used for 
> monitoring these queues.
> 
> Can somebody suggest suitable tools ?
> 
> Regards,
> 
> Chhaya
> 



RE: Monitoring ActiveMQ

2016-04-13 Thread Vishwakarma, Chhaya
Im looking for a free/open source solution


Regards,
Chhaya Vishwakarma
Data Engineer, Think Big Solution Center - India
Think Big
chhaya.vishwaka...@thinkbiganalytics.com

Desk: +91 2261178196
Cell:   +91 7045306767



-Original Message-
From: Quinn Stevenson [mailto:qu...@pronoia-solutions.com] 
Sent: 13 April 2016 19:08
To: users@activemq.apache.org
Cc: barry.barn...@wellsfargo.com
Subject: Re: Monitoring ActiveMQ

I’ve used Splunk a few times with my customers - it was pretty easy to get 
going.

I’ve used Splunk scripted inputs to pull data from the ActiveMQ Statistics 
plugin, and I’ve also pushed data directly to Splunk from ActiveMQ via Camel.

> On Apr 13, 2016, at 5:46 AM, Vishwakarma, Chhaya 
>  wrote:
> 
> Thanks,
> 
> Can you please provide some more detaiuls about it ? documentation ? how to 
> use it ?
> 
> Also I need alerting how that can be achieved any suggestions ?
> 
> 
> Regards,
> Chhaya Vishwakarma
> Data Engineer, Think Big Solution Center - India Think Big 
> chhaya.vishwaka...@thinkbiganalytics.com
> 
> Desk: +91 2261178196
> Cell:   +91 7045306767
> 
> 
> -Original Message-
> From: barry.barn...@wellsfargo.com 
> [mailto:barry.barn...@wellsfargo.com]
> Sent: 11 April 2016 17:48
> To: users@activemq.apache.org; users@activemq.apache.org
> Subject: RE: Monitoring ActiveMQ
> 
> RHQ is a good tool!
> 
> 
> 
> Regards,
> 
> Barry Barnett
> Enterprise Queuing Services | QS4U
> Cell: 803-207-7452
> 
> 
> -Original Message-
> From: Vishwakarma, Chhaya 
> [chhaya.vishwaka...@thinkbiganalytics.com inkbiganalytics.com>]
> Sent: Monday, April 11, 2016 07:10 AM Central Standard Time
> To: users@activemq.apache.org
> Subject: Monitoring ActiveMQ
> 
> 
> Hi All,
> 
> I have ingestion pipeline source --> ActiveMQ --> Storm --> HDFS. Now I want 
> to monitor ActiveMQ queue so as to detect failures and send email to 
> concerned person.
> 
> I haven't used it before so I'm looking at options that can be used for 
> monitoring these queues.
> 
> Can somebody suggest suitable tools ?
> 
> Regards,
> 
> Chhaya
> 



Re: Monitoring ActiveMQ

2016-04-13 Thread Quinn Stevenson
Splunk isn’t open source for sure - it was just easier to get up and going than 
ElasticSearch or Solr, and most of my customers already use it.

You could do the same sort of thing with Solr or ElasticSearch.

I think Nagios has an ActiveMQ plugin too, but I’ve never used that.

> On Apr 13, 2016, at 7:39 AM, Vishwakarma, Chhaya 
>  wrote:
> 
> Im looking for a free/open source solution
> 
> 
> Regards,
> Chhaya Vishwakarma
> Data Engineer, Think Big Solution Center - India
> Think Big
> chhaya.vishwaka...@thinkbiganalytics.com
> 
> Desk: +91 2261178196
> Cell:   +91 7045306767
> 
> 
> 
> -Original Message-
> From: Quinn Stevenson [mailto:qu...@pronoia-solutions.com] 
> Sent: 13 April 2016 19:08
> To: users@activemq.apache.org
> Cc: barry.barn...@wellsfargo.com
> Subject: Re: Monitoring ActiveMQ
> 
> I’ve used Splunk a few times with my customers - it was pretty easy to get 
> going.
> 
> I’ve used Splunk scripted inputs to pull data from the ActiveMQ Statistics 
> plugin, and I’ve also pushed data directly to Splunk from ActiveMQ via Camel.
> 
>> On Apr 13, 2016, at 5:46 AM, Vishwakarma, Chhaya 
>>  wrote:
>> 
>> Thanks,
>> 
>> Can you please provide some more detaiuls about it ? documentation ? how to 
>> use it ?
>> 
>> Also I need alerting how that can be achieved any suggestions ?
>> 
>> 
>> Regards,
>> Chhaya Vishwakarma
>> Data Engineer, Think Big Solution Center - India Think Big 
>> chhaya.vishwaka...@thinkbiganalytics.com
>> 
>> Desk: +91 2261178196
>> Cell:   +91 7045306767
>> 
>> 
>> -Original Message-
>> From: barry.barn...@wellsfargo.com 
>> [mailto:barry.barn...@wellsfargo.com]
>> Sent: 11 April 2016 17:48
>> To: users@activemq.apache.org; users@activemq.apache.org
>> Subject: RE: Monitoring ActiveMQ
>> 
>> RHQ is a good tool!
>> 
>> 
>> 
>> Regards,
>> 
>> Barry Barnett
>> Enterprise Queuing Services | QS4U
>> Cell: 803-207-7452
>> 
>> 
>> -Original Message-
>> From: Vishwakarma, Chhaya 
>> [chhaya.vishwaka...@thinkbiganalytics.com> inkbiganalytics.com>]
>> Sent: Monday, April 11, 2016 07:10 AM Central Standard Time
>> To: users@activemq.apache.org
>> Subject: Monitoring ActiveMQ
>> 
>> 
>> Hi All,
>> 
>> I have ingestion pipeline source --> ActiveMQ --> Storm --> HDFS. Now I want 
>> to monitor ActiveMQ queue so as to detect failures and send email to 
>> concerned person.
>> 
>> I haven't used it before so I'm looking at options that can be used for 
>> monitoring these queues.
>> 
>> Can somebody suggest suitable tools ?
>> 
>> Regards,
>> 
>> Chhaya
>> 
> 



Re: Monitoring ActiveMQ

2016-04-13 Thread R.I.Pienaar
I wrote some nagios plugins:

Basic alive test that sends a message and waits for a reply:

  
https://github.com/ripienaar/monitoring-scripts/blob/master/activemq/check_activemq.rb

Queue size and so check:

  
https://github.com/ripienaar/monitoring-scripts/blob/master/activemq/check_activemq_queue.rb

they're for use with nagios and needs the ruby stomp lib - and stomp
on your broker.

- Original Message -
> From: "Quinn Stevenson" 
> To: "users" 
> Cc: "barry barnett" 
> Sent: Wednesday, 13 April, 2016 15:49:13
> Subject: Re: Monitoring ActiveMQ

> Splunk isn’t open source for sure - it was just easier to get up and going 
> than
> ElasticSearch or Solr, and most of my customers already use it.
> 
> You could do the same sort of thing with Solr or ElasticSearch.
> 
> I think Nagios has an ActiveMQ plugin too, but I’ve never used that.
> 
>> On Apr 13, 2016, at 7:39 AM, Vishwakarma, Chhaya
>>  wrote:
>> 
>> Im looking for a free/open source solution
>> 
>> 
>> Regards,
>> Chhaya Vishwakarma
>> Data Engineer, Think Big Solution Center - India
>> Think Big
>> chhaya.vishwaka...@thinkbiganalytics.com
>> 
>> Desk: +91 2261178196
>> Cell:   +91 7045306767
>> 
>> 
>> 
>> -Original Message-
>> From: Quinn Stevenson [mailto:qu...@pronoia-solutions.com]
>> Sent: 13 April 2016 19:08
>> To: users@activemq.apache.org
>> Cc: barry.barn...@wellsfargo.com
>> Subject: Re: Monitoring ActiveMQ
>> 
>> I’ve used Splunk a few times with my customers - it was pretty easy to get
>> going.
>> 
>> I’ve used Splunk scripted inputs to pull data from the ActiveMQ Statistics
>> plugin, and I’ve also pushed data directly to Splunk from ActiveMQ via Camel.
>> 
>>> On Apr 13, 2016, at 5:46 AM, Vishwakarma, Chhaya
>>>  wrote:
>>> 
>>> Thanks,
>>> 
>>> Can you please provide some more detaiuls about it ? documentation ? how to 
>>> use
>>> it ?
>>> 
>>> Also I need alerting how that can be achieved any suggestions ?
>>> 
>>> 
>>> Regards,
>>> Chhaya Vishwakarma
>>> Data Engineer, Think Big Solution Center - India Think Big
>>> chhaya.vishwaka...@thinkbiganalytics.com
>>> 
>>> Desk: +91 2261178196
>>> Cell:   +91 7045306767
>>> 
>>> 
>>> -Original Message-
>>> From: barry.barn...@wellsfargo.com
>>> [mailto:barry.barn...@wellsfargo.com]
>>> Sent: 11 April 2016 17:48
>>> To: users@activemq.apache.org; users@activemq.apache.org
>>> Subject: RE: Monitoring ActiveMQ
>>> 
>>> RHQ is a good tool!
>>> 
>>> 
>>> 
>>> Regards,
>>> 
>>> Barry Barnett
>>> Enterprise Queuing Services | QS4U
>>> Cell: 803-207-7452
>>> 
>>> 
>>> -Original Message-
>>> From: Vishwakarma, Chhaya
>>> [chhaya.vishwaka...@thinkbiganalytics.com>> inkbiganalytics.com>]
>>> Sent: Monday, April 11, 2016 07:10 AM Central Standard Time
>>> To: users@activemq.apache.org
>>> Subject: Monitoring ActiveMQ
>>> 
>>> 
>>> Hi All,
>>> 
>>> I have ingestion pipeline source --> ActiveMQ --> Storm --> HDFS. Now I 
>>> want to
>>> monitor ActiveMQ queue so as to detect failures and send email to concerned
>>> person.
>>> 
>>> I haven't used it before so I'm looking at options that can be used for
>>> monitoring these queues.
>>> 
>>> Can somebody suggest suitable tools ?
>>> 
>>> Regards,
>>> 
>>> Chhaya
>>>


Re: Monitoring ActiveMQ

2016-04-13 Thread James A. Robinson
Through the JMX service there are an extensive number of mbeans available
to determine the state of the broker and its queues and topics:

http://activemq.apache.org/jmx.html

It possible to access the JMX MBeans over HTTP, and of course you can use
tools that make direct use of the JMX service. For example there are JMX
aware nagios monitors you can use to monitor the mbean attribute values:

https://exchange.nagios.org/directory/Plugins/Java-Applications-and-Servers/check_jmx/details

For more complicated decision making you might also consider writing
something in Groovy, and interacting with the JMX api through it. I haven't
done it, but it looks pretty straight forward:

http://www.andrejkoelewijn.com/blog/2011/03/18/listing-activemq-queues-with-jmx-and-groovy/

And there are also ganglia monitors available, though I've never used them
so I can't say how well they work:

https://github.com/jbuchbinder/ganglia-activemq


Jim


Testing a network of brokers

2016-04-13 Thread James A. Robinson
Hi,

I've written a client to exercise the network of brokers in my setup, the
intent is to use this to help monitor that all members of the network can
pull messages from each other.

Currently it's set up to generate N tests, one for each possible
combination of a broker producer and broker consumer.  So if I had

amq-prod-1a (10.0.0.2)
amq-prod-2a (10.0.0.3)

as members of the network, I'm generating tests to

publish to amq-prod-1a, consume fro amq-prod-1a
publish to amq-prod-1a, consume fro amq-prod-2a
publish to amq-prod-2a, consume from amq-prod-2a
publish to amq-prod-2a, consume from amq-prod-1a

I've got a client that work, but I think there are two issues I still need
to deal with.

1. If I have concurrent producers/consumer tests running I need to be sure
that a message produced by the test producer isn't consumed by some other
test instance for a different pair of producer/consumers.

2. I need to be sure each consumer will receive exactly one message, so
that if two tests are running and testing the same combination of
producer/consumer ip, that each consumer gets a chance to read a message.

To handle issue #1 I was thinking I'd use a naming hierarchy that used the
producer and consumer hosts ips, e.g., test.10_0_0_2.10_0_0_3 if I had
amq-prod-1a on 10.0.0.2 and amq-prod-2a on 10.0.0.3, and I were producing
from 1a and reading from 2a.

To handle issue #2 I'm wondering if the correct thing to do is to set a
prefetch limit on the consumer when I connect to the broker?  It looks as
though http://activemq.apache.org/what-is-the-prefetch-limit-for.html says
I could set "consumer.prefetchSize=1" as a parameter on the broker URL.

If that's correct, does this apply to any sort of protocol that might be in
use on the broker, e.g., openwire, amqp, and stomp URLs?


Jim


Re: Message Redelivery in STOMP client using NACK

2016-04-13 Thread Timothy Bish

On 04/13/2016 07:13 AM, xabhi wrote:

Hi,

Will ActiveMQ redeliver the message for which the STOMP client sent a NACK
frame?

I found this ActiveMQ page(
http://activemq.apache.org/how-do-i-unack-the-message-with-stomp.html
  )
but not sure that it explains the behavior correctly since we have NACK in
STOMP protocol to say that message was not consumed.

Could someone from ActiveMQ dev confirm the exact behavior as the STOMP
specification also says that the behavior is server specific and I didn't
find any documentation in ActiveMQ wiki

Thanks,
Abhishek



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/Message-Redelivery-in-STOMP-client-using-NACK-tp4710711.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Normally when you NACK a message from STOMP the message will be sent to 
the DLQ.  You can have the broker do broker side redelivery by 
configuring the broker redelivery plugin which is documented here: 
http://activemq.apache.org/message-redelivery-and-dlq-handling.html 
along with information on DLQs


--
Tim Bish
twitter: @tabish121
blog: http://timbish.blogspot.com/



ActiveMQ 5.13.0 - Bug in Composite Destination using Stomp ?

2016-04-13 Thread aanto
ActiveMQ: 5.13.0
Java: 1.8.0u51

Using Stomp for Sending message to a composite destination as below
generates a single queue name as 
"aanto.test1queue://aanto.test2". Ideally it should have created 2 queues -
aanto.test1 and aanto.test2.

Stomp Code.
StompConnection stompconnection = new StompConnection();
stompconnection.open("lcoalhost", 61613);
stompconnection.connect("admin", "admin");
stompconnection.begin("tx1");
stompconnection.send("aanto.test1,aanto.test2", 
"message1", "tx1", null);
stompconnection.commit("tx1");
stompconnection.disconnect();


This same test using tcp/openwire works well, creates 2 separate queues.
Quickly tested against an older activemq install, (5.6), which seems to be
working.

Thanks



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-13-0-Bug-in-Composite-Destination-using-Stomp-tp4710740.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Re: ActiveMQ 5.13.0 - Bug in Composite Destination using Stomp ?

2016-04-13 Thread Timothy Bish

On 04/13/2016 02:55 PM, aanto wrote:

ActiveMQ: 5.13.0
Java: 1.8.0u51

Using Stomp for Sending message to a composite destination as below
generates a single queue name as
"aanto.test1queue://aanto.test2". Ideally it should have created 2 queues -
aanto.test1 and aanto.test2.

Stomp Code.
StompConnection stompconnection = new StompConnection();
stompconnection.open("lcoalhost", 61613);
stompconnection.connect("admin", "admin");
stompconnection.begin("tx1");
stompconnection.send("aanto.test1,aanto.test2", "message1", 
"tx1", null);
stompconnection.commit("tx1");
stompconnection.disconnect();


This same test using tcp/openwire works well, creates 2 separate queues.
Quickly tested against an older activemq install, (5.6), which seems to be
working.

Thanks



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-13-0-Bug-in-Composite-Destination-using-Stomp-tp4710740.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

This is fixed now: https://issues.apache.org/jira/browse/AMQ-6246 will 
be in 5.13.3


--
Tim Bish
twitter: @tabish121
blog: http://timbish.blogspot.com/