activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bobeo <vnger2...@gmail.com>
Subject Re: AMQCPP -- Cannot publish to a delete Destination: temp-queue
Date Fri, 19 May 2017 23:56:01 GMT
hi Tim,

Maybe I wasn't clear enough. Let me make it clear again:

First, I have a queue : sn.queue.settings.

>From Java, I send a message to that queue, and I can see from the log of
activemq broker, I highlight important bits: 

INFO | Sending message: ActiveMQTextMessage {commandId = 24,
responseRequired = false, *messageId =
ID:ubuntu-14-dev-49451-1495115456046-1:1:1:1:3*, originalDestination = null,
originalTransactionId = null, producerId =
ID:ubuntu-14-dev-49451-1495115456046-1:1:1:1, destination =
queue://sn.queue.settings, transactionId = null, expiration = 1495115724634,
timestamp = 1495115722634, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
correlationId = null, *replyTo =
temp-queue://ID:ubuntu-14-dev-49451-1495115456046-1:1:3*, persistent =
false, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.apache.activemq.util.ByteSequence@1cf5297b, marshalledProperties =
org.apache.activemq.util.ByteSequence@21c49053, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = {fromHost=central,
toHost=central}, readOnlyProperties = false, readOnlyBody = false, droppable
= false, jmsXGroupFirstForConsumer = false, text = <?xml version="1.0"
encoding="UTF-8" standalo...></settings>

As you can see, I set replyTo to a temporary queu
"temp-queue://ID:ubuntu-14-dev-49451-1495115456046-1:1:3" 

My consumer( client ) is written in C++, from onMessage() callback, I
receive the message :

Message ID =
ID:sensen-hyd-edge-demo-01-42179-1495108420785-1:1:1:1:3:-1:-1:2
Destination type = 3

And when I try to send back the reply with the destination from
message->getCMSReplyTo(), it gives me exception:

 Cannot publish to a deleted Destination: temp-queue://
	FILE: activemq/core/kernels/ActiveMQSessionKernel.cpp, LINE: 1013
	FILE: activemq/core/kernels/ActiveMQProducerKernel.cpp, LINE: 274
	FILE: activemq/core/kernels/ActiveMQProducerKernel.cpp, LINE: 184
	FILE: activemq/core/ActiveMQProducer.cpp, LINE: 100

I hope this is clearer. Do you still think the broker has advisory support
disabled? ( How to check this? ). 

Is this the right way to disable the watching of temp destination?

      amqConnFactory = new ActiveMQConnectionFactory(CONN); 
      amqConnFactory.setWatchTopicAdvisories(false);

Thanks a lot for your help.



--
View this message in context: http://activemq.2283324.n4.nabble.com/AMQCPP-Cannot-publish-to-a-delete-Destination-temp-queue-tp4672611p4726407.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message