Package | Description |
---|---|
org.jboss.as.controller.client.impl |
Implementation classes to support the
core JBoss AS management client API . |
org.jboss.ejb.client | |
org.jboss.naming.remote.protocol | |
org.jboss.naming.remote.protocol.v1 | |
org.jboss.naming.remote.server | |
org.jboss.remoting3 |
The base Remoting 3 API package.
|
org.jboss.remoting3.spi |
Service provider classes and interfaces.
|
org.jboss.remotingjmx | |
org.jboss.remotingjmx.protocol | |
org.jboss.remotingjmx.protocol.v1 | |
org.jboss.remotingjmx.protocol.v2 |
Modifier and Type | Method and Description |
---|---|
protected Channel |
RemotingModelControllerClient.getOrCreateChannel() |
Modifier and Type | Method and Description |
---|---|
static ModelControllerClient |
ExistingChannelModelControllerClient.createReceiving(Channel channel,
ExecutorService executorService)
Create a model controller client which is exclusively receiving messages on a existing channel.
|
Modifier and Type | Method and Description |
---|---|
void |
Logs.channelCanNoLongerProcessMessages(Channel channel) |
void |
Logs.successfulVersionHandshake(EJBReceiverContext receiverContext,
Channel channel) |
Modifier and Type | Method and Description |
---|---|
T |
ProtocolCommand.execute(Channel channel,
Object... args) |
static RemoteNamingServer |
Versions.getRemoteNamingServer(byte version,
Channel channel,
RemoteNamingService remoteNamingServer) |
static RemoteNamingStore |
Versions.getRemoteNamingStore(byte version,
Channel channel) |
static RemoteNamingStore |
Versions.getRemoteNamingStore(byte version,
Channel channel,
EJBClientHandler ejbClientHandler) |
void |
ProtocolCommand.handleServerMessage(Channel channel,
DataInput input,
int correlationId,
RemoteNamingService namingServer) |
Modifier and Type | Method and Description |
---|---|
static RemoteNamingServer |
VersionOne.getNamingServer(Channel channel,
RemoteNamingService remoteNamingServer) |
static RemoteNamingStoreV1 |
VersionOne.getRemoteNamingStore(Channel channel) |
static RemoteNamingStoreV1 |
VersionOne.getRemoteNamingStore(Channel channel,
EJBClientHandler ejbClientHandler) |
Constructor and Description |
---|
RemoteNamingServerV1(Channel channel,
RemoteNamingService remoteNamingServer) |
RemoteNamingStoreV1(Channel channel) |
RemoteNamingStoreV1(Channel channel,
EJBClientHandler ejbClientHandler) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteNamingServerLogger.closingChannel(Channel channel,
Throwable t) |
void |
DefaultRemoteNamingServerLogger.closingChannel(Channel channel,
Throwable error) |
void |
RemoteNamingServerLogger.closingChannelOnChannelEnd(Channel channel) |
void |
DefaultRemoteNamingServerLogger.closingChannelOnChannelEnd(Channel channel) |
Modifier and Type | Method and Description |
---|---|
IoFuture<Channel> |
Connection.openChannel(String serviceType,
OptionMap optionMap)
Open a channel to a remote service on this connection.
|
Modifier and Type | Method and Description |
---|---|
void |
OpenListener.channelOpened(Channel channel)
Notification that a new channel has been opened for this service.
|
void |
Channel.Receiver.handleEnd(Channel channel)
Handle an end-of-input condition on a channel.
|
void |
Channel.Receiver.handleError(Channel channel,
IOException error)
Handle an error condition on the channel.
|
void |
Channel.Receiver.handleMessage(Channel channel,
MessageInputStream message)
Handle an incoming message.
|
Modifier and Type | Method and Description |
---|---|
static Runnable |
SpiUtils.getServiceOpenTask(Channel newChannel,
OpenListener listener)
Get an executor task for opening a service.
|
Modifier and Type | Method and Description |
---|---|
Cancellable |
ConnectionHandler.open(String serviceType,
Result<Channel> result,
OptionMap optionMap)
Open a request handler.
|
Modifier and Type | Method and Description |
---|---|
ServerMessageInterceptor |
ServerMessageInterceptorFactory.create(Channel channel)
Creates a server message interceptor when a channel is opened
|
Modifier and Type | Method and Description |
---|---|
VersionedConnection |
Versions.getVersionedConnection(byte version,
Channel channel,
JMXServiceURL serviceURL) |
void |
Versions.startServer(byte version,
Channel channel,
MBeanServerManager serverManager,
Executor executor,
ServerMessageInterceptor serverMessageInterceptor) |
Modifier and Type | Method and Description |
---|---|
static VersionedConnection |
VersionOne.getConnection(Channel channel,
Map<String,?> environment) |
static void |
VersionOne.startServer(Channel channel,
WrappedMBeanServerConnection server,
Executor executor,
ServerMessageInterceptor serverMessageInterceptor) |
Modifier and Type | Method and Description |
---|---|
static VersionedConnection |
VersionTwo.getConnection(Channel channel,
Map<String,?> environment,
JMXServiceURL serviceURL) |
void |
ServerCommon.MessageReciever.handleEnd(Channel channel) |
void |
ServerCommon.MessageReciever.handleError(Channel channel,
IOException error) |
void |
ServerCommon.MessageReciever.handleMessage(Channel channel,
MessageInputStream message) |
static void |
VersionTwo.startServer(Channel channel,
MBeanServerManager mbeanServerManager,
Executor executor,
ServerMessageInterceptor serverMessageInterceptor) |
Copyright © 2013 JBoss by Red Hat. All Rights Reserved.