Re: How activemq resend failing message manually？

[Quinn Stevenson]

I use virtual topics ( http://activemq.apache.org/virtual-destinations.html 
 ) - then I can resend to 
individual “subscribers”.

If you need to use JMS Topics, the only way I can think of is to use a message 
selector.


> On Jul 25, 2018, at 10:16 AM, difficult  wrote:
> 
> There are some subscribers ,such as A,B,C ,and they listener the same
> topic.For one message ,these subscribers should handle this message once and
> only once.When the publisher send one message ,these subscribers may handle
> this message unsuccessfully,for example the B subscriber can't handle the
> message for the background database temporary problem.The activemq's
> redelivery policy is unsuited for this case.When the database recover,we
> want manually resend the mesaage in the DLQ to this topic, the A,C
> subscriber can't receive this message,because they had consume this
> message,but the subscribers B can receive this message and handle it.
> Above is my business application scenario,with activemq can implement it and
> how ? 
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Older Message Not Consumed(Stay Untouched in queue) Newer Messages consumed

[Quinn Stevenson]

Sorry - the weren’t really shuffled.

I don’t know exactly if they were moved to the back of the queue or just held 
until their redelivery delay expired and then re-injected into the queue.  We 
didn’t test enough to make that determination - we stopped as soon as we 
discovered that delayed redelivery on the broker side broke FIFO.



> On Apr 3, 2018, at 9:59 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
> 
> When you say "shuffled", do you simply mean that the message went to the
> back of the queue when it got sent back for broker-side redelivery? Or do
> you mean that actual randomization of all messages on the queue occurred?
> 
> Tim
> 
> On Tue, Apr 3, 2018 at 8:29 AM, Quinn Stevenson <qu...@pronoia-solutions.com
>> wrote:
> 
>> No - we weren’t using selectors.  The only “special” feature we were using
>> was Virtual Topics - we saw the order shuffled on the queues created for
>> the Virtual Topic Consumers.
>> 
>> 
>>> On Apr 2, 2018, at 11:20 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
>>> 
>>> @RuralHunter, same question as to the OP: were you using selectors? Was
>> it
>>> possible that no consumer with a selector matching those messages was
>>> online, and then one came online and consumed the message?
>>> 
>>> Tim
>>> 
>>> On Mon, Mar 26, 2018 at 8:31 AM, RuralHunter <ruralhun...@gmail.com>
>> wrote:
>>> 
>>>> I reported the same problem for 5.13.4.
>>>> http://activemq.2283324.n4.nabble.com/Message-stuck-in-
>>>> queue-td4720713.html
>>>> 
>>>> 
>>>> 
>>>> --
>>>> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
>>>> f2341805.html
>>>> 
>> 
>> 

Re: Older Message Not Consumed(Stay Untouched in queue) Newer Messages consumed

[Quinn Stevenson]

No - we weren’t using selectors.  The only “special” feature we were using was 
Virtual Topics - we saw the order shuffled on the queues created for the 
Virtual Topic Consumers.


> On Apr 2, 2018, at 11:20 PM, Tim Bain  wrote:
> 
> @RuralHunter, same question as to the OP: were you using selectors? Was it
> possible that no consumer with a selector matching those messages was
> online, and then one came online and consumed the message?
> 
> Tim
> 
> On Mon, Mar 26, 2018 at 8:31 AM, RuralHunter  wrote:
> 
>> I reported the same problem for 5.13.4.
>> http://activemq.2283324.n4.nabble.com/Message-stuck-in-
>> queue-td4720713.html
>> 
>> 
>> 
>> --
>> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
>> f2341805.html
>> 

Re: Older Message Not Consumed(Stay Untouched in queue) Newer Messages consumed

[Quinn Stevenson]

I don’t know if it’s related, but we were seeing something that sounds like 
this when we setup the ActiveMQ broker for delayed redelivery.  

What we observed was when a message was rolled-back to the broker and the delay 
started, the next message on the queue would be delivered to the consumer.  
This was on an older version of ActiveMQ (5.11) and I didn’t really go much 
further than this - I moved the redelivery handling to the client side.


> On Mar 26, 2018, at 8:31 AM, RuralHunter  wrote:
> 
> I reported the same problem for 5.13.4.
> http://activemq.2283324.n4.nabble.com/Message-stuck-in-queue-td4720713.html
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Can I connect to a vm URL without a password?

[Quinn Stevenson]

Thanks for all your help Tim.

I created https://issues.apache.org/jira/browse/AMQ-6941 
<https://issues.apache.org/jira/browse/AMQ-6941> for this request, and I put a 
link to the example implementation in the JIRA rather than the source.  I did 
it that way because the jar with the plugin is in Maven Central, and the source 
can be found on Github. 

I’ll be moving this customer to Artemis in the near future - I guess I’ll have 
to look at doing the same thing in Artemis.

Thanks Again


> On Mar 27, 2018, at 7:12 AM, Tim Bain <tb...@alumni.duke.edu> wrote:
> 
> Quinn,
> 
> Great, I'm glad you got it working.
> 
> Yes, I think there would be benefit to having this capability. However, I'm
> not sure if what you've implemented is the ideal implementation from a
> long-term maintenance standpoint (I suspect that we'd want to fold it into
> the Simple Authentication Plugin, with configuration options to turn it on
> and off and possibly a way to specify the set of protocols that do not
> require authentication), so I suggest you create an enhancement request in
> JIRA and attach your implementation to it. Whoever implements the
> enhancement request can use the core of your code and wrap the appropriate
> options around it in the Simple Authentication Plugin (or wherever else),
> and anyone who wants the capability before it gets implemented officially
> can grab your plugin file off of the enhancement request.
> 
> Tim
> 
> On Mon, Mar 26, 2018, 9:48 PM Quinn Stevenson <qu...@pronoia-solutions.com>
> wrote:
> 
>> Thanks Tim - I think I’ve got one working now.
>> 
>> I wound up casting the result of getConnector() to TransportConnector and
>> then calling getName() - it looks like it has what I need.
>> 
>> I’ve got a version running locally now, and it seems to be doing what I’m
>> after.  Thanks for all of your help.
>> 
>> BTW - let me know if you think this is something the community would like
>> and I’ll put together a PR for it.
>> 
>> Thanks Again
>> Quinn
>> 
>>> On Mar 25, 2018, at 11:11 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
>>> 
>>> Quinn,
>>> 
>>> I think you should be able to access the URI to which the connection is
>>> bound by calling
>>> ((TransportConnector)context.getConnector()).getServer().getConnectURI(),
>>> and then you can parse the protocol out of it. But it's not something
>> I've
>>> personally done and I don't have time to try it right now, so this is
>>> purely conjecture based on the documentation plus reading the code. So if
>>> that doesn't work, I apologize, but let me know how it blows up and I can
>>> try to help further.
>>> 
>>> Tim
>>> 
>>> On Thu, Mar 22, 2018 at 10:22 AM, Quinn Stevenson <
>>> qu...@pronoia-solutions.com> wrote:
>>> 
>>>> Thank you Tim -
>>>> 
>>>> I was afraid you were going to say that :-)
>>>> 
>>>> I was looking at the SimpleAuthenticationPlugin /
>>>> SimpleAuthenticationBroker, and I have an idea how to do this.  The one
>>>> thing I’m not sure about is how I can tell when the connection is coming
>>>> via a VM URL - do you have any hints on that?
>>>> 
>>>> 
>>>>> On Mar 21, 2018, at 7:21 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
>>>>> 
>>>>> I'm not sure there's a built-in way to do this without writing any
>> code,
>>>>> but you should be able to write a simple security plugin that allows
>> you
>>>> to
>>>>> allow or deny connections based on their transport and whether they are
>>>>> anonymous. The bottom of http://activemq.apache.org/security.html has
>>>>> details about how to get started.
>>>>> 
>>>>> Tim
>>>>> 
>>>>> On Wed, Mar 21, 2018, 6:08 PM Quinn Stevenson <
>>>> qu...@pronoia-solutions.com>
>>>>> wrote:
>>>>> 
>>>>>> I have several components running inside the same JVM as ActiveMQ, and
>>>>>> they connect to the broker using a vm URL.  Guest access to the broker
>>>> has
>>>>>> been disabled for security reasons, but I’d like the embedded
>>>> components to
>>>>>> be able to connect to the broker without a username or password.
>>>>>> 
>>>>>> Is there a way to configure ActiveMQ to allow anonymous/guest access
>> for
>>>>>> VM connections only?
>>>>>> 
>>>>>> 
>>>>>> 
>>>>>> 
>>>> 
>>>> 
>> 
>> 

Re: Can I connect to a vm URL without a password?

[Quinn Stevenson]

Thanks Tim - I think I’ve got one working now.

I wound up casting the result of getConnector() to TransportConnector and then 
calling getName() - it looks like it has what I need.

I’ve got a version running locally now, and it seems to be doing what I’m 
after.  Thanks for all of your help.

BTW - let me know if you think this is something the community would like and 
I’ll put together a PR for it.

Thanks Again
Quinn

> On Mar 25, 2018, at 11:11 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
> 
> Quinn,
> 
> I think you should be able to access the URI to which the connection is
> bound by calling
> ((TransportConnector)context.getConnector()).getServer().getConnectURI(),
> and then you can parse the protocol out of it. But it's not something I've
> personally done and I don't have time to try it right now, so this is
> purely conjecture based on the documentation plus reading the code. So if
> that doesn't work, I apologize, but let me know how it blows up and I can
> try to help further.
> 
> Tim
> 
> On Thu, Mar 22, 2018 at 10:22 AM, Quinn Stevenson <
> qu...@pronoia-solutions.com> wrote:
> 
>> Thank you Tim -
>> 
>> I was afraid you were going to say that :-)
>> 
>> I was looking at the SimpleAuthenticationPlugin /
>> SimpleAuthenticationBroker, and I have an idea how to do this.  The one
>> thing I’m not sure about is how I can tell when the connection is coming
>> via a VM URL - do you have any hints on that?
>> 
>> 
>>> On Mar 21, 2018, at 7:21 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
>>> 
>>> I'm not sure there's a built-in way to do this without writing any code,
>>> but you should be able to write a simple security plugin that allows you
>> to
>>> allow or deny connections based on their transport and whether they are
>>> anonymous. The bottom of http://activemq.apache.org/security.html has
>>> details about how to get started.
>>> 
>>> Tim
>>> 
>>> On Wed, Mar 21, 2018, 6:08 PM Quinn Stevenson <
>> qu...@pronoia-solutions.com>
>>> wrote:
>>> 
>>>> I have several components running inside the same JVM as ActiveMQ, and
>>>> they connect to the broker using a vm URL.  Guest access to the broker
>> has
>>>> been disabled for security reasons, but I’d like the embedded
>> components to
>>>> be able to connect to the broker without a username or password.
>>>> 
>>>> Is there a way to configure ActiveMQ to allow anonymous/guest access for
>>>> VM connections only?
>>>> 
>>>> 
>>>> 
>>>> 
>> 
>> 

Re: Can I connect to a vm URL without a password?

[Quinn Stevenson]

Thank you Tim -

I was afraid you were going to say that :-)

I was looking at the SimpleAuthenticationPlugin / SimpleAuthenticationBroker, 
and I have an idea how to do this.  The one thing I’m not sure about is how I 
can tell when the connection is coming via a VM URL - do you have any hints on 
that?


> On Mar 21, 2018, at 7:21 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
> 
> I'm not sure there's a built-in way to do this without writing any code,
> but you should be able to write a simple security plugin that allows you to
> allow or deny connections based on their transport and whether they are
> anonymous. The bottom of http://activemq.apache.org/security.html has
> details about how to get started.
> 
> Tim
> 
> On Wed, Mar 21, 2018, 6:08 PM Quinn Stevenson <qu...@pronoia-solutions.com>
> wrote:
> 
>> I have several components running inside the same JVM as ActiveMQ, and
>> they connect to the broker using a vm URL.  Guest access to the broker has
>> been disabled for security reasons, but I’d like the embedded components to
>> be able to connect to the broker without a username or password.
>> 
>> Is there a way to configure ActiveMQ to allow anonymous/guest access for
>> VM connections only?
>> 
>> 
>> 
>> 

Can I connect to a vm URL without a password?

[Quinn Stevenson]

I have several components running inside the same JVM as ActiveMQ, and they 
connect to the broker using a vm URL.  Guest access to the broker has been 
disabled for security reasons, but I’d like the embedded components to be able 
to connect to the broker without a username or password.

Is there a way to configure ActiveMQ to allow anonymous/guest access for VM 
connections only?

Re: ActiveMQ & OSGI Startup

[Quinn Stevenson]

I had a client with a similar requirement a while back, and what I wound up 
doing was writing a couple of simple bundles that dynamically registered OSGi 
services.  I need two - on for running in the same JVM as the ActiveMQ broker 
and another for running in a different JVM.  

The bundle that ran in the same JVM watched for a JMX MBean to show up for the 
broker before it registered it’s service, while the bundle that ran in a 
separate JVM tried to connect to the broker and would registered the service 
once a connection could be made.  In both cases, the services were unregistered 
if the broker was unavailable.

Unfortunately I don’t have that code to share anymore.

Quinn Stevenson
qu...@pronoia-solutions.com
(801) 244-7758



> On Dec 9, 2017, at 3:53 AM, smunro <stephen.ross.mu...@gmail.com> wrote:
> 
> Hello,
> 
> I've got a small project which has an OSGI bundle deployed on Karaf. It uses
> the latest ActiveMQ feature. The issue is that my bundle is starting up
> before the Broker has fully started.
> 
> Is there a clean way to tell the bundle to wait until the broker has fully
> initialised to start receiving connections. I don't want to rely on start
> levels as they are not reliable. I've also tried basic things like a loop
> that catches exceptions until it finally connects, but that doesn't feel
> very clean and I thought I'd ask if there is a better way to handle this?
> 
> All I want is for my bundle to wait until ActiveMQ is up and running. is
> there a better way to handle this that what I've already suggested?
> 
> Thanks,
> Stephen
> 
> 
> 
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Re: Artemis Core XA Example

[Quinn Stevenson]

I would say just use camel-jms (http://camel.apache.org/jms.html 
<http://camel.apache.org/jms.html>) or camel-sjms 
(http://camel.apache.org/sjms.html <http://camel.apache.org/sjms.html>).

> On Oct 25, 2016, at 2:56 PM, Clebert Suconic <clebert.suco...@gmail.com> 
> wrote:
> 
> I guess I should add that to the FAQ. I get this question once in a while.
> 
> How would we describe it? there's no need for an Artemiq-Camel
> component at the moment, just use what?
> 
> 
> Any camel specialist can provide me a simple answer to add to the doc?
> 
> On Tue, Oct 25, 2016 at 12:22 PM, Quinn Stevenson
> <qu...@pronoia-solutions.com> wrote:
>> I don’t think an equivalent for the “activemq-broker” Camel component is 
>> needed - just my opinion there.
>> 
>> As far as a “artemis-camel” or “camel-artemis” component goes, I don’t think 
>> one is “needed” - but I’m wondering if a specific component could provide 
>> any value over using just the JMS abstractions.  If everything you can do in 
>> “core” is available (or will be available) via the JMS abstractions, then I 
>> don’t see a compelling reason for a component dedicated to Artemis - unless 
>> of course configuring the component becomes too complex or the JMS 
>> abstractions incur too much overhead.
>> 
>> If it is decided that a specific component would provide some value, I would 
>> like to see it in the Camel project and not in Artemis (i.e. camel-artemis 
>> instead of artemis-camel).  Just my opinion ...
>> 
>> 
>>> On Oct 24, 2016, at 4:40 PM, Clebert Suconic <clebert.suco...@gmail.com> 
>>> wrote:
>>> 
>>> - There is an “activemq-camel” component today, and since Artemis is
>>> slated to become the next “ActiveMQ”, I was looking for functional
>>> equivalents.  This is actually what started the whole question for me,
>>> because I can do everything I need to do in core Artemis without
>>> muddying the waters with JMS abtractions.  For example, the aliases
>>> that get created for JMS destinations really confused me at first.
>>> 
>>> 
>>> We are fixing the destinations on next release (1.6.0) 1.5.0 is bound
>>> to be released this week.
>>> 
>>> 
>>> 
>>> Do we need a camel component within Artemis? if we do we can create
>>> one.. but every I ask this question I get the same answer that we
>>> don't need it given it's a bit different with Artemis.
>>> 
>>> 
>>> if you found a real need we can certainly create it.
>>> 
>>> 
>>> On Mon, Oct 24, 2016 at 1:32 PM, Quinn Stevenson
>>> <qu...@pronoia-solutions.com> wrote:
>>>> I can stick with JMS - I’ve used JMS servers for a long time, and I can 
>>>> get what I need done that way.
>>>> 
>>>> There are a couple of reasons behind the question:
>>>> 
>>>> - I try to keep my dependencies to a minimum.  When I use JMS in camel 
>>>> currently, I use camel-sjms whenever I can (basically whenever I don’t 
>>>> need XA) because the configuration is simpler and I don’t drag in all the 
>>>> Spring dependencies.  The camel-sjms component does some other things 
>>>> better IMO opinion as well - but it’s mostly because it’s simpler to 
>>>> configure and easier to use IMO.
>>>> 
>>>> - There is an “activemq-camel” component today, and since Artemis is 
>>>> slated to become the next “ActiveMQ”, I was looking for functional 
>>>> equivalents.  This is actually what started the whole question for me, 
>>>> because I can do everything I need to do in core Artemis without muddying 
>>>> the waters with JMS abtractions.  For example, the aliases that get 
>>>> created for JMS destinations really confused me at first.
>>>> 
>>>> As an aside, there isn’t an equivalent for the activemq-broker component.  
>>>> I don’t really use that one, but it can be handy.  I guess I could do this 
>>>> with a diverter, but I haven’t tried yet.
>>>> 
>>>> 
>>>>> On Oct 20, 2016, at 12:38 PM, Clebert Suconic <clebert.suco...@gmail.com> 
>>>>> wrote:
>>>>> 
>>>>> the JMS layer on Artemis is a thin layer on top of the Core API. I
>>>>> would stick to JMS or JMS2.
>>>>> 
>>>>> There are some extra controls you can have on addresses and queues but
>>>>> that will soon also come into JMS after martyn is done with the
>>&g

Re: Artemis Core XA Example

[Quinn Stevenson]

I don’t think an equivalent for the “activemq-broker” Camel component is needed 
- just my opinion there.

As far as a “artemis-camel” or “camel-artemis” component goes, I don’t think 
one is “needed” - but I’m wondering if a specific component could provide any 
value over using just the JMS abstractions.  If everything you can do in “core” 
is available (or will be available) via the JMS abstractions, then I don’t see 
a compelling reason for a component dedicated to Artemis - unless of course 
configuring the component becomes too complex or the JMS abstractions incur too 
much overhead.

If it is decided that a specific component would provide some value, I would 
like to see it in the Camel project and not in Artemis (i.e. camel-artemis 
instead of artemis-camel).  Just my opinion ...


> On Oct 24, 2016, at 4:40 PM, Clebert Suconic <clebert.suco...@gmail.com> 
> wrote:
> 
> - There is an “activemq-camel” component today, and since Artemis is
> slated to become the next “ActiveMQ”, I was looking for functional
> equivalents.  This is actually what started the whole question for me,
> because I can do everything I need to do in core Artemis without
> muddying the waters with JMS abtractions.  For example, the aliases
> that get created for JMS destinations really confused me at first.
> 
> 
> We are fixing the destinations on next release (1.6.0) 1.5.0 is bound
> to be released this week.
> 
> 
> 
> Do we need a camel component within Artemis? if we do we can create
> one.. but every I ask this question I get the same answer that we
> don't need it given it's a bit different with Artemis.
> 
> 
> if you found a real need we can certainly create it.
> 
> 
> On Mon, Oct 24, 2016 at 1:32 PM, Quinn Stevenson
> <qu...@pronoia-solutions.com> wrote:
>> I can stick with JMS - I’ve used JMS servers for a long time, and I can get 
>> what I need done that way.
>> 
>> There are a couple of reasons behind the question:
>> 
>> - I try to keep my dependencies to a minimum.  When I use JMS in camel 
>> currently, I use camel-sjms whenever I can (basically whenever I don’t need 
>> XA) because the configuration is simpler and I don’t drag in all the Spring 
>> dependencies.  The camel-sjms component does some other things better IMO 
>> opinion as well - but it’s mostly because it’s simpler to configure and 
>> easier to use IMO.
>> 
>> - There is an “activemq-camel” component today, and since Artemis is slated 
>> to become the next “ActiveMQ”, I was looking for functional equivalents.  
>> This is actually what started the whole question for me, because I can do 
>> everything I need to do in core Artemis without muddying the waters with JMS 
>> abtractions.  For example, the aliases that get created for JMS destinations 
>> really confused me at first.
>> 
>> As an aside, there isn’t an equivalent for the activemq-broker component.  I 
>> don’t really use that one, but it can be handy.  I guess I could do this 
>> with a diverter, but I haven’t tried yet.
>> 
>> 
>>> On Oct 20, 2016, at 12:38 PM, Clebert Suconic <clebert.suco...@gmail.com> 
>>> wrote:
>>> 
>>> the JMS layer on Artemis is a thin layer on top of the Core API. I
>>> would stick to JMS or JMS2.
>>> 
>>> There are some extra controls you can have on addresses and queues but
>>> that will soon also come into JMS after martyn is done with the
>>> refactoring on addressing here:
>>> 
>>> https://github.com/apache/activemq-artemis/tree/ARTEMIS-780
>>> 
>>> On Wed, Oct 19, 2016 at 8:50 AM, Tim Bain <tb...@alumni.duke.edu> wrote:
>>>> What's the reason behind wanting to avoid using the JMS layer in favor of
>>>> the proprietary Artemis core API?  I've not done anything with Artemis, so
>>>> this is very much a question from a place of ignorance, but Quinn's
>>>> statement sounded a lot like "I only want to use Hibernate-proprietary
>>>> APIs, none of those pesky JPA-standard ones that might let me interoperate
>>>> or swap underlying technologies later," and I'm curious about the logic
>>>> that led to the statement...
>>>> 
>>>> Tim
>>>> 
>>>> On Oct 18, 2016 3:55 PM, "Clebert Suconic" <clebert.suco...@gmail.com>
>>>> wrote:
>>>> 
>>>>> On Tue, Oct 18, 2016 at 12:45 PM, Quinn Stevenson
>>>>> <qu...@pronoia-solutions.com> wrote:
>>>>>> Clebert -
>>>>>> 
>>>>>> Thank you for your input!
>>>>>> 
>>>>>>

Re: Artemis Core XA Example

[Quinn Stevenson]

I can stick with JMS - I’ve used JMS servers for a long time, and I can get 
what I need done that way.

There are a couple of reasons behind the question:

 - I try to keep my dependencies to a minimum.  When I use JMS in camel 
currently, I use camel-sjms whenever I can (basically whenever I don’t need XA) 
because the configuration is simpler and I don’t drag in all the Spring 
dependencies.  The camel-sjms component does some other things better IMO 
opinion as well - but it’s mostly because it’s simpler to configure and easier 
to use IMO.

- There is an “activemq-camel” component today, and since Artemis is slated to 
become the next “ActiveMQ”, I was looking for functional equivalents.  This is 
actually what started the whole question for me, because I can do everything I 
need to do in core Artemis without muddying the waters with JMS abtractions.  
For example, the aliases that get created for JMS destinations really confused 
me at first.

As an aside, there isn’t an equivalent for the activemq-broker component.  I 
don’t really use that one, but it can be handy.  I guess I could do this with a 
diverter, but I haven’t tried yet.


> On Oct 20, 2016, at 12:38 PM, Clebert Suconic <clebert.suco...@gmail.com> 
> wrote:
> 
> the JMS layer on Artemis is a thin layer on top of the Core API. I
> would stick to JMS or JMS2.
> 
> There are some extra controls you can have on addresses and queues but
> that will soon also come into JMS after martyn is done with the
> refactoring on addressing here:
> 
> https://github.com/apache/activemq-artemis/tree/ARTEMIS-780
> 
> On Wed, Oct 19, 2016 at 8:50 AM, Tim Bain <tb...@alumni.duke.edu> wrote:
>> What's the reason behind wanting to avoid using the JMS layer in favor of
>> the proprietary Artemis core API?  I've not done anything with Artemis, so
>> this is very much a question from a place of ignorance, but Quinn's
>> statement sounded a lot like "I only want to use Hibernate-proprietary
>> APIs, none of those pesky JPA-standard ones that might let me interoperate
>> or swap underlying technologies later," and I'm curious about the logic
>> that led to the statement...
>> 
>> Tim
>> 
>> On Oct 18, 2016 3:55 PM, "Clebert Suconic" <clebert.suco...@gmail.com>
>> wrote:
>> 
>>> On Tue, Oct 18, 2016 at 12:45 PM, Quinn Stevenson
>>> <qu...@pronoia-solutions.com> wrote:
>>>> Clebert -
>>>> 
>>>> Thank you for your input!
>>>> 
>>>> I try and avoid XA transactions whenever possible as well.  I do have a
>>> few customers that insist on transactions when they do JMS->JMS routes (the
>>> JMS destination are in different brokers/servers - hence the need for XA).
>>> 
>>> got it... was just pointing my 2 cents there. Try to batch (like 1000
>>> messages & 1000 whatever else you are doing on a single TX). if you
>>> can.
>>> 
>>>> 
>>>> This is really the last piece I need to figure out before I’ll be able
>>> to implement Artemis (core only) into our standard flows.  I know we can
>>> always use the JMS layer, but I’d like to be able to use just the core if I
>>> can.
>>>> 
>>> 
>>> all the methods available on JMS for XA are also available on
>>> ClientSession. There shouldn't be any difference.
>>> 
>>> Let me know If you can't figure out, and I (or someone else) may write
>>> an example
>>> 
>>> 
>>>> I’m planning on doing the integration in Camel, and it’s looking more
>>> and more like I’ll need an “artemis-camel” (hosted in the Artemis source)
>>> or a “camel-artemis” (hosted in the Camel Components source).  Any thoughts
>>> on which would be the most appropriate place for the component?  ActiveMQ
>>> 5.x has the activemq-camel component, but it always seemed to me it was in
>>> the wrong place - that it should be camel-activemq.
>>>> 
>>> 
>>> 
>>> I looked at the camel component on AMQ5 at some time ago and it would
>>> be simple to port it. I thought it wasn't needed though. but if you
>>> need it we can add something into artemis/master just like AMQ5 has
>>> one.
>>> 
>>> Can you add it?  Send a PR... we accept PRs :)
>>> 
>>> 
>>> if you even send it soon, I'm planning a release early next week. if
>>> it's well done (well done means.. not breaking anything) it might be
>>> there before we release it.
>>> 
> 
> 
> 
> -- 
> Clebert Suconic

Re: Artemis Core XA Example

[Quinn Stevenson]

Clebert -

Thank you for your input!

I try and avoid XA transactions whenever possible as well.  I do have a few 
customers that insist on transactions when they do JMS->JMS routes (the JMS 
destination are in different brokers/servers - hence the need for XA).  

This is really the last piece I need to figure out before I’ll be able to 
implement Artemis (core only) into our standard flows.  I know we can always 
use the JMS layer, but I’d like to be able to use just the core if I can.

I’m planning on doing the integration in Camel, and it’s looking more and more 
like I’ll need an “artemis-camel” (hosted in the Artemis source) or a 
“camel-artemis” (hosted in the Camel Components source).  Any thoughts on which 
would be the most appropriate place for the component?  ActiveMQ 5.x has the 
activemq-camel component, but it always seemed to me it was in the wrong place 
- that it should be camel-activemq.  



> On Oct 18, 2016, at 10:08 AM, Clebert Suconic <clebert.suco...@gmail.com> 
> wrote:
> 
> Most of the usecases around XA are around an application server, and
> hence around MDBs, And JMS.
> 
> ClientSession extends XAResource so you should be able to use / enlist
> on a Transaction Manager, or if you really wanted (I'm not advising
> you) you could play the TransactionManager on some fakes (for tests
> maybe).
> 
> 
> I always advise people to use messaging for fast services as much as
> possible. Transactions will introduce a point of sync and you will be
> using your messaging system pretty much as a database. if you really
> need that at least try to batch your transactions so you can scale
> without requiring many servers to support your load.
> 
> On Tue, Oct 18, 2016 at 11:06 AM, Quinn Stevenson
> <qu...@pronoia-solutions.com> wrote:
>> Is there an example of using the Artemis Core APIs with XA?  It appears that 
>> all of the XA examples use JMS.  Am I missing something?
>> 
>> 
>> 
> 
> 
> 
> -- 
> Clebert Suconic

Artemis Core XA Example

[Quinn Stevenson]

Is there an example of using the Artemis Core APIs with XA?  It appears that 
all of the XA examples use JMS.  Am I missing something?

Re: problems getting test results deterministic

[Quinn Stevenson]

Have you tried explicitly disabling the automatic creation of embedded brokers 
(i.e. add create=false option to vm://…. )

> On Jul 20, 2016, at 9:15 AM, jnicolay  wrote:
> 
> Hi all
> 
> We ran into some strange behavior in our application and I tried to reproduce 
> it in a unit test.
> 
> Our setup looks somewhat like this:
> +---+   ++  +---+
> | embedded1 | <---> | master | <--> | embedded2 |
> +---+   ++  +---+
>\--  / \---  --/
>   \/  \/
> +---+   |   ++  |   +---+
> | producer1 |---+   | slave  |  +---| producer2 |
> +---+   |   ++  |   +---+
>|   | 
> +-+ |   | +-+
> | subscriber1 |-+   +-| subscriber2 |
> +-+   +-+
> 
> 
> We have a master/slave broker pair in the middle and two embedded brokers 
> called embedded-client1 and embedded-client2 that connect to it with 
> "static:failover://(tcp://localhost:,tcp://localhost:)?randomize=false=0
> 
> Then we're simulating two clients, one uses the connection URL 
> "failover://(tcp://localhost:",tcp://localhost:,vm://embedded-
> client1)?randomize=false" for sending and subscribing,
> the second uses the connection URL 
> "failover://(tcp://localhost:",tcp://localhost:,vm://embedded-
> client2)?randomize=false" for sending and subscribing.
> 
> Both clients register a durable subscriber and after both have registered 
> (and 
> we gave the subscriptions some time to propagate) both clients send a message.
> 
> After waiting again some time so the message is delivered we kill the master 
> and every client sends another message.
> At this point I expect the producers to notice that they can neither connect 
> to the master, nor the slave (because it hasn't had time to start yet) and 
> falls back to delivering the message to their embedded brokers.
> Also I expect the subscribers to notice their connection is gone and 
> subscribe 
> at their embedded brokers.
> 
> So given enough time, both clients should have received the first two 
> messages 
> and the second one they sent.
> 
> Then the slave starts up (in our test we manually start it at this point) and 
> given enough time, both embedded brokers should reestablish their network 
> bridge, forward the message that was delivered to them to the central broker 
> and this should forward the messages to the other embedded broker with it's 
> subscriber.
> 
> So both subscribers should have received all four messages. (In different 
> order, but that's ok.)
> 
> What actually happens is: The test works. once. But when I run it 20 times, 
> it 
> looks like this:
> - The first time always works.
> - A statistical average of 6 times it succeeds.
> - A statistical average of 4 times I get a JMSException that a client id is 
> already registered.
> - A statistical average of 2 times the clients don't get their own messages 
> after the central broker died.
> - A statistical average of 8 times the clients already received all 4 
> messages 
> before the central broker was restarted.
> - Even though all brokers have been told to use a temporary directory to 
> store 
> their data that's wiped after every test run (junit TemporaryFolder rule), 
> directories "activemq-data/", "activemq-data/ of-embedded-broker2>" are created in the current directory.
> 
> The test case already stops all 4 brokers that are started after the test 
> with 
> stop() and waitUntilStopped().
> 
> 
> I have the impression that sometimes the connection does not go to the 
> embedded broker that I manually created but a new embedded broker with 
> default 
> settings is created instead. But I have no clue why this happens sometimes. 
> Maybe the embedded instances from the last test run aren't disposed properly 
> yet. But then again I have no clue how to clean the state between test runs 
> properly.
> 
> At the moment the test starts with a 4 second delay, without it the number of 
> JMSExceptions rises dramatically.
> 
> 
> I'll attach a small maven project with this test case, as well as a log file 
> of a test run where all 4 test outcomes happened.
> 
> 
> Any help would be greatly appreciated.
> 
> Thanks
> Joachim
> 
> 
> maven-test-project.zip (9K) 
> 
> tests.log.zip (904K) 
> 
> 
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/problems-getting-test-results-deterministic-tp4714185.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Queue size from client side

[Quinn Stevenson]

Have you looked at the Statistics Plugin?

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


> On Jul 19, 2016, at 5:51 AM, khandelwalanuj  
> wrote:
> 
> Hi,
> 
> How to check Queue size from ActiveMQ java client ?
> 
> Thanks,
> Anuj
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Queue-size-from-client-side-tp4714102.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with Camel Config routing using a custom ActiveMQ Message Property

[Quinn Stevenson]

No - Camel don’t have a “/dev/null” endpoint.  However, if you don’t want the 
message to go anywhere, just don’t send it (i.e. bypass the to).  If you really 
need the to, you can always send it to a log uri - something like 

Re: Help with Camel Config routing using a custom ActiveMQ Message Property

[Quinn Stevenson]

I had a similar use case in the past, and I chose to route the "trash"
messages to a JMS Topic that didn't have any durable subscribers.  That way
I could create a subscriber when I needed it to see what was being
"trashed" - just be careful you don't create a durable subscriber or the
messages will build-up in that topic.

On Thu, Jun 23, 2016 at 7:09 PM, Tim Bain <tb...@alumni.duke.edu> wrote:

> To trash a message, do not send it to a DLQ!  DLQ != /dev/null.
>
> Instead, just ack the message after you consume it (without doing anything
> in response, just end the route or have your processor return null), which
> in the default Camel configuration happens automatically when your Camel
> route receives the message.  If your route is somehow set up for individual
> acks, you'd have to do the ack manually, but the code you've inherited
> would have an example of what to do if that were the case.
>
> Tim
> On Jun 23, 2016 8:14 AM, "Hassen Bennour" <bennour.has...@gmail.com>
> wrote:
>
> > Hello,
> >
> > You can route messages following messages properties with filtered
> > destinations  http://activemq.apache.org/virtual-destinations.html
> > or camel  http://activemq.apache.org/sample-camel-routes.html
> > http://camel.apache.org/message-filter.html
> >
> > to trash a message i think you can route it to DLQ or another "trash
> queue"
> > or simply if it not correspond to any filtered Destination selector or
> > route it will not been forwarded, loosed.
> >
> > for example :
> > 
> > 
> > 
> > 
> > 
> > * *
> > 
> > * *
> > 
> > 
> > 
> > 
> > 
> > 
> >
> > if you remove the filter 1 and a if a message dont have a *clientID =
> > 'activemq' * it will be ignored.
> >
> >
> >
> > Kind regards.
> >
> > *BENNOUR HASSEN*
> >
> > *SOA **Architect **/ **Java **Software Engineer*
> >
> > 2016-06-23 14:47 GMT+02:00 daelliott <my_fo...@outlook.com>:
> >
> > > I've taken over a project in which everyone that knows anything is
> gone.
> > > I'm new to ActiveMQ and have never used Camel before.
> > > I'm trying to do content message routing and have a sample of what I'm
> > > attempting to do but have a couple of questions.
> > >
> > > * How to access a custom ActiveMQ message property.
> > >Is what I have below correct?
> > >
> > > * How to trash a message  i.e. send to /dev/null
> > >
> > > This is what I have after going through all the documentation that I
> > could
> > > find.
> > > Any help is GREATLY appreciated.
> > >
> > >
> > >
> > >
> > >
> > >
> > >
> > > --
> > > View this message in context:
> > >
> >
> http://activemq.2283324.n4.nabble.com/Help-with-Camel-Config-routing-using-a-custom-ActiveMQ-Message-Property-tp4713278.html
> > > Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> > >
> >
>



-- 
Quinn Stevenson
qu...@pronoia-solutions.com
(801) 244-7758

Re: GPFS file storage and ActiveMQ - file locking?

[Quinn Stevenson]

One of my customers did a PoC using GPFS last fall, and everything went fine.

We chose to use NFS anyway because the environment setup for GPFS was more 
complex.

> On May 24, 2016, at 8:08 AM, Naveed Hashmi  
> wrote:
> 
> Hi,
> 
> ( I'm new to activemq) ...
> 
> We run Blackboard Learn which uses ActiveMQ, see link below for info ..
> 
> https://en-us.help.blackboard.com/Learn/9.1_2014_04/Administrator/070_Server_Management_and_Integrations/System_Integration/SIS/040_SIS_Integration_Admin/060_Configuring_ActiveMQ_Messaging
> 
> We run multiple Blackboard servers (behind a load balancer) which share
> content via an NFS share. We are thinking about moving away from NFS to
> GPFS storage, but this may pose a risk to our activemq service because
> (according to Blackboard tech support), GPFS uses byte-size file locking
> meaning it can lock part of the file which may result in activemq having
> problems.
> 
> Does anyone have any thoughts on this?  anyone successfully using GPFS with
> activemq with multiple nodes (cluster)?
> 
> Thanks,
> 
> -- 
> Naveed

Re: Measuring service time of the broker

[Quinn Stevenson]

Have you looked at the Statistics Plugin? ( 
http://activemq.apache.org/statisticsplugin.html 
 ).  It will give you the 
averageEnqueueTime for each destination.

> On May 12, 2016, at 10:30 AM, siddutta  wrote:
> 
> I have a network of brokers and wish to find the avg. time a message stays at
> a broker's queue. Is there a plugin or API call that I can make to find
> this?
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Measuring-service-time-of-the-broker-tp4711866.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Separate kahadb for queues and dead letter queues?

[Quinn Stevenson]

Wildcards aren’t quite that flexible - the docs say “don’t specify any string 
after ‘>’ on your wildcard express, it will be ignored” 
http://activemq.apache.org/wildcards.html 


For what it’s worth - I got around this issue with DLQs by changing the naming 
pattern - I put DLQ at the front, rather than the end.

> On Apr 29, 2016, at 9:25 AM, Christian Schneider  
> wrote:
> 
> I just tested by sending messages into a queue test. Unfortunately the filter 
> ">.DLQ" seems to include "test". So it seems everything after ">" is ignored.
> Is there any way to express that I want all queues that end in DLQ?
> 
> Christian
> 
> On 29.04.2016 17:17, Christian Schneider wrote:
>> I took a stab at creating a config with a separate kahadb for the DLQs:
>> 
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> 
>> Does that make sense?
>> 
>> I am unsure about the ">" wildcard as I am not sure if it can be used at the 
>> start. All examples I found till now only seem to use it at the end.
>> I would be happy about a confirmation that what I do is correct or a better 
>> solution.
>> 
>> Christian
>> 
>> On 29.04.2016 14:39, Christian Schneider wrote:
>>> We have the issue that our journals at a customer are very large. We 
>>> analyzed the messages in the system and found that most of the time
>>> the normal queues stay at a very low number of messages near to 0. The only 
>>> queues that hold messages for longer periods of time are the dead letter 
>>> queues.
>>> 
>>> The journals are much bigger than the dead letter queue contents.
>>> 
>>> My assumption is that most of the journals only contain very few still 
>>> needed messages and the ones they contain are the messages that now are in 
>>> the dead letter queues.
>>> Still the journals can not be cleaned up of course.
>>> 
>>> So what I would like to to is to use one kahadb for the regular queues and 
>>> a different one for the dead letter queues. Does that make sense?
>>> I will try to do this using "Multi(m) kahaDB persistence adapter": See 
>>> http://activemq.apache.org/kahadb.html
>>> 
>>> I also wonder if it would make sense that ActiveMQ cleans up its journals 
>>> regularly. It could simply move all oldest messages to the newest jorunal 
>>> to kind of pack if denser.
>>> Would that work?
>>> 
>>> Christian
>>> 
>> 
>> 
> 
> 
> -- 
> Christian Schneider
> http://www.liquid-reality.de
> 
> Open Source Architect
> http://www.talend.com
> 

Re: Testing Master Slave on Shared File System

[Quinn Stevenson]

Chris -

Most of the implementations I’ve seen have used NFS, but it’s needs to be NFSv4 
to get the right locking behavior.

I’ve run this type of setup in a VM environment as well, but we didn’t use a VM 
for the NFS server the client had an enterprise NFS solution so we used that.  
Also, I know some SANs will export NFS natively.

> On Apr 29, 2016, at 8:54 AM, Christopher Fogarty 
> <christopher.foga...@versiant.com> wrote:
> 
> Quinn
> 
> Thanks. I could use NFS, but the master slave shared docs (very Spartan) 
> indicated SAN. If ext4 is not the proper filesystem. What should I use? I 
> could use NFS, but I was concerned over performance. Also, NFS in a VM 
> environment would require a third server?
> 
> Node 1
> Node 2
> NFS server (I would not think it would be prudent to use nfs from one of the 
> two nodes?)
> 
> Chris Fogarty
> 
> VP, System Engineering
> Versiant Corporation
> 3700 Arco Corporate Drive
> Suite 350
> Charlotte, NC 28273
> Office: (704) 831-3905 | Mobile: (704) 763-3333
> 
> chris.foga...@versiant.com
> 
> -Original Message-
> From: Quinn Stevenson [mailto:qu...@pronoia-solutions.com] 
> Sent: Friday, April 29, 2016 10:45 AM
> To: users@activemq.apache.org
> Subject: Re: Testing Master Slave on Shared File System
> 
> I've done quite a bit of master/slave setups - they've never been an issue as 
> long as I had a filesystem that supported locking.  I've used NFSv4 and GFSv2 
> for these setups.
> 
> If I'm reading this correctly, you've setup a volume on a SAN and mounted it 
> on both systems as an ext4 filesystem.  If that's the case, I think that is 
> your issue - ext4 is not a shared filesystem and it isn't cluster aware.  
> 
> Can you try using NFSv4?
> 
>> On Apr 29, 2016, at 8:37 AM, Matt Pavlovich <mattr...@gmail.com> wrote:
>> 
>> Are both volumes mounted with ext4? Does EXT4 have support for distributed 
>> lock sharing?  Sounds like one server would mount rw and the other would be 
>> mounted ro and there aren't any shared locks.
>> 
>> I'm not as current on the latest EXT4 features, but do know a cluster-aware 
>> filesystem such as GFSv2 is designed for this type of setup.
>> 
>> -Matt
>> 
>> On 4/28/16 3:14 PM, Christopher Fogarty wrote:
>>> I have the disk a part of its on vggroup and an lv carved out of that with 
>>> ext 4 file system on it. This is mounted on both systems and I am able to 
>>> start active mq fine. But would feel a lot better validating that only one 
>>> of the two nodes actually has a lock. I would love even more to verify that 
>>> both nodes when started are doing what they should, which is one has a 
>>> locked access and the other is in a sort of stand by until the lock is 
>>> released.
>>> 
>>> Hope this makes sense.
>>> 
>>> Chris Fogarty
>>> 
>>> 
>>> 
>>> 
>>> 
>>> On Thu, Apr 28, 2016 at 12:37 PM -0700, "Matt Pavlovich" 
>>> <mattr...@gmail.com<mailto:mattr...@gmail.com>> wrote:
>>> 
>>> Chris-
>>> 
>>> What file system are you using to share the mount?  The filesystem 
>>> would need to support distributed locking (many "shareable 
>>> filesystems" don't do this properly.
>>> 
>>> The other approach is to use the shared filesystem for KahaDB and a 
>>> database lease-locker to work around the 
>>> most-shared-filesystems-don't-do-locking-properly problem.
>>> 
>>> -Matt
>>> 
>>> On 4/28/16 12:34 PM, Christopher Fogarty wrote:
>>>> I have set up two servers:
>>>> 
>>>> Both CENTOS with a shared SAN disk mounted and active on both nodes.
>>>> 
>>>> I have set up ActiveMQ 5.6
>>>> 
>>>> I am able to start each with the following configuration
>>>> 
>>>> 
>>>>   
>>>> 
>>>> 
>>>> Each node can and does start, but how can I test, or what do I look for to 
>>>> make sure that file locking is actually working as described in the 
>>>> http://activemq.apache.org/shared-file-system-master-slave.html document.  
>>>> Before putting this into production, I would feel a lot better knowing 
>>>> that only one of the two nodes is capable of accessing the kahadb.
>>>> 
>>>> 
>>>> Chris Fogarty
>>>> 
>>>> VP, System Engineering
>>>> Versiant Corporation
>>>> 3700 Arco Corporate Drive
>>>> Suite 350
>>>> Cha

Re: Testing Master Slave on Shared File System

[Quinn Stevenson]

I’ve done quite a bit of master/slave setups - they’ve never been an issue as 
long as I had a filesystem that supported locking.  I’ve used NFSv4 and GFSv2 
for these setups.

If I’m reading this correctly, you’ve setup a volume on a SAN and mounted it on 
both systems as an ext4 filesystem.  If that’s the case, I think that is your 
issue - ext4 is not a shared filesystem and it isn’t cluster aware.  

Can you try using NFSv4?

> On Apr 29, 2016, at 8:37 AM, Matt Pavlovich  wrote:
> 
> Are both volumes mounted with ext4? Does EXT4 have support for distributed 
> lock sharing?  Sounds like one server would mount rw and the other would be 
> mounted ro and there aren't any shared locks.
> 
> I'm not as current on the latest EXT4 features, but do know a cluster-aware 
> filesystem such as GFSv2 is designed for this type of setup.
> 
> -Matt
> 
> On 4/28/16 3:14 PM, Christopher Fogarty wrote:
>> I have the disk a part of its on vggroup and an lv carved out of that with 
>> ext 4 file system on it. This is mounted on both systems and I am able to 
>> start active mq fine. But would feel a lot better validating that only one 
>> of the two nodes actually has a lock. I would love even more to verify that 
>> both nodes when started are doing what they should, which is one has a 
>> locked access and the other is in a sort of stand by until the lock is 
>> released.
>> 
>> Hope this makes sense.
>> 
>> Chris Fogarty
>> 
>> 
>> 
>> 
>> 
>> On Thu, Apr 28, 2016 at 12:37 PM -0700, "Matt Pavlovich" 
>> > wrote:
>> 
>> Chris-
>> 
>> What file system are you using to share the mount?  The filesystem would
>> need to support distributed locking (many "shareable filesystems" don't
>> do this properly.
>> 
>> The other approach is to use the shared filesystem for KahaDB and a
>> database lease-locker to work around the
>> most-shared-filesystems-don't-do-locking-properly problem.
>> 
>> -Matt
>> 
>> On 4/28/16 12:34 PM, Christopher Fogarty wrote:
>>> I have set up two servers:
>>> 
>>> Both CENTOS with a shared SAN disk mounted and active on both nodes.
>>> 
>>> I have set up ActiveMQ 5.6
>>> 
>>> I am able to start each with the following configuration
>>> 
>>> 
>>>
>>> 
>>> 
>>> Each node can and does start, but how can I test, or what do I look for to 
>>> make sure that file locking is actually working as described in the 
>>> http://activemq.apache.org/shared-file-system-master-slave.html document.  
>>> Before putting this into production, I would feel a lot better knowing that 
>>> only one of the two nodes is capable of accessing the kahadb.
>>> 
>>> 
>>> Chris Fogarty
>>> 
>>> VP, System Engineering
>>> Versiant Corporation
>>> 3700 Arco Corporate Drive
>>> Suite 350
>>> Charlotte, NC 28273
>>> Office: (704) 831-3905 | Mobile: (704) 763-
>>> 
>>> chris.foga...@versiant.com
>>> 
>>> -Original Message-
>>> From: Christopher Fogarty
>>> Sent: Wednesday, April 27, 2016 9:02 AM
>>> To: 'users@activemq.apache.org' 
>>> Subject: RE: Running ActiveMQ Broker as different username unable to 
>>> connect via web admin console
>>> 
>>> What Platform? Do you have a firewall running
>>> 
>>> Chris Fogarty
>>> 
>>> VP, System Engineering
>>> Versiant Corporation
>>> 3700 Arco Corporate Drive
>>> Suite 350
>>> Charlotte, NC 28273
>>> Office: (704) 831-3905 | Mobile: (704) 763-
>>> 
>>> chris.foga...@versiant.com
>>> 
>>> -Original Message-
>>> From: jboss [mailto:jb...@bcidaho.com]
>>> Sent: Wednesday, April 27, 2016 8:16 AM
>>> To: users@activemq.apache.org
>>> Subject: Re: Running ActiveMQ Broker as different username unable to 
>>> connect via web admin console
>>> 
>>> The web console does not come up at all.   The error that the Chrome gives 
>>> is
>>> "Connection Refused".  Does not even get to the point of asking for 
>>> username/password.
>>> 
>>> Thanks,
>>> 
>>> 
>>> 
>>> 
>>> --
>>> View this message in context: 
>>> http://activemq.2283324.n4.nabble.com/Running-ActiveMQ-Broker-as-different-username-unable-to-connect-via-web-admin-console-tp4711175p4711280.html
>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>> 
> 

Composite Destinations and originalDestination

[Quinn Stevenson]

I’m trying to use a composite destination to setup a simple wiretap of messages 
going to a set of queues - the configuration I’m using looks like this






This works great except for one problem - I can’t tell where the original 
message came from so I can’t build my audit trail.

Is there a way to configure the composite destination so it can set the 
originalDestination header?

Re: ActiveMQ Broker Camel Component and wildcards

[Quinn Stevenson]

Thank You Tim -

Is there an example of an interceptor somewhere in the code base I can use as a 
reference to get started on this?

BTW - I did it working with the Camel Broker Component by switching from 
 to .  I’m not sure why that made a difference, but 
it did.

> On Apr 28, 2016, at 10:53 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
> 
> I think you want to be using interceptors (
> http://activemq.apache.org/interceptors.html), not consuming from a queue
> and then publishing back to the same queue.  I've always believed that
> embedded Camel routes couldn't be inserted into the middle of accepting a
> message (which is what you really want), but interceptors should be able to
> do that.
> 
> Tim
> 
> On Thu, Apr 28, 2016 at 12:49 PM, Quinn Stevenson <
> qu...@pronoia-solutions.com> wrote:
> 
>> I’m trying to use the ActiveMQ Broker Camel Component to add some JMS user
>> properties to messages as they arrive at the broker.  I’m using a wildcard
>> on the from so I can apply the same logic to a set of topics or queues, but
>> I can’t seem to send the message back to the original queue.
>> 
>> Without wildcards, it works fine - something like this:
>> http://www.springframework.org/schema/beans;
>>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
>>   xsi:schemaLocation="
>>http://camel.apache.org/schema/spring
>> http://camel.apache.org/schema/spring/camel-spring.xsd
>>http://www.springframework.org/schema/beans
>> http://www.springframework.org/schema/beans/spring-beans.xsd;>
>> 
>>http://camel.apache.org/schema/spring;>
>>
>>
>>
>>MyHeaderValue
>>
>>
>>
>> 
>>
>> 
>> 
>> 
>> However when I put in the wildcards, I get and IllegalStateException.  The
>> configuration I’m trying looks like this
>> http://www.springframework.org/schema/beans;
>>   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
>>   xsi:schemaLocation="
>>http://camel.apache.org/schema/spring
>> http://camel.apache.org/schema/spring/camel-spring.xsd
>>http://www.springframework.org/schema/beans
>> http://www.springframework.org/schema/beans/spring-beans.xsd;>
>> 
>>http://camel.apache.org/schema/spring;>
>>
>>
>>
>>MyHeaderValue
>>
>>
>>broker://${header[JMSDestination]}
>>
>>
>> 
>>
>> 
>> 
>> 
>> And here’s the exception I get
>> 
>> 2016-04-28 12:47:43,721 | ERROR | Failed delivery for (MessageId:
>> ID-macpro-local-53588-1461869253207-0-2 on ExchangeId:
>> ID-macpro-local-53588-1461869253207-0-3). Exhausted after delivery attempt:
>> 1 caught: java.lang.IllegalStateException: Not the original message from
>> the broker Message: Enter some text here for the message body...
>> 
>> Message History
>> 
>> ---
>> RouteId  ProcessorId  Processor
>>Elapsed (ms)
>> [in-audit-to-file  ] [in-audit-to-file  ] [broker://queue:in.adt.*
>>   ] [23]
>> [in-audit-to-file  ] [setHeader1] [setHeader[MyCustomHeader]
>>   ] [ 3]
>> [in-audit-to-file  ] [recipientList1]
>> [recipientList[simple{broker://${header[JMSDestination]}}]
>>   ] [18]
>> 
>> Exchange
>> 
>> ---
>> Exchange[
>>Id  ID-macpro-local-53588-1461869253207-0-3
>>ExchangePattern InOnly
>>Headers
>> {breadcrumbId=ID:macpro.local-53587-1461869252118-4:1:1:1:1,
>> CamelRedelivered=false, CamelRedeliveryCounter=0, JMSCorrelationID=,
>> JMSCorrelationIDAsBytes=, JMSDeliveryMode=1,
>> JMSDestination=queue://in.adt.epic, JMSExpiration=0,
>> JMSMessageID=ID:macpro.local-53587-1461869252118-4:1:1:1:1, JMSPriority=0,
>> JMSRedelivered=false, JMSReplyTo=null, JMSTimestamp=1461869263684,
>> JMSType=, JMSXGroupID=null, JMSXUserID=null, MyCustomHeader=MyHeaderValue}
>>BodyTypeString
>

ActiveMQ Broker Camel Component and wildcards

[Quinn Stevenson]

I’m trying to use the ActiveMQ Broker Camel Component to add some JMS user 
properties to messages as they arrive at the broker.  I’m using a wildcard on 
the from so I can apply the same logic to a set of topics or queues, but I 
can’t seem to send the message back to the original queue.

Without wildcards, it works fine - something like this:
http://www.springframework.org/schema/beans;
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
   xsi:schemaLocation="
http://camel.apache.org/schema/spring 
http://camel.apache.org/schema/spring/camel-spring.xsd
http://www.springframework.org/schema/beans 
http://www.springframework.org/schema/beans/spring-beans.xsd;>

http://camel.apache.org/schema/spring;>



MyHeaderValue








However when I put in the wildcards, I get and IllegalStateException.  The 
configuration I’m trying looks like this
http://www.springframework.org/schema/beans;
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
   xsi:schemaLocation="
http://camel.apache.org/schema/spring 
http://camel.apache.org/schema/spring/camel-spring.xsd
http://www.springframework.org/schema/beans 
http://www.springframework.org/schema/beans/spring-beans.xsd;>

http://camel.apache.org/schema/spring;>



MyHeaderValue


broker://${header[JMSDestination]}







And here’s the exception I get

2016-04-28 12:47:43,721 | ERROR | Failed delivery for (MessageId: 
ID-macpro-local-53588-1461869253207-0-2 on ExchangeId: 
ID-macpro-local-53588-1461869253207-0-3). Exhausted after delivery attempt: 1 
caught: java.lang.IllegalStateException: Not the original message from the 
broker Message: Enter some text here for the message body...

Message History
---
RouteId  ProcessorId  Processor 
   Elapsed (ms)
[in-audit-to-file  ] [in-audit-to-file  ] [broker://queue:in.adt.*  
 ] [23]
[in-audit-to-file  ] [setHeader1] [setHeader[MyCustomHeader]
 ] [ 3]
[in-audit-to-file  ] [recipientList1] 
[recipientList[simple{broker://${header[JMSDestination]}}] 
] [18]

Exchange
---
Exchange[
Id  ID-macpro-local-53588-1461869253207-0-3
ExchangePattern InOnly
Headers 
{breadcrumbId=ID:macpro.local-53587-1461869252118-4:1:1:1:1, 
CamelRedelivered=false, CamelRedeliveryCounter=0, JMSCorrelationID=, 
JMSCorrelationIDAsBytes=, JMSDeliveryMode=1, 
JMSDestination=queue://in.adt.epic, JMSExpiration=0, 
JMSMessageID=ID:macpro.local-53587-1461869252118-4:1:1:1:1, JMSPriority=0, 
JMSRedelivered=false, JMSReplyTo=null, JMSTimestamp=1461869263684, JMSType=, 
JMSXGroupID=null, JMSXUserID=null, MyCustomHeader=MyHeaderValue}
BodyTypeString
BodyEnter some text here for the message body...
]

Stacktrace
---
 | org.apache.camel.processor.DefaultErrorHandler | ActiveMQ VMTransport: 
vm://localhost#1
java.lang.IllegalStateException: Not the original message from the broker 
Message: Enter some text here for the message body...
at 
org.apache.activemq.camel.component.broker.BrokerProducer.checkOriginalMessage(BrokerProducer.java:95)[activemq-camel-5.13.2.jar:5.13.2]
at 
org.apache.activemq.camel.component.broker.BrokerProducer.getMessage(BrokerProducer.java:73)[activemq-camel-5.13.2.jar:5.13.2]
at 
org.apache.activemq.camel.component.broker.BrokerProducer.processInOnly(BrokerProducer.java:55)[activemq-camel-5.13.2.jar:5.13.2]
at 
org.apache.activemq.camel.component.broker.BrokerProducer.process(BrokerProducer.java:43)[activemq-camel-5.13.2.jar:5.13.2]
at 
org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:460)[camel-core-2.16.2.jar:2.16.2]
at 
org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)[camel-core-2.16.2.jar:2.16.2]
at 
org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:668)[camel-core-2.16.2.jar:2.16.2]
at 
org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:596)[camel-core-2.16.2.jar:2.16.2]
at 

Re: Monitoring ActiveMQ

[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 
> <chhaya.vishwaka...@thinkbiganalytics.com> 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 
>> <chhaya.vishwaka...@thinkbiganalytics.com> 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<mailto:Chhaya.Vishwakarma@Th
>> 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

[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: Pooled connection factory does not work

[Quinn Stevenson]

Sorry Everyone - I missed that when reading the configs.

Thanks for pointing that out Tim - the configuration does look right.

> On Apr 7, 2016, at 10:00 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
> 
> Although I've only used the string-based syntax (e.g.
> from("jms:MyQueue?concurrentConsumers=10") ) to specify the number of
> concurrent consumers when I've used Camel, I assumed that  name="concurrentConsumers" value="10"/> specified in the XML DSL would have
> the same effect.
> 
> On Thu, Apr 7, 2016 at 9:21 AM, Quinn Stevenson <qu...@pronoia-solutions.com
>> wrote:
> 
>> Looking at the Camel route, I only see once consumer on the queue - am I
>> missing something?
>> 
>> 
>> 
>>> On Apr 7, 2016, at 4:17 AM, Michele <michele.mazzi...@finconsgroup.com>
>> wrote:
>>> 
>>> Hi Tim,
>>> 
>>> sorry, but I'm a bit confused.
>>> 
>>> My use case is to create a Camel Route that it is capable:
>>> 
>>> 1. Read large number of lines in File (approx. 5)
>>> 2. Split, Process and store every line in AMQ (Simple hash map)
>>> 3. Retrieve message from queue and invoke with POST a Rest Service that
>> is
>>> bottleneck (I need to process messages stored in AMQ slowly in order to
>>> don't overload a Rest Service Interface).
>>> 
>>> 
>>>   
>>>
>>>  
>>>  
>>>  
>>>  
>>>  
>>>
>>> 
>>> 
>>> 
>>>>> uri="activemq:queue:incomingTickets?destination.consumer.prefetchSize=0"
>> />
>>>
>>> 5
>>>  >> uri="jetty:
>> http://host/rs/v1.0/ticket?jettyHttpBindingRef=CustomJettyHttpBinding;
>>> />
>>>
>>> 
>>> 
>>> I don't understand well how Producer and Consumer work on the broker. My
>>> idea is that Producer pust message in Queue and Consumer pop message from
>>> queue to dispatch. Is it right?
>>> So, I configured  a pooled connection factory to handle efficiently
>>> connections, sessions, producers and consumers.
>>> As you can see bt attached picture  pooled-connection.png
>>> <
>> http://activemq.2283324.n4.nabble.com/file/n4710461/pooled-connection.png>
>>> , why is there only one consumer that works on Queue?
>>> 
>>> I hope i was clear.
>>> 
>>> Thanks a lot again
>>> 
>>> Kind greetings
>>> 
>>> Michele
>>> 
>>> 
>>> 
>>> --
>>> View this message in context:
>> http://activemq.2283324.n4.nabble.com/Pooled-connection-factory-does-not-work-tp4710421p4710461.html
>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>> 
>> 

Re: Pooled connection factory does not work

[Quinn Stevenson]

Looking at the Camel route, I only see once consumer on the queue - am I 
missing something?



> On Apr 7, 2016, at 4:17 AM, Michele  wrote:
> 
> Hi Tim,
> 
> sorry, but I'm a bit confused.
> 
> My use case is to create a Camel Route that it is capable:
> 
> 1. Read large number of lines in File (approx. 5)
> 2. Split, Process and store every line in AMQ (Simple hash map)
> 3. Retrieve message from queue and invoke with POST a Rest Service that is
> bottleneck (I need to process messages stored in AMQ slowly in order to
> don't overload a Rest Service Interface).
> 
> 
>
> 
>   
>   
>   
>   
>   
> 
> 
> 
> 
>  uri="activemq:queue:incomingTickets?destination.consumer.prefetchSize=0" />
> 
>  5   
>uri="jetty:http://host/rs/v1.0/ticket?jettyHttpBindingRef=CustomJettyHttpBinding;
> />
>   
> 
> 
> I don't understand well how Producer and Consumer work on the broker. My
> idea is that Producer pust message in Queue and Consumer pop message from
> queue to dispatch. Is it right?
> So, I configured  a pooled connection factory to handle efficiently
> connections, sessions, producers and consumers.
> As you can see bt attached picture  pooled-connection.png
>  
> , why is there only one consumer that works on Queue?
> 
> I hope i was clear.
> 
> Thanks a lot again
> 
> Kind greetings
> 
> Michele
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Pooled-connection-factory-does-not-work-tp4710421p4710461.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Usage of ActiveMQ as CDC (change data capture)

[Quinn Stevenson]

You can use ActiveMQ as the message broker between the process polling the 
database and the consuming process, but you’ll need something to poll the 
database.  You could use a simple Camel route for that.

> On Apr 6, 2016, at 5:03 AM, jotarada  wrote:
> 
> Hi i'm new to brokeres and massage queues.
> 
> In my project i need to check on a table from a database there are new row's
> and convert it to a message to the broker get it and send it to a consumer.
> 
> Is that possible in ActiveMQ?
> 
> Thanks in advance.
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Usage-of-ActiveMQ-as-CDC-change-data-capture-tp4710410.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Measures to improve the throughput

[Quinn Stevenson]

That seems very slow for a simple throughput test - my simple Camel tests have 
usually been in the 1000’s msgs/sec range.

Can you share the full test?

> On Mar 31, 2016, at 12:01 AM, Frizz  wrote:
> 
> In an atempt to improve the throughput of my system I did various tests. I
> started with a simple setup:
> - 1 Topic, non persistent
> - 1 Producer
> - 1 Consumer
> - Messge size: 4k
> - Active MQ 5.12.1
> 
> My system is reasonably fast (8 cores, 32GB memory, SSD) - still I only
> manage to send & receive about 45.000 messages per second.
> 
> Basically my producer looks like this:
>...
>ConnectionFactory factory = new
> ActiveMQConnectionFactory("tcp://loclhost:61616");
>Connection connection = factory.createConnection();
>session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
>producer = session.createProducer(null);
>connection.start();
> 
>for (long i = 0; i < 100; i++) {
>final Topic topic = session.createTopic(topicName);
>producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
> 
>BytesMessage message = session.createBytesMessage();
>message.writeBytes(someByteArray); // size 4k
>producer.send(topic, message);
>}
>...
> 
> I measured the time that the consumer spends in its onMessage() method and
> it's only about 1% of its total runtime (so consuming the messages is not a
> bottleneck (no surprise, because of BytesMessages)).
> 
> 45.000 messages/second does not sound *that* much to me - is this the
> maximum I can expect to get from Active MQ?
> 
> I did some further tests increasing the number of topic consumers - and
> noticed that my msg/sec drop. But the total amount of mes/sec that pass
> through my system stays roughly the same (OK, with some shrinkage/friction):
> 
> producer: 45.000
> consumer: 45.000
> --> 90.000 total
> producer: 28.700
> consumer: 28.700
> consumer: 28.700
> --> 86.100 total
> producer: 20.400
> consumer: 20.400
> consumer: 20.400
> consumer: 20.400
> --> 81.600 total
> producer: 15.700
> consumer: 15.700
> consumer: 15.700
> consumer: 15.700
> consumer: 15.700
> --> 78.500 total
> 
> 
> What I had expected would look more like this:
> producer: 43.000
> consumer: 43.000
> consumer: 43.000
> consumer: 43.000
> consumer: 43.000
> 
> Where does this "global total msg/sec limit" come from? Where is the
> bottleneck?

Re: Configuring Virtual Destinations via Jolokia REST Api in ActiveMQ 5.13.2

[Quinn Stevenson]

You may be able to accomplish what you’re after using a Camel route embedded in 
the ActiveMQ broker.
http://activemq.apache.org/broker-camel-component.html 

> On Mar 16, 2016, at 4:06 PM, Adel Boutros  wrote:
> 
> Hello Christopher,
> 
> In the way we will be using the broker, we would provide an API for clients
> to create these "redirections" between queues and topics on the fly. So
> this feature would be really useful as I know no other way of linking a
> queue to a topic.
> 
> Regards,
> Adel Boutros
> Murex SAS
> www.murex.com
> 
> On Wed, Mar 16, 2016 at 7:51 PM, Christopher Shannon <
> christopher.l.shan...@gmail.com> wrote:
> 
>> Currently this doesn't exist because Virtual destinations can only be set
>> on start up or modified by a runtime plugin. (either the xml runtime plugin
>> or the new java based one added in 5.13.0)
>> 
>> There would need to be a new feature implemented to enable modification
>> through JMX.
>> 
>> On Wed, Mar 16, 2016 at 1:45 PM, Adel Boutros  wrote:
>> 
>>> Hello,
>>> 
>>> I was wondering if there is a way to configure a Virtual Destination
>>> programmatically using the Jolokia REST Api?
>>> 
>>> I explored the JMX module using JConsole but found no possible solution.
>>> 
>>> I am following the example here:
>>> http://activemq.apache.org/virtual-destinations.html
>>> 
>>> Regards,
>>> 
>>> Adel Boutros
>>> Murex SAS
>>> www.murex.com
>>> 
>> 

Re: Multiple virtual topics and messages routing to consumers

[Quinn Stevenson]

umers, one that will consume from queue 
> Consumer.ConsumerA.VirtualTopic.> and another 
> one that will consume from queue Consumer.ConsumerB.VirtualTopic.MIGRATION.
> 
> Sending one message to each virtual topic I would expect something like this:
> 
>Consumer 'ConsumerA' received: This message was from topic 
> 'VirtualTopic.>'.
>Consumer 'ConsumerB' received: This message was from topic 
> 'VirtualTopic.MIGRATION'.
> 
> But I get something like this (the messages are replicated to all queues):
> 
>Consumer 'ConsumerA' received: This message was from topic 
> 'VirtualTopic.>'.
>Consumer 'ConsumerB' received: This message was from topic 
> 'VirtualTopic.>'.
>Consumer 'ConsumerA' received: This message was from topic 
> 'VirtualTopic.MIGRATION'.
>Consumer 'ConsumerB' received: This message was from topic 
> 'VirtualTopic.MIGRATION'.
> 
> I tested this using the default configuration with ActiveMQ versions 5.9.0 
> and 5.13.2.
> 
> You told that you were able to get this behavior with a sample. I would be 
> very grateful if you could share that sample :)
> 
> Regards, 
> 
> Le mardi 15 mars 2016 à 13:36 -0600, Quinn Stevenson a écrit :
>> Is there a specific reason the default configuration won’t work for you?  
>> (Either don’t set anything, or explicitly set the default of
>> 
>> 
>> I tried a simple sample using the defaults, and it seems to accomplish what 
>> you’re after.
>> 
>>> On Mar 14, 2016, at 11:05 AM, Nuno Oliveira 
>>> <nuno.olive...@geo-solutions.it> wrote:
>>> 
>>> >> prefix="Consumer.*.VirtualTopic."/>
>>>   >> prefix="Consumer.*.VirtualTopic."/>
>> 
> -- 
> ==
> GeoServer Professional Services from the experts! 
> Visit http://goo.gl/it488V for more information.
> ==
> Nuno Miguel Carvalho Oliveira
> @nmcoliveira
> Software Engineer
> 
> GeoSolutions S.A.S.
> Via di Montramito 3/A
> 55054  Massarosa (LU)
> Italy
> 
> phone: +39 0584 962313
> fax:   +39 0584 1660272
> mob:   +39  333 8128928
> 
> http://www.geo-solutions.it
> http://twitter.com/geosolutions_it
> 
> ---
> 
> AVVERTENZE AI SENSI DEL D.Lgs. 196/2003
> Le informazioni contenute in questo messaggio di posta elettronica e/o nel/i 
> file/s allegato/i sono
> da considerarsi strettamente riservate. Il loro utilizzo è consentito 
> esclusivamente al destinatario del messaggio, per le finalità indicate
> nel messaggio stesso. Qualora riceviate questo messaggio senza esserne il 
> destinatario, Vi preghiamo cortesemente di darcene notizia via e
> -mail e di procedere alla distruzione del messaggio stesso, cancellandolo dal 
> Vostro sistema. Conservare il messaggio stesso, divulgarlo
> anche in parte, distribuirlo ad altri soggetti, copiarlo, od utilizzarlo per 
> finalità diverse, costituisce comportamento contrario ai
> principi dettati dal D.Lgs. 196/2003.
> 
> The information in this message and/or attachments, is intended solely for 
> the attention and use of
> the named addressee(s) and may be confidential or proprietary in nature or 
> covered by the provisions of privacy act (Legislative Decree
> June, 30 2003, no.196 - Italy's New Data Protection Code).Any use not in 
> accord with its purpose, any disclosure, reproduction, copying,
> distribution, or either dissemination, either whole or partial, is strictly 
> forbidden except previous formal approval of the named
> addressee(s). If you are not the intended recipient, please contact 
> immediately the sender by telephone, fax or e-mail and delete the
> information in this message that has been received in error. The sender does 
> not give any warranty or accept liability as the content,
> accuracy or completeness of sent messages and accepts no responsibility  for 
> changes made after they were sent or for other risks which
> arise as a result of e-mail transmission, viruses, etc.
> 

Re: Multiple virtual topics and messages routing to consumers

[Quinn Stevenson]

Is there a specific reason the default configuration won’t work for you?  
(Either don’t set anything, or explicitly set the default of 

I tried a simple sample using the defaults, and it seems to accomplish what 
you’re after.

> On Mar 14, 2016, at 11:05 AM, Nuno Oliveira  
> wrote:
> 
>  prefix="Consumer.*.VirtualTopic."/>
> prefix="Consumer.*.VirtualTopic."/>

Re: Daily Message Count - HELP

[Quinn Stevenson]

You probably need to use the XML-escaped version of the & - i.e.  - I 
must’ve messed that up somehow in the copy/paste.


> On Mar 7, 2016, at 12:33 PM, gmelasecca  
> wrote:
> 
> This is great. I am using this in my dev environment successfully. The only 
> question or issue I have is the below error I get in the logs when im using 
> the query string below you provided. I changed the query to remove the 
> "=queue:stats.destination" pattern="InOnly". And activemq starts and 
> logs the stats. Can you assist and explain why it doesn't like that replyTo 
> query string? I tried to google the error and look at ActiveMQ forum but 
> didn't explain much.
> 
> Camel.xml
> 
> 
> 
> 
> 
> 
> 
> 
> 
>  uri="activemq://queue:ActiveMQ.Statistics.Destination?preserveMessageQos=true=queue://stats.destination"
>  pattern="InOnly"/>
> 
> 
> 
> ACTIVEMQ.log
> 2016-03-07 14:46:53,385 | INFO  | Refreshing 
> org.apache.activemq.xbean.XBeanBrokerFactory$1@393a82f5: startup date [Mon 
> Mar 07 14:46:53 EST 2016]; root of context hierarchy | 
> org.apache.activemq.xbean.XBeanBrokerFactory$1 | WrapperSimpleAppMain
> 2016-03-07 14:46:54,587 | ERROR | Failed to load: class path resource 
> [activemq.xml], reason: Line 54 in XML document from class path resource 
> [camel.xml] is invalid; nested exception is org.xml.sax.SAXParseException; 
> lineNumber: 54; columnNumber: 90; The reference to entity "replyTo" must end 
> with the ';' delimiter. | org.apache.activemq.xbean.XBeanBrokerFactory | 
> WrapperSimpleAppMain
> org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line 
> 54 in XML document from class path resource [camel.xml] is invalid; nested 
> exception is org.xml.sax.SAXParseException; lineNumber: 54; columnNumber: 90; 
> The reference to entity "replyTo" must end with the ';' delimiter.
>at 
> org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:396)
>at 
> org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:334)
>at 
> org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:302)
>at 
> org.apache.xbean.spring.context.v2.XBeanBeanDefinitionDocumentReader.importBeanDefinitionResource(XBeanBeanDefinitionDocumentReader.java:129)
>at 
> org.apache.xbean.spring.context.v2.XBeanBeanDefinitionDocumentReader.parseDefaultElement(XBeanBeanDefinitionDocumentReader.java:95)
>at 
> org.apache.xbean.spring.context.v2.XBeanBeanDefinitionDocumentReader.parseBeanDefinitions(XBeanBeanDefinitionDocumentReader.java:81)
>at 
> org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.registerBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:93)
> 
> Greg Melasecca
> Analyst - IS Shared Services
> 1.610.612.5782 (work)
> 1.302.250.2519 (cell)
> [cid:image001.png@01D17882.0E70]
> 
> From: hqstevenson [via ActiveMQ] 
> [mailto:ml-node+s2283324n4708593...@n4.nabble.com]
> Sent: Monday, February 29, 2016 2:49 PM
> To: Melasecca, Gregory 
> Subject: Re: Daily Message Count - HELP
> 
> I don't know if you still need this, but I put together a small XML sample 
> that will log all destination statistics every 5 seconds.
> 
> You'll probably want to mess with the pattern for the destination names and 
> the timer for the destination statistics.  There's also a Camel route that is 
> commented out that will log the broker statistics.
> 
> camel-stats.xml
> 
> You can put this file in the $ACTIVEMQ_HOME/conf directory and then add an 
> import into the activemq.xml
> 
> 
> 
> If you reply to this email, your message will be added to the discussion 
> below:
> http://activemq.2283324.n4.nabble.com/Daily-Message-Count-HELP-tp4708157p4708593.html
> To unsubscribe from Daily Message Count - HELP, click 
> here.
> NAML
> This e-mail and any attachments may contain information which is 
> confidential, proprietary, privileged or otherwise protected by law. The 
> information is solely intended for the named addressee (or a person 
> responsible for delivering it to the addressee). If you are not the intended 
> recipient of this message, you are not authorized to read, 

Re: Daily Message Count - HELP

[Quinn Stevenson]

You shouldn’t need to write any java - you can use the Spring DSL, and the 
route can run inside the ActiveMQ broker.

I don’t think you’ll have the camel-splunk component in that old of an ActiveMQ 
version, so that limits your options a bit.  You could have the route log the 
contents of the statistics messages and then Splunk will pick them up (since 
you’re already indexing the ActiveMQ logs).

Unfortunately, I don’t have authority to share the XML I used to do this before 
I did this for a customer and I’ll have to ask them if they are willing to let 
me share it.

> On Feb 24, 2016, at 10:16 AM, gmelasecca  
> wrote:
> 
> Awesome, this makes it easier to understand what I need to do but in the 
> scheme of things we do not have an on-site java developer to help build/code 
> any classes so I’m kind of being the admin of this application out of the box 
> for now. Our vendor required we use it to coincide with their new API’s. the 
> only difference is our environment is different than theirs so we can’t just 
> copy down their configs.
> BTW we are running Apache ActiveMQ version: 5.6.0-4.0
> 
> I do believe we have camel route enabled. I opened the jar file we have and 
> see there is a bunch of camel classes under 
> “org\apache\activemq\camel\component” such as: CalemEndpointLoader, 
> ActiveMQComponent, JournalEndpoint and within “org\apache\activemq\camel” I 
> have about 12 different camel classes like: CamelConnection, CamelQueue, 
> CamelMessageCOnsumer etc.
> 
> To answer/ comment on your statements below:
> The configuration you’ve got below will enable the statistics plugin - that’s 
> step one.
> **I enabled that configuration within the dev environment I have.
> Step two is to setup some process that periodically triggers the statistics 
> plugin.  The Statistics plugin will then put the acquired statistics on the 
> JMS destination specified by the requester.  This is pretty easy to do with a 
> camel route embedded in the ActiveMQ broker, but it can run anywhere.
> **What kind of process, are you saying write some code to do this within 
> java? Do you have an example or steps on what needs to be done? Unfortunately 
> the camel.apache.org docs assume im a java developer in their terminology.
> 
> Finally, you need something to read the statistics from the JMS destinations 
> and do whatever you want with them - I send them to Splunk using the 
> camel-splunk component.
> **I have splunk installed within my DEV environment and its reading the 
> activemq.log and kahadb.log. It is however not reading the camel components. 
> Can you give any assistance on setting this up? It looks like I need to add 
> some XML to the MAVEN\pom.xml which I assume is within the activeMQ.jar file 
> (I opened/spoke about above)
> 
> Greg Melasecca
> Analyst - IS Shared Services
> 1.610.612.5782 (work)
> 1.302.250.2519 (cell)
> [cid:image001.png@01D16EFE.AFA2B6C0]
> 
> From: hqstevenson [via ActiveMQ] 
> [mailto:ml-node+s2283324n4708216...@n4.nabble.com]
> Sent: Wednesday, February 24, 2016 10:47 AM
> To: Melasecca, Gregory 
> Subject: Re: Daily Message Count - HELP
> 
> The configuration you’ve got below will enable the statistics plugin - that’s 
> step one.
> 
> Step two is to setup some process that periodically triggers the statistics 
> plugin.  The Statistics plugin will then put the acquired statistics on the 
> JMS destination specified by the requester.  This is pretty easy to do with a 
> camel route embedded in the ActiveMQ broker, but it can run anywhere.
> 
> Finally, you need something to read the statistics from the JMS destinations 
> and do whatever you want with them - I send them to Splunk using the 
> camel-splunk component.
> 
>> On Feb 24, 2016, at 6:17 AM, gmelasecca <[hidden 
>> email]> wrote:
>> 
>> Hqstevenson - I am not a java coder of any sort and really just starting 
>> out. So first thanks for the article but im still unclear as to what I need 
>> to do. I have splunk installed as a forwarder on the ActiveMQ server, which 
>> feeds the kahadb and activemq.log files to my indexers and search head. I 
>> installed the JMS plug-in for splunk also but im getting JNDI connection 
>> errors.
>> 
>> That being said from your example, you are saying that I need to edit my 
>> activemq.xml and add the below configuration string within , than 
>> restart ActiveMQ? DO I need to implement code, classes etc?
>> 
>> 
>>   
>> 
>> 
>> Regards,
>> 
>> Greg Melasecca
>> Analyst - IS Shared Services
>> 1.610.612.5782 (work)
>> 1.302.250.2519 (cell)
>> [cid:image001.png@01D16EDF.23B7DE70] 
>> 
>> From: hqstevenson [via ActiveMQ] [mailto:[hidden 
>> email] > email]>]
>> Sent: Tuesday, February 23, 2016 10:29 PM
>> To: Melasecca, Gregory <[hidden 
>> email] > email]>>
>> Subject: Re: Daily Message Count - HELP
>> 
>> We use the ActiveMQ Statistics Plugin ( 

Re: Daily Message Count - HELP

[Quinn Stevenson]

The configuration you’ve got below will enable the statistics plugin - that’s 
step one.

Step two is to setup some process that periodically triggers the statistics 
plugin.  The Statistics plugin will then put the acquired statistics on the JMS 
destination specified by the requester.  This is pretty easy to do with a camel 
route embedded in the ActiveMQ broker, but it can run anywhere.

Finally, you need something to read the statistics from the JMS destinations 
and do whatever you want with them - I send them to Splunk using the 
camel-splunk component.


> On Feb 24, 2016, at 6:17 AM, gmelasecca  
> wrote:
> 
> Hqstevenson - I am not a java coder of any sort and really just starting out. 
> So first thanks for the article but im still unclear as to what I need to do. 
> I have splunk installed as a forwarder on the ActiveMQ server, which feeds 
> the kahadb and activemq.log files to my indexers and search head. I installed 
> the JMS plug-in for splunk also but im getting JNDI connection errors.
> 
> That being said from your example, you are saying that I need to edit my 
> activemq.xml and add the below configuration string within , than 
> restart ActiveMQ? DO I need to implement code, classes etc?
> 
>  
>
>  
> 
> Regards,
> 
> Greg Melasecca
> Analyst - IS Shared Services
> 1.610.612.5782 (work)
> 1.302.250.2519 (cell)
> [cid:image001.png@01D16EDF.23B7DE70] 
> 
> From: hqstevenson [via ActiveMQ] 
> [mailto:ml-node+s2283324n4708203...@n4.nabble.com 
> ]
> Sent: Tuesday, February 23, 2016 10:29 PM
> To: Melasecca, Gregory  >
> Subject: Re: Daily Message Count - HELP
> 
> We use the ActiveMQ Statistics Plugin ( 
> http://activemq.apache.org/statisticsplugin.html 
>  
>  > )
> 
> We have a small camel route that runs on a timer, grabs the statistics from 
> the plugin and stores them in Splunk.
> 
>> On Feb 23, 2016, at 3:33 PM, gmelasecca <[hidden 
>> email]> wrote:
>> 
>> Evening - I am new to ActiveMQ and my current company is using the
>> application for a large set of applications/messages. We are working to
>> determine how to find the Daily or Hourly amount of messages the entire
>> application consumes or if possible what each queue consumes on a
>> daily/hourly basis. I know the home page offers me Store, Memory, Temp usage
>> but this doesn't help us tune our application to the specified needs.
>> 
>> It seems every couple of days we are having to delete or purge many queues
>> because we are reaching our store limit of "10gb". below is what our limits
>> are set at utilizing the messagebroker.properties. I am looking into adding
>> the "producerFlowControl=" feature for the max consumed queues.
>> 
>> system.memory.limit= 3072mb
>> system.storage.limit   = 10gb
>> system.temp.limit  = 10gb
>> producer.memory.limit  = 200mb
>> 
>> 
>> 
>> --
>> View this message in context: 
>> http://activemq.2283324.n4.nabble.com/Daily-Message-Count-HELP-tp4708157.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> 
> 
> 
> If you reply to this email, your message will be added to the discussion 
> below:
> http://activemq.2283324.n4.nabble.com/Daily-Message-Count-HELP-tp4708157p4708203.html
>  
> 
> To unsubscribe from Daily Message Count - HELP, click 
> here  
> >.
> NAML  
> >
> This e-mail and any attachments may contain information which is 
> confidential, proprietary, privileged or otherwise protected by law. The 
> information is solely intended for 

Re: Daily Message Count - HELP

[Quinn Stevenson]

We use the ActiveMQ Statistics Plugin ( 
http://activemq.apache.org/statisticsplugin.html 
 )

We have a small camel route that runs on a timer, grabs the statistics from the 
plugin and stores them in Splunk.

> On Feb 23, 2016, at 3:33 PM, gmelasecca  
> wrote:
> 
> Evening - I am new to ActiveMQ and my current company is using the
> application for a large set of applications/messages. We are working to
> determine how to find the Daily or Hourly amount of messages the entire
> application consumes or if possible what each queue consumes on a
> daily/hourly basis. I know the home page offers me Store, Memory, Temp usage
> but this doesn't help us tune our application to the specified needs. 
> 
> It seems every couple of days we are having to delete or purge many queues
> because we are reaching our store limit of "10gb". below is what our limits
> are set at utilizing the messagebroker.properties. I am looking into adding
> the "producerFlowControl=" feature for the max consumed queues.
> 
> system.memory.limit= 3072mb
> system.storage.limit = 10gb
> system.temp.limit  = 10gb
> producer.memory.limit  = 200mb
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Daily-Message-Count-HELP-tp4708157.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Help with a Failover testing that shows missing messages

[Quinn Stevenson]

This Camel route doesn’t appear to use any sort of transactional control - i.e. 
CLIENT_ACKNOWLEDGE or SESSION_TRANSACTED.  

Try adding “transacted=true” in your consuming URI -




> On Feb 22, 2016, at 8:05 AM, mtod  wrote:
> 
> Thanks for the reply.
> 
> The messages were missing across all clients.
> 
> Not sure what you referring to about Camel Ack mode.
> 
> I  add the Camel file using an import in the ActiveMQ file
> 
> ...
> 
>  
> 
> Here is my Camel Code:
> 
> 
>   xmlns="http://www.springframework.org/schema/beans;
>  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance;
>  xsi:schemaLocation="http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
>  http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd
>  http://activemq.apache.org/schema/core
> http://activemq.apache.org/schema/core/activemq-core.xsd;>
> 
> 
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
>
>file:${activemq.conf}/credentials.properties
>
>
>   
>class="org.apache.camel.builder.DeadLetterChannelBuilder">
>   
>ref="myRedeliveryPolicyConfig"/>
>   
> 
>class="org.apache.camel.processor.RedeliveryPolicy">
>   
>   
>   
>   
>xmlns="http://camel.apache.org/schema/spring;
> xmlns:km="http://xsdrepo.foundationmedicine.com/messaging/esb;>   
>   
>   
>   
>
>uri="validator:http://xsdrepo.foundationmedicine.com/messaging/esb/ESBMessageV3.xsd"/>
>
> 
>resultType="String">/km:FMIMessage/km:Header/km:Route/text()
>   
>   
>   Route1
>   
>   
>   
> org.apache.camel.ValidationException   
>   
>   
>   
> ${exception.message}
>   
>uri="activemq:queue:invalid.schema"/>
>   
>   
>   
>   
> 
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Help-with-a-Failover-testing-that-shows-missing-messages-tp4707916p4707937.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: suppress error from Camel Route on slave

[Quinn Stevenson]

I had a similar setup in ActiveMQ 5.11.2 - but the route was a simple timer 
that wrote a log statement (amount other things).  When I ran this 
configuration in a Master/Slave configuration with a KahaDB store, the routes 
were only active one ActiveMQ instance at a time.

Can you post the camel.xml and the activemq.xml files?  I’d like to see what 
the differences are.

Quinn Stevenson
qu...@pronoia-solutions.com
(801) 244-7758



> On Dec 29, 2015, at 10:14 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
> 
> Nope, never; I've only read about it here and on the wiki.  (I've used
> Camel, but never embedded in a broker.)  Sorry.  But others on this list
> have, so hopefully they can share first-hand knowledge.
> On Dec 29, 2015 10:22 AM, "Quinn Stevenson" <qu...@pronoia-solutions.com>
> wrote:
> 
>> Have you tried using the Broker Camel Component (
>> http://activemq.apache.org/broker-camel-component.html <
>> http://activemq.apache.org/broker-camel-component.html> )?  I thought
>> that it wouldn’t start the route unless the broker was running.
>> 
>> 
>> Quinn Stevenson
>> qu...@pronoia-solutions.com
>> (801) 244-7758
>> 
>> 
>> 
>>> On Dec 29, 2015, at 7:45 AM, mtod <m...@thetods.net> wrote:
>>> 
>>> That's what I would like to happen but the question is how?
>>> 
>>> Thanks
>>> 
>>> Mike
>>> 
>>> 
>>> 
>>> --
>>> View this message in context:
>> http://activemq.2283324.n4.nabble.com/suppress-error-from-Camel-Route-on-slave-tp4705457p4705478.html
>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>> 
>> 

Re: suppress error from Camel Route on slave

[Quinn Stevenson]

Have you tried using the Broker Camel Component ( 
http://activemq.apache.org/broker-camel-component.html 
<http://activemq.apache.org/broker-camel-component.html> )?  I thought that it 
wouldn’t start the route unless the broker was running.


Quinn Stevenson
qu...@pronoia-solutions.com
(801) 244-7758



> On Dec 29, 2015, at 7:45 AM, mtod <m...@thetods.net> wrote:
> 
> That's what I would like to happen but the question is how?
> 
> Thanks
> 
> Mike
> 
> 
> 
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/suppress-error-from-Camel-Route-on-slave-tp4705457p4705478.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.