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,

Reply via email to