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.IOReactorException
public 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.