Re: JMS Asynchronous Receiver for ActiveMQ Artemis

2019-02-21 Thread Justin Bertram
That makes sense, Tim. Thanks for the clarification. Justin On Thu, Feb 21, 2019 at 9:31 PM Timothy Bish wrote: > On 2/21/19 10:24 PM, Justin Bertram wrote: > > I looked at the code for the javax.jms.Connection implementation in > > ActiveMQ 5 and it wasn't clear to me what would have been blo

Re: JMS Asynchronous Receiver for ActiveMQ Artemis

2019-02-21 Thread Timothy Bish
On 2/21/19 10:24 PM, Justin Bertram wrote: I looked at the code for the javax.jms.Connection implementation in ActiveMQ 5 and it wasn't clear to me what would have been blocking in the call to start(). Artemis supports the OpenWire protocol so you can still use the 5.x client. If you use the 5.x

Re: JMS Asynchronous Receiver for ActiveMQ Artemis

2019-02-21 Thread Justin Bertram
I looked at the code for the javax.jms.Connection implementation in ActiveMQ 5 and it wasn't clear to me what would have been blocking in the call to start(). Artemis supports the OpenWire protocol so you can still use the 5.x client. If you use the 5.x client with Artemis does it block? I'd be cur

Re: JMS Asynchronous Receiver for ActiveMQ Artemis

2019-02-21 Thread Riyafa Abdul Hameed
Hi, I tried the same example (after changing the contextfactory) with ActiveMQ (version 5.15.8) and the main program does not exit. That is the reason I expected the same behavior from ActiveMQ Artemis. If that is not defined in the JMS spec I will follow other ways you have suggested to prevent t

Re: [ActiveMQ Artemis]: Message Groups; STOMP; idle consumers

2019-02-21 Thread Justin Bertram
I believe you're seeing the expected behavior. A queue's fundamental semantics are first-in-first-out (i.e. FIFO). Using message grouping doesn't change those semantics. The first 100 messages in the queue (which all belong to the same group) must be dispatched before the 101st message is dispatche

Soket connection ActiveMQ with .Net

2019-02-21 Thread adan_fabbri
Hello, I have a task where I need to establish a connection between an ActiveMQ queue and a .Net application. I am using the AMQP.Net Lite plugin for this. But I have a need for the receiver of the .Net application to be called the moment the message goes into the queue. Is there any solution wher

[ActiveMQ Artemis]: Message Groups; STOMP; idle consumers

2019-02-21 Thread Egor Kalinin
Good day, Protocol: STOMP auto-create-queues, auto-create-addresses Steps to reproduce: 1. Run two consumers which subscribe to the `test` queue ['ack': 'client', 'subscription-type': 'ANYCAST'] which are in the infinite loop take a message from a queue, wait for 1 second and then send ACK. 2. Pu

Re: JMS Asynchronous Receiver for ActiveMQ Artemis

2019-02-21 Thread michael.andre.pearce
You could use a countdown latch that then when you wish to shutdown you simply from another thread countdown.Sent from my Samsung Galaxy smartphone. Original message From: Riyafa Abdul Hameed Date: 21/02/2019 14:06 (GMT+00:00) To: users@activemq.apache.org Subject: JMS Asynch

Re: JMS Asynchronous Receiver for ActiveMQ Artemis

2019-02-21 Thread Justin Bertram
I've never seen or heard of javax.jms.Connection.start() blocking in that respect, and the JMS specification doesn't describe the behavior you expect. I think such behavior would be problematic in many use-cases (e.g. when you don't want to block). The whole point behind using a MessageListener is

JMS Asynchronous Receiver for ActiveMQ Artemis

2019-02-21 Thread Riyafa Abdul Hameed
Hi, I have the following asynchronous receiver for ActiveMQ Artemis: https://gist.github.com/riyafa/7b0e5814286c60edb157f9a83fb64765 Here what I would expect when I call queueConn.start(); is that I want the thread to wait to receive messages. I mean I don't want the main to exit causing the pro

client can't consume some messages in pendingmessages

2019-02-21 Thread mymailmjj1984
hi,I am confused by a question. I send messages with spring-jms producer,the activemq server works most normally,but some pendingmessages can't be confused by consumers unitil I reboot the activemq server. os:suse activemq version:activemq 5.9.0 client version:spring-jms 4.1.4 spring 3.2.4 Any one