建立连接的代码如下:
Hashtable env = new Hashtable();
env.put("java.naming.provider.url", url);
env.put("java.naming.security.principal", userName);
env.put("java.naming.security.credentials", password);
env.put("java.naming.factory.initial", "weblogic.jndi.WLInitialContextFactory");
ctx = new InitialContext(env);
fcty = (QueueConnectionFactory)ctx.lookup(connectionFactoryJNDI);
conn = fcty.createQueueConnection();
sess = conn.createQueueSession(false, 1);
q = (Queue)ctx.lookup(queueJNDI);
qsdr = sess.createSender(q);
qrcr = sess.createReceiver(q);
conn.start();
Hashtable env = new Hashtable();
env.put("java.naming.provider.url", url);
env.put("java.naming.security.principal", userName);
env.put("java.naming.security.credentials", password);
env.put("java.naming.factory.initial", "weblogic.jndi.WLInitialContextFactory");
ctx = new InitialContext(env);
fcty = (QueueConnectionFactory)ctx.lookup(connectionFactoryJNDI);
conn = fcty.createQueueConnection();
sess = conn.createQueueSession(false, 1);
q = (Queue)ctx.lookup(queueJNDI);
qsdr = sess.createSender(q);
qrcr = sess.createReceiver(q);
conn.start();
解决方案 »
免费领取超大流量手机卡,每月29元包185G流量+100分钟通话, 中国电信官方发货