Hi,
I implement a server as follows:
public Server() {
Bus bus = BusFactory.getDefaultBus();
WorkQueueManager wqm = bus.getExtension(WorkQueueManager.class);
AutomaticWorkQueueImpl wq = new
AutomaticWorkQueueImpl("udp-transport");
wq.setHighWaterMark(50); ///number of threads, min: 5, max: 2^31-1,
default: 25
wq.setQueueSize(512); ///queue size, min: 1, max: 2^31-1,
default:256
wqm.addNamedWorkQueue("udp-transport", wq);
System.out.println("Server with a cache ");
JaxWsServerFactoryBean factory = new JaxWsServerFactoryBean();
factory.setAddress("udp://192.168.56.1:9292/print");
factory.setServiceClass(Service.class);
factory.setServiceBean(this);
factory.getInInterceptors().add(new LoggingInInterceptor());
factory.getOutInterceptors().add(new LoggingOutInterceptor());
factory.create().start();
}
How to get the messages which have not processed and returned to client yet
in Queue (wq) ?
Thanks,
Regards,