[
https://issues.apache.org/jira/browse/ARTEMIS-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justin Bertram updated ARTEMIS-1773:
------------------------------------
Description:
Following code as reference:
{code:java}
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TemporaryQueue;
import javax.jms.TextMessage;
public class TemporaryQueueExample {
public static void main(final String[] args) throws Exception {
Connection consumeConnection = null;
Connection produceConnection = null;
try {
ConnectionFactory cf = new
ActiveMQConnectionFactory("tcp://localhost:61616");
consumeConnection = cf.createConnection();
produceConnection = cf.createConnection();
consumeConnection.start();
produceConnection.start();
Session consumeSession = consumeConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Session produceSession = produceConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
TemporaryQueue tempQueue = consumeSession.createTemporaryQueue();
System.out.println("Temporary queue is created: " + tempQueue);
MessageProducer messageProducer =
produceSession.createProducer(tempQueue);
TextMessage message = produceSession.createTextMessage("This is a
text message");
messageProducer.send(message);
System.out.println("Sent message: " + message.getText());
MessageConsumer messageConsumer =
consumeSession.createConsumer(tempQueue);
message = (TextMessage) messageConsumer.receive(5000);
System.out.println("Received message: " + message.getText());
// close
messageProducer.close();
produceSession.close();
produceConnection.close();
produceConnection = new
ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
produceSession = produceConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
messageProducer = produceSession.createProducer(tempQueue);
TextMessage message2 = produceSession.createTextMessage("This is
anoter text message");
messageProducer.send(message2);
System.out.println("Sent message: " + message2.getText());
message = (TextMessage) messageConsumer.receive(5000);
System.out.println("Received message: " + message.getText());
} finally {
if (produceConnection != null) {
produceConnection.close();
}
if (consumeConnection != null) {
consumeConnection.close();
}
}
}
}
{code}
Above code fails randomly (not always) when trying to send a message to the
temp queue created by the "consumeSession". It fails either on the first
{code:java}
messageProduer.send(message);
{code}
or on the second
{code:java}
messageProduer.send(message2);
{code}
The exception is:
{code:java}
javax.jms.InvalidDestinationException: Cannot publish to a deleted Destination:
temp-queue://ID:XXXX
{code}
It only failed with the following combination of server/client libs:
* Artemis Server 2.3.0 or 2.5.0 and activemq-client library 5.15.3 or 5.14.5
When using ActiveMQ as a JMS server all worked fine. Also when using
{{org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory}} together
with Artemis Server 2.5.0 all worked fine.
was:
Following code as reference:
{code:java}
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TemporaryQueue;
import javax.jms.TextMessage;
public class TemporaryQueueExample {
public static void main(final String[] args) throws Exception {
Connection consumeConnection = null;
Connection produceConnection = null;
try {
ConnectionFactory cf = new
ActiveMQConnectionFactory("tcp://localhost:61616");
consumeConnection = cf.createConnection();
produceConnection = cf.createConnection();
consumeConnection.start();
produceConnection.start();
Session consumeSession = consumeConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Session produceSession = produceConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
TemporaryQueue tempQueue = consumeSession.createTemporaryQueue();
System.out.println("Temporary queue is created: " + tempQueue);
MessageProducer messageProducer =
produceSession.createProducer(tempQueue);
TextMessage message = produceSession.createTextMessage("This is a
text message");
messageProducer.send(message);
System.out.println("Sent message: " + message.getText());
MessageConsumer messageConsumer =
consumeSession.createConsumer(tempQueue);
message = (TextMessage) messageConsumer.receive(5000);
System.out.println("Received message: " + message.getText());
// close
messageProducer.close();
produceSession.close();
produceConnection.close();
produceConnection = new
ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
produceSession = produceConnection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
messageProducer = produceSession.createProducer(tempQueue);
TextMessage message2 = produceSession.createTextMessage("This is
anoter text message");
messageProducer.send(message2);
System.out.println("Sent message: " + message2.getText());
message = (TextMessage) messageConsumer.receive(5000);
System.out.println("Received message: " + message.getText());
} finally {
if (produceConnection != null) {
produceConnection.close();
}
if (consumeConnection != null) {
consumeConnection.close();
}
}
}
}
{code}
Above code fails randomly (not always) when trying to send a message to the
temp queue created by the "consumeSession". It fails either on the first
{code:java}
messageProduer.send(message);
{code}
or on the second
{code:java}
messageProduer.send(message2);
{code}
The exception is:
{code:java}
javax.jms.InvalidDestinationException: Cannot publish to a deleted Destination:
temp-queue://ID:XXXX
{code}
It only failed with the following combination of server/client libs:
* Artemis Server 2.3.0 or 2.5.0 and activemq-client library 5.15.3 or 5.14.5
When using ActiveMQ as a JMS server all worked fine. Also when using
{{org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory}} together
with Artemis Server 2.5.0 all worked fine.
> Trying to send to an existing temp queue fails after a "reconnect"
> ------------------------------------------------------------------
>
> Key: ARTEMIS-1773
> URL: https://issues.apache.org/jira/browse/ARTEMIS-1773
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Affects Versions: 2.5.0
> Reporter: Mario Hochreiter
> Priority: Major
>
> Following code as reference:
> {code:java}
> import org.apache.activemq.ActiveMQConnectionFactory;
> import javax.jms.Connection;
> import javax.jms.ConnectionFactory;
> import javax.jms.MessageConsumer;
> import javax.jms.MessageProducer;
> import javax.jms.Session;
> import javax.jms.TemporaryQueue;
> import javax.jms.TextMessage;
> public class TemporaryQueueExample {
> public static void main(final String[] args) throws Exception {
> Connection consumeConnection = null;
> Connection produceConnection = null;
> try {
> ConnectionFactory cf = new
> ActiveMQConnectionFactory("tcp://localhost:61616");
> consumeConnection = cf.createConnection();
> produceConnection = cf.createConnection();
> consumeConnection.start();
> produceConnection.start();
> Session consumeSession = consumeConnection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
> Session produceSession = produceConnection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
> TemporaryQueue tempQueue = consumeSession.createTemporaryQueue();
> System.out.println("Temporary queue is created: " + tempQueue);
> MessageProducer messageProducer =
> produceSession.createProducer(tempQueue);
> TextMessage message = produceSession.createTextMessage("This is a
> text message");
> messageProducer.send(message);
> System.out.println("Sent message: " + message.getText());
> MessageConsumer messageConsumer =
> consumeSession.createConsumer(tempQueue);
> message = (TextMessage) messageConsumer.receive(5000);
> System.out.println("Received message: " + message.getText());
> // close
> messageProducer.close();
> produceSession.close();
> produceConnection.close();
> produceConnection = new
> ActiveMQConnectionFactory("tcp://localhost:61616").createConnection();
> produceSession = produceConnection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
> messageProducer = produceSession.createProducer(tempQueue);
> TextMessage message2 = produceSession.createTextMessage("This is
> anoter text message");
> messageProducer.send(message2);
> System.out.println("Sent message: " + message2.getText());
> message = (TextMessage) messageConsumer.receive(5000);
> System.out.println("Received message: " + message.getText());
> } finally {
> if (produceConnection != null) {
> produceConnection.close();
> }
> if (consumeConnection != null) {
> consumeConnection.close();
> }
> }
> }
> }
> {code}
> Above code fails randomly (not always) when trying to send a message to the
> temp queue created by the "consumeSession". It fails either on the first
> {code:java}
> messageProduer.send(message);
> {code}
> or on the second
> {code:java}
> messageProduer.send(message2);
> {code}
> The exception is:
> {code:java}
> javax.jms.InvalidDestinationException: Cannot publish to a deleted
> Destination: temp-queue://ID:XXXX
> {code}
> It only failed with the following combination of server/client libs:
> * Artemis Server 2.3.0 or 2.5.0 and activemq-client library 5.15.3 or 5.14.5
>
> When using ActiveMQ as a JMS server all worked fine. Also when using
> {{org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory}} together
> with Artemis Server 2.5.0 all worked fine.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
