Hi Gordon,
Thank you for the help.
After sending utf8 encoded contentobject it is working fine.
Posting working snippet below.
Sender managementSender =
session.createSender("activemq.management");
Message requestMessage;
//Working combinations
//-----------------------------------------------------------------
//1)
/*requestMessage.setProperty("_AMQ_ResourceName", "broker");
requestMessage.setProperty("_AMQ_OperationName",
"getQueueNames");*/
//output
/*[["TempQueue","ExpiryQueue","DLQ","318e9e2b-b1b5-4099-958e-0e863621eeff"]]*/
//2) Queue Operations
/*requestMessage.setProperty("_AMQ_ResourceName",
"queue.TempQueue");
requestMessage.setProperty("_AMQ_OperationName",
"getMessageCount"); */
/*requestMessage.setProperty("_AMQ_ResourceName",
"queue.TempQueue");
requestMessage.setProperty("_AMQ_OperationName",
"getConsumerCount");
*/
/*requestMessage.setProperty("_AMQ_ResourceName",
"queue.TempQueue");
requestMessage.setProperty("_AMQ_OperationName",
"getMaxConsumers");*/
//-----------------------------------------------------------------
requestMessage.setProperty("_AMQ_ResourceName",
"queue.TempQueue");
requestMessage.setProperty("_AMQ_OperationName",
"getMaxConsumers");
Receiver managementReceiver = session.createReceiver("#");
Address managementReplyQueue = managementReceiver.getAddress();
requestMessage.setReplyTo(managementReplyQueue);
qpid::types::Variant varObj("[]");
varObj.setEncoding("utf8");
requestMessage.setContentObject(varObj);
managementSender.send(requestMessage);
Thanks,
Mohan
--
Sent from: http://qpid.2158936.n2.nabble.com/Apache-Qpid-users-f2158936.html
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
