[jira] [Updated] (ARTEMIS-2520) Consumer.receive return null if server is stopped

[Timothy A. Bish (Jira)]

 [ 
https://issues.apache.org/jira/browse/ARTEMIS-2520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Timothy A. Bish updated ARTEMIS-2520:
-
Priority: Minor  (was: Major)

> Consumer.receive return null if server is stopped
> -
>
> Key: ARTEMIS-2520
> URL: https://issues.apache.org/jira/browse/ARTEMIS-2520
> Project: ActiveMQ Artemis
>  Issue Type: Improvement
>Reporter: Domenico Bruscino
>Priority: Minor
>
> ActiveMQMessageConsumer.receive(timeout) returns null, if the server is 
> stopped during the call.
> Test to reproduce:
> {code:java}
> ConnectionFactory factorySend = new ActiveMQConnectionFactory();
> Connection connection = factorySend.createConnection();
> try (Session session = connection.createSession()) {
>javax.jms.Queue queue = session.createQueue("queueStop");
>MessageProducer producer = session.createProducer(queue);
>producer.send(session.createTextMessage("text"));
>connection.start();
>MessageConsumer consumer = session.createConsumer(queue);
>assertNotNull(consumer.receive(1000));
>final CountDownLatch stoppingLatch = new CountDownLatch(1);
>(new Thread(new Runnable() {
>   @Override
>   public void run() {
>  try {
> stoppingLatch.countDown();
> Thread.sleep(1000);
> server.stop();
>  } catch (Exception e) {
> e.printStackTrace();
>  }
>   }
>})).start();
>try {
>   stoppingLatch.await();
>   consumer.receive(5000);
>   Assert.fail("didn't get expected exception!");
>} catch (Exception e) {
>   e.printStackTrace();
>}
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (ARTEMIS-2520) Consumer.receive return null if server is stopped

[Domenico Bruscino (Jira)]

 [ 
https://issues.apache.org/jira/browse/ARTEMIS-2520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Domenico Bruscino updated ARTEMIS-2520:
---
Issue Type: Improvement  (was: Bug)

> Consumer.receive return null if server is stopped
> -
>
> Key: ARTEMIS-2520
> URL: https://issues.apache.org/jira/browse/ARTEMIS-2520
> Project: ActiveMQ Artemis
>  Issue Type: Improvement
>Reporter: Domenico Bruscino
>Priority: Major
>
> ActiveMQMessageConsumer.receive(timeout) returns null, if the server is 
> stopped during the call.
> Test to reproduce:
> {code:java}
> ConnectionFactory factorySend = new ActiveMQConnectionFactory();
> Connection connection = factorySend.createConnection();
> try (Session session = connection.createSession()) {
>javax.jms.Queue queue = session.createQueue("queueStop");
>MessageProducer producer = session.createProducer(queue);
>producer.send(session.createTextMessage("text"));
>connection.start();
>MessageConsumer consumer = session.createConsumer(queue);
>assertNotNull(consumer.receive(1000));
>final CountDownLatch stoppingLatch = new CountDownLatch(1);
>(new Thread(new Runnable() {
>   @Override
>   public void run() {
>  try {
> stoppingLatch.countDown();
> Thread.sleep(1000);
> server.stop();
>  } catch (Exception e) {
> e.printStackTrace();
>  }
>   }
>})).start();
>try {
>   stoppingLatch.await();
>   consumer.receive(5000);
>   Assert.fail("didn't get expected exception!");
>} catch (Exception e) {
>   e.printStackTrace();
>}
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)