Methods Summary |
---|
public void | close()
if (selectorThread != null) {
selectorThread.stopEndpoint();
IncomeMessageProcessor.releaseListener(selectorThread.getPort());
selectorThread = null;
}
|
public int | getFrameSize()
return selectorThread.getBufferSize();
|
public java.lang.String | getHost()
return host;
|
public com.sun.xml.ws.transport.tcp.server.TCPMessageListener | getListener()
return listener;
|
public int | getPort()
return port;
|
public void | listen()
if (isPortUnificationMode) {
listenOnUnifiedPort();
} else {
listenOnNewPort();
}
|
public void | listenOnNewPort()
try {
IncomeMessageProcessor.registerListener(port, listener, properties);
selectorThread = new SelectorThread();
selectorThread.setClassLoader(WSTCPStreamAlgorithm.class.getClassLoader());
selectorThread.setAlgorithmClassName(WSTCPStreamAlgorithm.class.getName());
selectorThread.setAddress(InetAddress.getByName(host));
selectorThread.setPort(port);
selectorThread.setBufferSize(TCPConstants.DEFAULT_FRAME_SIZE);
selectorThread.initEndpoint();
selectorThread.start();
} catch (IOException e) {
close();
throw e;
} catch (InstantiationException e) {
close();
throw new IOException(e.getClass().getName() + ": " + e.getMessage());
}
|
public void | listenOnUnifiedPort()
WSTCPProtocolHandler.setIncomingMessageProcessor(IncomeMessageProcessor.registerListener(0, listener, properties));
|
public void | setFrameSize(int frameSize)
selectorThread.setBufferSize(frameSize);
|
public void | setHost(java.lang.String host)
this.host = host;
|
public void | setListener(com.sun.xml.ws.transport.tcp.server.TCPMessageListener listener)
this.listener = listener;
|
public void | setPort(int port)
this.port = port;
|