public class PassThroughListeningIOReactorManager extends Object
| Modifier and Type | Method and Description |
|---|---|
boolean |
closeAllPTTListenerEndpoints(int port)
Close all endpoints started by PTT Listeners.
|
boolean |
closeDynamicPTTEndpoint(int port)
Close external endpoints listen in shared IO Reactor
|
boolean |
closeSpecificPTTListenerEndpoints(int port,
Set<InetSocketAddress> bindAddresses)
Close specific endpoints started by PTT Listeners using give set of bind addresses.
|
static PassThroughListeningIOReactorManager |
getInstance()
Provide manager object for internal services
|
ServerIODispatch |
getServerIODispatch(int port)
Return ServerIODispatch registered under given port
|
SourceConfiguration |
getSharedPassThroughSourceConfiguration() |
SourceConfiguration |
getSharedSSLPassThroughSourceConfiguration() |
org.apache.http.nio.reactor.ListeningIOReactor |
initIOReactor(int port,
org.apache.http.nio.NHttpServerEventHandler nHttpServerEventHandler,
PassThroughSharedListenerConfiguration passThroughSharedListenerConfiguration)
Create IOReactor with given configuration
|
boolean |
isDynamicEndpointRunning(int port)
Check whether dynamic endpoint is running for a particular port
|
void |
pauseIOReactor(int port)
Pause IO Reactor which is registered by HTTPListener running on given port
|
void |
resumeIOReactor(int port)
Resume IO Reactor which is registered by HTTPListener running on given port
|
void |
shutdownIOReactor(int port)
ShutdownIOReactor which is registered by HTTPListener running on given port
|
void |
shutdownIOReactor(int port,
long miliSeconds)
ShutdownIOReactor which is registered by HTTPListener running on given port
|
boolean |
startDynamicPTTEndpoint(InetSocketAddress inetSocketAddress,
org.apache.http.nio.NHttpServerEventHandler nHttpServerEventHandler,
String endpointName)
Start Endpoint in IOReactor which is external to PTT Axis2 Listeners started at server startup
|
boolean |
startDynamicPTTSSLEndpoint(InetSocketAddress inetSocketAddress,
org.apache.http.nio.NHttpServerEventHandler nHttpServerEventHandler,
String endpointName,
SSLConfiguration sslConfiguration)
Start SSL endpoint in IO reactor which is external to PTT Axis Listeners started at server startup
|
void |
startIOReactor(org.apache.http.nio.reactor.ListeningIOReactor listeningIOReactor,
ServerIODispatch serverIODispatch,
String prefix)
StartIOReactor with given ServerIODispatch
|
boolean |
startPTTEndpoint(InetSocketAddress inetSocketAddress,
org.apache.http.impl.nio.reactor.DefaultListeningIOReactor defaultListeningIOReactor,
String namePrefix)
Start PTT Endpoint which is given by axis2.xml
|
public static PassThroughListeningIOReactorManager getInstance()
public boolean startPTTEndpoint(InetSocketAddress inetSocketAddress, org.apache.http.impl.nio.reactor.DefaultListeningIOReactor defaultListeningIOReactor, String namePrefix)
inetSocketAddress - Socket Address of starting endpointdefaultListeningIOReactor - IO Reactor which starts EndpointnamePrefix - name specified for endpointpublic boolean startDynamicPTTEndpoint(InetSocketAddress inetSocketAddress, org.apache.http.nio.NHttpServerEventHandler nHttpServerEventHandler, String endpointName)
inetSocketAddress - Socket Address of starting endpointnHttpServerEventHandler - ServerHandler responsible for handle events of portendpointName - Endpoint Namepublic boolean startDynamicPTTSSLEndpoint(InetSocketAddress inetSocketAddress, org.apache.http.nio.NHttpServerEventHandler nHttpServerEventHandler, String endpointName, SSLConfiguration sslConfiguration)
inetSocketAddress - InetSocketAddressnHttpServerEventHandler - ServerHandler responsible for handle events of portendpointName - Endpoint NamesslConfiguration - SSL information for create secure connectionpublic org.apache.http.nio.reactor.ListeningIOReactor initIOReactor(int port,
org.apache.http.nio.NHttpServerEventHandler nHttpServerEventHandler,
PassThroughSharedListenerConfiguration passThroughSharedListenerConfiguration)
throws org.apache.http.nio.reactor.IOReactorException
port - Port of the Endpoint for axis2 ListenernHttpServerEventHandler - Server Handler responsible for handle events of portpassThroughSharedListenerConfiguration - configuration related to create and start IOReactororg.apache.http.nio.reactor.IOReactorExceptionpublic boolean closeDynamicPTTEndpoint(int port)
port - Port of the endpoint need to closepublic boolean closeAllPTTListenerEndpoints(int port)
port - Port of the Endpoint for PTT axis2 Listenerpublic boolean closeSpecificPTTListenerEndpoints(int port,
Set<InetSocketAddress> bindAddresses)
port - Port of the listenerbindAddresses - bind address list of endpoints to be closedpublic ServerIODispatch getServerIODispatch(int port)
port - Port of axis2 PTT Listenerpublic SourceConfiguration getSharedPassThroughSourceConfiguration()
public SourceConfiguration getSharedSSLPassThroughSourceConfiguration()
public void shutdownIOReactor(int port)
throws IOException
port - Port of axis2 PTT ListenerIOException - Exception throwing when Shutdownpublic void shutdownIOReactor(int port,
long miliSeconds)
throws IOException
port - Port of axis2 PTT ListenermiliSeconds - Waiting Time before close IO ReactorIOException - Exception throwing when Shutdownpublic void pauseIOReactor(int port)
throws IOException
port - Port of axis2 PTT ListenerIOException - Exception throwing when pausingpublic void resumeIOReactor(int port)
throws IOException
port - Port of axis2 PTT ListenerIOException - Exception throwing when pausingpublic void startIOReactor(org.apache.http.nio.reactor.ListeningIOReactor listeningIOReactor,
ServerIODispatch serverIODispatch,
String prefix)
listeningIOReactor - Listening IO Reactor to be startserverIODispatch - underlying Event Dispatcher for Reactorprefix - HTTP/HTTPSpublic boolean isDynamicEndpointRunning(int port)
port - portCopyright © 2005–2019 Apache Software Foundation. All rights reserved.