Re: Load balancing based on topics

[Clebert Suconic]

when you have the same subscription created among different boxes, it
will follow the LOAD_BALANCE policy you have selected.

When it's different subscriptions, all the boxes on the same cluster
connection will receive the same messages. i.e. it will distribute to
them all.




On Fri, Oct 7, 2016 at 6:05 PM, aries.aries  wrote:
> Hi,
>
> Can someone please explain me how Artemis performs load balancing with
> topics? I understand somewhat about how it does with jms queues but I don't
> understand how the load balancing is done with respect to topics. Also is a
> there a way I can configure Artemis to evenly distribute topics among
> different nodes in a cluster? Thank you in advance.
>
>
>
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Load-balancing-based-on-topics-tp4717664.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.



-- 
Clebert Suconic

Re: [Artemis] Browse scheduled and delivering messages

[Clebert Suconic]

Take a look on QueueControl::browse

It would be easy to patch it to look at the ScheduledDeliveries. I
could even guide you around it if you are interested.




On Tue, Oct 18, 2016 at 2:36 PM, abhijith  wrote:
> I am assuming you are referring to JMSBrowser.
>
> We have locked down Queues and Topics with authentication and authorization.
> We would have to create a management role just for browsing which I am
> trying to avoid.  Also, this user would be super user who could essentially
> read from everywhere.
>
>
>
> --
> View this message in context: 
> http://activemq.2283324.n4.nabble.com/Artemis-Browse-scheduled-and-delivering-messages-tp4717972p4718043.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.



-- 
Clebert Suconic

Re: Artemis Core XA Example

[Clebert Suconic]

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  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" 
> wrote:
>
>> On Tue, Oct 18, 2016 at 12:45 PM, Quinn Stevenson
>>  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: ActiveMq 5.14.1 - Memory Leak?

[Christopher Shannon]

As far as I know there haven't been any reports or issues having to do with
a memory leak in recent versions.

How much memory is being used is really up to the JVM in terms of how it
handles allocation and GC.  The only way to really know if there is a
memory leak is to analyze the results of a heap dump and see what's
actually in memory and not just how much memory is allocated.


On Thu, Oct 20, 2016 at 9:13 AM, swidnow2 
wrote:

> Hi Guys
>
> I am running Broker using: 'java -cp activemq-all-5.14.1.jar
> org.apache.activemq.console.command.ShellCommand start' (JDK8u60).
>
> Besides of this I used OpenWire example code for Java:
> https://www.dropbox.com/s/y654vrltof1w0p2/openwire2.zip?dl=0
>
> I have just modified Producer's code to send messages for longer time.
>
> What I observed is that memory consumed by Broker process is increasing in
> time - about 15 MB after 2 hours ('WS Private' in Process Explorer or
> 'Private Working Set' in Task Manager).
>
> On the other side I do not see anything suspicious using Yourkit Profiler
> (heap space is GC collected correctly).
>
> I have also checked the queue status using mBeans, but it looks that there
> are no messages not consumed.
>
> As I am new in ActiveMQ, could someone explain to me why is the memory
> consumption increasing in time for Broker process? Is it a memory leak?
>
> I was looking for similar topic, but could not find any - if there is,
> please guide me.
>
> Thank you
> Damian
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/ActiveMq-5-14-1-Memory-Leak-tp4718129.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Re: activemq cms - timeToLive is creating an issue

[mkoppala]

Sorry for less information.
I tried the following:-

Just now I changed the delivery mode to PERSISTENT and setting the ttl. The
messages are getting delivered to the broker now.

But still I see the messages are not discarded at broker after the timer
expiry.
I suppose the api call to setTimeToLive is not overriding the default
value!?
Some post says I need to set setExplicitQosEnabled(true) to set the below
values. If so, how can I set this?

producer->send(message.get(),DeliveryMode::PERSISTENT,4,6);

I also tried setting the ttl at producer and send(message.get()) But no
help.




--
View this message in context: 
http://activemq.2283324.n4.nabble.com/activemq-cms-timeToLive-is-creating-an-issue-tp4718128p4718135.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: HornetQ client connect to Artemis server

[Martyn Taylor]

Great.  Good to hear.

On Wed, Oct 19, 2016 at 2:58 PM, hcrobison 
wrote:

> I am all set. My problem was when we embedded the Artemis server, we missed
> the jar arttemis-hornetq-protocol-1.x.0.jar.
> Thanks.
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/HornetQ-client-connect-to-Artemis-server-tp4717861p4718084.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Re: activemq cms - timeToLive is creating an issue

[Timothy Bish]

If you want someone to offer you help then it'd be good to cover what 
you've done to analyze the problem.


On 10/20/2016 09:27 AM, mkoppala wrote:

I check in broker uri and also capture the trace on broker port.
The clocks are in synch.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/activemq-cms-timeToLive-is-creating-an-issue-tp4718128p4718133.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.




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

Re: activemq cms - timeToLive is creating an issue

[mkoppala]

I check in broker uri and also capture the trace on broker port.
The clocks are in synch.



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/activemq-cms-timeToLive-is-creating-an-issue-tp4718128p4718133.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: activemq cms - timeToLive is creating an issue

[Timothy Bish]

How do you know they aren't delivered to the broker?
Have you checked that the clocks on the machines are in sync?

On 10/20/2016 08:27 AM, mkoppala wrote:

Hi,
I am using activemq-cpp-3.9.3. I want to set ttl value on a producer or
while sending messages.
The moment I set ttl value using producer->setTimeToLive(3), the
messages never delivered to the broker. If I comment above line all is fine
and messages are delivered properly. Can anyone help me to figure out the
issue here?





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/activemq-cms-timeToLive-is-creating-an-issue-tp4718128.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.




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

ActiveMq 5.14.1 - Memory Leak?

[swidnow2]

Hi Guys

I am running Broker using: 'java -cp activemq-all-5.14.1.jar
org.apache.activemq.console.command.ShellCommand start' (JDK8u60).

Besides of this I used OpenWire example code for Java:
https://www.dropbox.com/s/y654vrltof1w0p2/openwire2.zip?dl=0

I have just modified Producer's code to send messages for longer time.

What I observed is that memory consumed by Broker process is increasing in
time - about 15 MB after 2 hours ('WS Private' in Process Explorer or
'Private Working Set' in Task Manager).

On the other side I do not see anything suspicious using Yourkit Profiler
(heap space is GC collected correctly). 

I have also checked the queue status using mBeans, but it looks that there
are no messages not consumed.

As I am new in ActiveMQ, could someone explain to me why is the memory
consumption increasing in time for Broker process? Is it a memory leak?

I was looking for similar topic, but could not find any - if there is,
please guide me.

Thank you
Damian



--
View this message in context: 
http://activemq.2283324.n4.nabble.com/ActiveMq-5-14-1-Memory-Leak-tp4718129.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

activemq cms - timeToLive is creating an issue

[mkoppala]

Hi,
I am using activemq-cpp-3.9.3. I want to set ttl value on a producer or
while sending messages.
The moment I set ttl value using producer->setTimeToLive(3), the
messages never delivered to the broker. If I comment above line all is fine
and messages are delivered properly. Can anyone help me to figure out the
issue here?





--
View this message in context: 
http://activemq.2283324.n4.nabble.com/activemq-cms-timeToLive-is-creating-an-issue-tp4718128.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.