org.jboss.remoting3.remote

Class RemoteConnection

java.lang.Object

org.jboss.remoting3.remote.RemoteConnection

final class RemoteConnection
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	RemoteConnection.RemoteWriteListener

Field Summary

Fields

Modifier and Type	Field and Description
private org.xnio.channels.ConnectedMessageChannel	channel
private java.util.concurrent.Executor	executor
private static java.lang.String	FQCN
private java.lang.Runnable	heartbeatCommand
private int	heartbeatInterval
private org.xnio.Pool<java.nio.ByteBuffer>	messageBufferPool
private org.xnio.OptionMap	optionMap
private RemoteConnectionProvider	remoteConnectionProvider
private org.xnio.Result<ConnectionHandlerFactory>	result
private org.xnio.sasl.SaslWrapper	saslWrapper
(package private) static org.xnio.Pooled<java.nio.ByteBuffer>	STARTTLS_SENTINEL
private org.xnio.channels.ConnectedStreamChannel	underlyingChannel
private RemoteConnection.RemoteWriteListener	writeListener

Constructor Summary

Constructors

Constructor and Description
RemoteConnection(org.xnio.Pool<java.nio.ByteBuffer> messageBufferPool, org.xnio.channels.ConnectedStreamChannel underlyingChannel, org.xnio.channels.ConnectedMessageChannel channel, org.xnio.OptionMap optionMap, RemoteConnectionProvider remoteConnectionProvider)

Method Summary

Modifier and Type	Method and Description
(package private) org.xnio.Pooled<java.nio.ByteBuffer>	allocate()
(package private) org.xnio.channels.ConnectedMessageChannel	getChannel()
java.util.concurrent.Executor	getExecutor()
(package private) java.lang.Object	getLock()
(package private) org.xnio.OptionMap	getOptionMap()
(package private) RemoteConnectionProvider	getRemoteConnectionProvider()
(package private) org.xnio.Result<ConnectionHandlerFactory>	getResult()
(package private) org.xnio.sasl.SaslWrapper	getSaslWrapper()
org.xnio.channels.SslChannel	getSslChannel()
(package private) org.xnio.ChannelListener<org.xnio.channels.ConnectedMessageChannel>	getWriteListener()
(package private) void	handleException(java.io.IOException e)
(package private) void	handleException(java.io.IOException e, boolean log)
(package private) void	handlePreAuthCloseRequest()
(package private) void	send(org.xnio.Pooled<java.nio.ByteBuffer> pooled)
(package private) void	send(org.xnio.Pooled<java.nio.ByteBuffer> pooled, boolean close)
(package private) void	sendAlive()
(package private) void	sendAliveResponse()
(package private) void	setReadListener(org.xnio.ChannelListener<? super org.xnio.channels.ConnectedMessageChannel> listener, boolean resume)
(package private) void	setResult(org.xnio.Result<ConnectionHandlerFactory> result)
(package private) void	setSaslWrapper(org.xnio.sasl.SaslWrapper saslWrapper)
(package private) void	shutdownWrites()
(package private) void	terminateHeartbeat()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

STARTTLS_SENTINEL

static final org.xnio.Pooled<java.nio.ByteBuffer> STARTTLS_SENTINEL

FQCN

private static final java.lang.String FQCN

messageBufferPool

private final org.xnio.Pool<java.nio.ByteBuffer> messageBufferPool

channel

private final org.xnio.channels.ConnectedMessageChannel channel

underlyingChannel

private final org.xnio.channels.ConnectedStreamChannel underlyingChannel

optionMap

private final org.xnio.OptionMap optionMap

writeListener

private final RemoteConnection.RemoteWriteListener writeListener

executor

private final java.util.concurrent.Executor executor

heartbeatInterval

private final int heartbeatInterval

result

private volatile org.xnio.Result<ConnectionHandlerFactory> result

saslWrapper

private volatile org.xnio.sasl.SaslWrapper saslWrapper

remoteConnectionProvider

private final RemoteConnectionProvider remoteConnectionProvider

heartbeatCommand

private final java.lang.Runnable heartbeatCommand

Constructor Detail

RemoteConnection

RemoteConnection(org.xnio.Pool<java.nio.ByteBuffer> messageBufferPool,
                 org.xnio.channels.ConnectedStreamChannel underlyingChannel,
                 org.xnio.channels.ConnectedMessageChannel channel,
                 org.xnio.OptionMap optionMap,
                 RemoteConnectionProvider remoteConnectionProvider)

Method Detail

allocate

org.xnio.Pooled<java.nio.ByteBuffer> allocate()

setReadListener

void setReadListener(org.xnio.ChannelListener<? super org.xnio.channels.ConnectedMessageChannel> listener,
                     boolean resume)

getRemoteConnectionProvider

RemoteConnectionProvider getRemoteConnectionProvider()

getResult

org.xnio.Result<ConnectionHandlerFactory> getResult()

setResult

void setResult(org.xnio.Result<ConnectionHandlerFactory> result)

handleException

void handleException(java.io.IOException e)

handleException

void handleException(java.io.IOException e,
                     boolean log)

send

void send(org.xnio.Pooled<java.nio.ByteBuffer> pooled)

send

void send(org.xnio.Pooled<java.nio.ByteBuffer> pooled,
          boolean close)

shutdownWrites

void shutdownWrites()

getOptionMap

org.xnio.OptionMap getOptionMap()

getChannel

org.xnio.channels.ConnectedMessageChannel getChannel()

getWriteListener

org.xnio.ChannelListener<org.xnio.channels.ConnectedMessageChannel> getWriteListener()

getExecutor

public java.util.concurrent.Executor getExecutor()

getSslChannel

public org.xnio.channels.SslChannel getSslChannel()

getSaslWrapper

org.xnio.sasl.SaslWrapper getSaslWrapper()

setSaslWrapper

void setSaslWrapper(org.xnio.sasl.SaslWrapper saslWrapper)

handlePreAuthCloseRequest

void handlePreAuthCloseRequest()

sendAlive

void sendAlive()

sendAliveResponse

void sendAliveResponse()

terminateHeartbeat

void terminateHeartbeat()

getLock

java.lang.Object getLock()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object