Hi, We can set the waiting timeout of client with the property "cxf.synchronous.timeout". However, i set the high value of waiting timeout but the client does not receive responses from server For example: waiting timeout of client is 10 minutes. The processing time of server is 5minutes par packet. In this case, the server responds messages to client but the client does not receive them. I think this is the problem of connection timeout between client and server. The session (connection) is not maintained during communication between client and server.
Can anyone please help me? Tho, 2015-04-15 9:26 GMT+02:00 Christian Schneider <[email protected]>: > I am not sure how to set the timeout to wait for the response in the udp > transport. > As your example is very asynchronous you might think about using two one > way transports anyway. > You can use ws addressing to set the url to send the response to. Or store > it in your service data. > > To use two one way transports would also allow to recover from the client > going down while waiting for a response. > > Christian > > > On 13.04.2015 18:22, tho huynh ngoc wrote: > >> Hi, >> >> I have a server CXF - OSGi, as delared >> >> Bus bus = BusFactory.*getDefaultBus*(); >> >> WorkQueueManager wqm = bus.getExtension(WorkQueueManager.*class*); >> >> AutomaticWorkQueueImpl wq = *new* AutomaticWorkQueueImpl("udp- >> transport"); >> >> wq.setHighWaterMark(25); ///number of threads, *min*: 5, max: 2^31-1, >> default: 25 >> >> wq.setQueueSize(64); ///queue size, *min*: 1, max: 2^31-1, default:256 >> >> //System.out.println("5th and 1mem"); >> >> //any other settings here >> >> wqm.addNamedWorkQueue("udp-transport", wq); >> >> JaxWsServerFactoryBean factory = *new* JaxWsServerFactoryBean(); >> >> factory.setAddress("udp://192.168.56.1:9393/print"); >> >> factory.setServiceClass(Service.*class*); >> >> factory.setServiceBean(*this*); >> >> factory.getInInterceptors().add(*new* LoggingInInterceptor()); >> >> factory.getOutInterceptors().add(*new* LoggingOutInterceptor()); >> >> factory.create().start(); >> >> I use my two queues to save requests and responses at server side. >> >> inputList = *new* ConcurrentLinkedQueue<Job>(); >> >> returnList = *new* CopyOnWriteArrayList<Job>(); >> >> inputList saves requests from clients >> >> returnList saves results of requests. >> >> When a client sends a message to the server, the server saves this >> message >> into inputList and then looks for results of this message in returnList >> and >> returns it to the client >> >> An independent thread reads inputList and calculate it, then returns >> results to returnList >> >> Problem: I run 100 clients sending msgs at the same time to server. With >> the above configuration, server can receive 91 msgs and RETURNS also these >> 91 msgs to client. >> >> However, there are only 62 clients receiving the returns, although I set >> timeout of clients with a high value (the waiting time to receiving the >> results). Clients are configured as follows >> >> factory = *new* JaxWsProxyFactoryBean(); >> >> factory.getInInterceptors().add(*new* LoggingInInterceptor()); >> >> factory.getOutInterceptors().add(*new* LoggingOutInterceptor()); >> >> factory.setServiceClass(Service.*class*); >> >> factory.setAddress("udp://192.168.56.1:9393/print"); >> >> Map<String, Object> props = *new* HashMap<String,Object>(); >> >> props.put("cxf.synchronous.timeout", *new* Integer(3000000)); >> >> factory.setProperties(props); >> >> service = (Service) factory.create(); >> >> I think this problem is related to connection timeout between client and >> server apart from "cxf.synchronous.timeout" value of a client. >> >> *Question:* >> >> I can configure the connection timeout at the server or client side, can't >> i? How to configure the connection timeout ? >> >> Best regards, >> >> > > -- > Christian Schneider > http://www.liquid-reality.de > > Open Source Architect > http://www.talend.com > >
