MQSeries.net :: View topic - Open Input exclusive option (MQC.MQOO_INPUT_EXCLUSIVE )

ksrjo24 · Last edited by ksrjo24 on Thu Sep 23, 2010 7:29 am; edited 2 times in total

Hi,
Here is a sample program that i am trying to test the exclusive Queue Access using MQ JMS.
MQQueueConnectionFactory cf = new MQQueueConnectionFactory();

// Config
cf.setHostName("myhost");
cf.setPort(1414);

cf.setTransportType(1);
cf.setQueueManager("MyQueueManager");
cf.setChannel("Mychannel");

MQQueueConnection connection = (MQQueueConnection) cf.createQueueConnection();
MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
MQQueue queue = (MQQueue) session.createQueue("queue:///myqueue");

//MQQueue queue = (MQQueue) session.createQueue("queue:///myqueue");
MQQueueSender sender = (MQQueueSender) session.createSender(queue);

MQQueueReceiver receiver = (MQQueueReceiver) session.createReceiver(queue);

long uniqueNumber = System.currentTimeMillis() % 1000;
JMSTextMessage message = (JMSTextMessage) session.createTextMessage("SimplePTP "+ uniqueNumber);

connection.start();

//sender.send(message);
System.out.println("Sent message:\\n" + message);

Message receivedMessage = (Message) receiver.receive(1000);
if (receivedMessage instanceof TextMessage) {
String replyString = ((TextMessage) receivedMessage).getText();
System.out.println(replyString);
} else {
// Print error message if Message was not a TextMessage.
System.out.println("Reply message was not a TextMessage");
}
//System.out.println("\\nReceived message:\\n" + receivedMessage);

sender.close();
receiver.close();
session.close();
connection.close();

System.out.println("\\nSUCCESS\\n");

What i need is for this connection go be equivalent to the IBM Native option of MQOO_INPUT_EXCLUSIVE and MQQA_SHAREABLE = FALSE

Basically I want the connection to get an exclusive access to the queue.

I can modify the
MQQueue queue = (MQQueue) session.createQueue("queue:///myqueue");

with soem key value pairs. something like
MQQueue queue = (MQQueue) session.createQueue("queue:///myqueue?persistence=1&priority=5")

or I could use the setProperty method of the MQQueue
queue.setPersistence(DeliveryMode.NON_PERSISTENT);
queue.setPriority(5);

From the documentation, these are the only properties that I can use are
expiry,priority,persistence,CCSID,targetClienet,encoding.

My question is what property do I set to get the equivalent of Exclusive write access to the queue??

Thanks