public abstract class AbstractChannelOpenListenerService extends Object implements org.jboss.msc.service.Service<Void>, org.jboss.remoting3.OpenListener
Modifier and Type | Field and Description |
---|---|
protected static int |
CHANNEL_SHUTDOWN_TIMEOUT
How long we wait for active operations to clear before allowing channel close to proceed
|
protected String |
channelName |
Constructor and Description |
---|
AbstractChannelOpenListenerService(String channelName,
org.xnio.OptionMap optionMap) |
Modifier and Type | Method and Description |
---|---|
void |
channelOpened(org.jboss.remoting3.Channel channel) |
protected abstract void |
execute(Runnable runnable)
Execute the shutdown task.
|
org.jboss.msc.value.InjectedValue<org.jboss.remoting3.Endpoint> |
getEndpointInjector() |
org.jboss.msc.value.InjectedValue<ManagementChannelRegistryService> |
getRegistry() |
org.jboss.msc.service.ServiceName |
getServiceName(org.jboss.msc.service.ServiceName endpointName) |
Void |
getValue() |
protected abstract ManagementChannelInitialization.ManagementChannelShutdownHandle |
handleChannelOpened(org.jboss.remoting3.Channel channel)
Handle a channel open event.
|
void |
registrationTerminated() |
void |
start(org.jboss.msc.service.StartContext context) |
void |
stop(org.jboss.msc.service.StopContext context) |
protected static final int CHANNEL_SHUTDOWN_TIMEOUT
protected final String channelName
public AbstractChannelOpenListenerService(String channelName, org.xnio.OptionMap optionMap)
public org.jboss.msc.service.ServiceName getServiceName(org.jboss.msc.service.ServiceName endpointName)
public org.jboss.msc.value.InjectedValue<org.jboss.remoting3.Endpoint> getEndpointInjector()
public org.jboss.msc.value.InjectedValue<ManagementChannelRegistryService> getRegistry()
public Void getValue() throws IllegalStateException, IllegalArgumentException
getValue
in interface org.jboss.msc.value.Value<Void>
IllegalStateException
IllegalArgumentException
public void start(org.jboss.msc.service.StartContext context) throws org.jboss.msc.service.StartException
start
in interface org.jboss.msc.service.Service<Void>
org.jboss.msc.service.StartException
public void stop(org.jboss.msc.service.StopContext context)
stop
in interface org.jboss.msc.service.Service<Void>
public void channelOpened(org.jboss.remoting3.Channel channel)
channelOpened
in interface org.jboss.remoting3.OpenListener
public void registrationTerminated()
registrationTerminated
in interface org.jboss.remoting3.OpenListener
protected abstract ManagementChannelInitialization.ManagementChannelShutdownHandle handleChannelOpened(org.jboss.remoting3.Channel channel)
channel
- the opened channelprotected abstract void execute(Runnable runnable)
runnable
- the runnableCopyright © 2023 JBoss by Red Hat. All rights reserved.