Re: Load balancing based on topics
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
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
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?
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
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
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
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
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
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?
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
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.