Package | Description |
---|---|
org.jboss.as.controller.client.impl |
Implementation classes to support the
core JBoss AS management client API . |
org.jboss.ejb._private | |
org.jboss.remoting3 |
The base Remoting 3 API package.
|
org.jboss.remoting3.spi |
Service provider classes and interfaces.
|
org.jboss.remoting3.util | |
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 an existing channel.
|
Modifier and Type | Method and Description |
---|---|
void |
Logs.channelCanNoLongerProcessMessages(Channel channel) |
void |
Logs_$logger.channelCanNoLongerProcessMessages(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.
|
Constructor and Description |
---|
ClientServiceHandle(String serviceName,
Function<Channel,IoFuture<T>> constructor)
Construct a new instance.
|
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.
|
Constructor and Description |
---|
InvocationTracker(Channel channel)
Construct a new instance, using the maximum number of messages from the channel.
|
InvocationTracker(Channel channel,
int maxMessages)
Construct a new instance.
|
InvocationTracker(Channel channel,
int maxMessages,
IntUnaryOperator intMasker)
Construct a new instance.
|
InvocationTracker(Channel channel,
IntUnaryOperator intMasker)
Construct a new instance, using the maximum number of messages from the channel.
|
InvocationTracker(Channel channel,
MessageTracker messageTracker,
IntUnaryOperator intMasker)
Construct a new instance.
|
MessageTracker(Channel channel,
int limit) |
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 © 2020 JBoss by Red Hat. All rights reserved.