Ans)
import java.util.Properties;
import
javax.jms.JMSException;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import
javax.jms.QueueConnectionFactory;
import
javax.jms.QueueReceiver;
import
javax.jms.QueueSender;
import
javax.jms.QueueSession;
import javax.jms.Session;
import javax.naming.Context;
import
javax.naming.InitialContext;
public class TestMQ
{
public static void main(String[] args) {
try {
Properties p = new Properties();
p.put("org.omg.CORBA.ORBClass","com.sun.CORBA.iiop.ORB");
//p.put("org.omg.CORBA.ORBSingletonClass","com.ibm.rmi.corba.ORBSingleton");
//
p.put("javax.rmi.CORBA.UtilClass","com.ibm.rmi.javax.rmi.CORBA.Util");
//
p.put("javax.rmi.CORBA.StubClass","com.ibm.rmi.javax.rmi.CORBA.StubDelegateImpl");
//
p.put("java.naming.factory.url.pkgs","com.ibm.ws.naming");
p.setProperty( javax.naming.Context.INITIAL_CONTEXT_FACTORY,
"com.ibm.websphere.naming.WsnInitialContextFactory"
);
//javax.naming.Context.INITIAL_CONTEXT_FACTORY, for the property
name,
//and the constant,
com.ibm.websphere.naming.PROPS.INITIAL_CONTEXT_FACTORY, for the
property value.
p.setProperty( "java.naming.provider.url",
"iiop://HOSTNAME:PORT" );
String
connectionfactoryjndi="jms/testQCF";
//String sendQueueName="jms/apinboundq";
String sendQueueName="jms/destOutboundQ";
Context jndiContext = new InitialContext();
jndiContext = new InitialContext( p );
QueueConnectionFactory cf = (QueueConnectionFactory)
jndiContext.lookup(connectionfactoryjndi);
System.out.println("Looked up : QueueConnectionFactory
"+ connectionfactoryjndi);
System.out.println("Transport Queue [" +
sendQueueName + "]");
QueueConnection connection = (QueueConnection)
cf.createQueueConnection();
QueueSession session = (QueueSession)
connection.createQueueSession(false,
Session.CLIENT_ACKNOWLEDGE);
Queue queue = (Queue) jndiContext.lookup(sendQueueName);
QueueSender sender = (QueueSender)
session.createSender(queue);
QueueReceiver receiver = (QueueReceiver)
session.createReceiver(queue);
long uniqueNumber = System.currentTimeMillis() % 1000;
javax.jms.TextMessage message =
session.createTextMessage("Test Message "+
uniqueNumber);
// Start the connection
connection.start();
sender.send(message);
//
System.out.println("Sent message:\\n" +
message);
sender.close();
receiver.close();
session.close();
connection.close();
System.out.println("\\nSUCCESS\\n");
}
catch (JMSException jmsex) {
System.out.println(jmsex);
System.out.println("\\nFAILURE\\n");
}
catch (Exception ex) {
System.out.println(ex);
System.out.println("\\nFAILURE\\n");
}
}
}
Back to top