Jmin队列的测试例子

Jmin队列的测试例子:

发送端:

public class TestQueue {

public static void main(String args[])throws Exception{

NSRB nsrb = NSRB.init();
NetContext context = nsrb.createNetContext("socket://localhost:9988");
QueueProxy proxy1 = new QueueProxy();
QueueXMLProxy proxy2 = new QueueXMLProxy();
proxy1.bind(context);
proxy2.bind(context);

AsynRequest request = new AsynRequest();
J2eeAspectDestination destination= new J2eeAspectDestination();
destination.setAspectName("hello");
destination.setServiceID("queue");
request.setDestination(destination);

request.setContent("test1");
proxy1.publish(request);
request.setContent("test2");
proxy2.publish(request);

}


接收端:(尽管发送端有时使用XML序列化传送的数据,一样可以接受;如果接受端不在线的话,信息将保存在队列中!)

public class TestReceiver {

public static void main(String args[])throws Exception{

NSRB nsrb = NSRB.init();
NetContext context = nsrb.createNetContext("socket://localhost:9988");
QueueProxy proxy1 = new QueueProxy();
proxy1.bind(context);

HelloAsynListner lister = new HelloAsynListner();
proxy1.connect("queue","hello",lister);

Object obj = new Object();
Locker.lock(obj);
}

}


简单吧!

文章来自: 本站原创
标签: jmservice