org.jboss.remoting3.remote

Class InboundMessage

java.lang.Object

org.jboss.remoting3.remote.InboundMessage

final class InboundMessage
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
(package private) boolean	cancelled
(package private) RemoteConnectionChannel	channel
(package private) boolean	closeSent
(package private) boolean	eofReceived
(package private) int	inboundWindow
(package private) static IntIndexer<InboundMessage>	INDEXER
(package private) org.xnio.streams.BufferPipeInputStream	inputStream
(package private) short	messageId
(package private) MessageInputStream	messageInputStream
(package private) long	remaining
(package private) boolean	streamClosed

Constructor Summary

Constructors

Constructor and Description
InboundMessage(short messageId, RemoteConnectionChannel channel, int inboundWindow, long maxInboundMessageSize)

Method Summary

Modifier and Type	Method and Description
(package private) org.xnio.Pooled<java.nio.ByteBuffer>	allocate(byte protoId)
private void	doAcknowledge(org.xnio.Pooled<java.nio.ByteBuffer> acked)
private void	doClose()
private void	doSendCloseMessage()
(package private) void	dumpState(java.lang.StringBuilder b)
(package private) void	handleDuplicate()
(package private) void	handleIncoming(org.xnio.Pooled<java.nio.ByteBuffer> pooledBuffer)
(package private) void	terminate()

Methods inherited from class java.lang.Object

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

Field Detail

messageId

final short messageId

channel

final RemoteConnectionChannel channel

inboundWindow

int inboundWindow

streamClosed

boolean streamClosed

closeSent

boolean closeSent

eofReceived

boolean eofReceived

cancelled

boolean cancelled

remaining

long remaining

INDEXER

static final IntIndexer<InboundMessage> INDEXER

inputStream

final org.xnio.streams.BufferPipeInputStream inputStream

messageInputStream

final MessageInputStream messageInputStream

Constructor Detail

InboundMessage

InboundMessage(short messageId,
               RemoteConnectionChannel channel,
               int inboundWindow,
               long maxInboundMessageSize)

Method Detail

terminate

void terminate()

doClose

private void doClose()

doSendCloseMessage

private void doSendCloseMessage()

doAcknowledge

private void doAcknowledge(org.xnio.Pooled<java.nio.ByteBuffer> acked)

allocate

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

handleIncoming

void handleIncoming(org.xnio.Pooled<java.nio.ByteBuffer> pooledBuffer)

handleDuplicate

void handleDuplicate()

dumpState

void dumpState(java.lang.StringBuilder b)