org.jboss.remoting3.remote

Class OutboundMessage

java.lang.Object

java.io.OutputStream

org.jboss.remoting3.MessageOutputStream

org.jboss.remoting3.remote.OutboundMessage

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable, org.xnio.Cancellable

final class OutboundMessage
extends MessageOutputStream

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.xnio.streams.BufferPipeOutputStream.BufferWriter	bufferWriter
(package private) boolean	cancelled
(package private) boolean	cancelSent
(package private) RemoteConnectionChannel	channel
(package private) boolean	closeCalled
(package private) boolean	closeReceived
(package private) boolean	eofSent
(package private) static IntIndexer<OutboundMessage>	INDEXER
(package private) int	maximumWindow
(package private) short	messageId
(package private) org.xnio.streams.BufferPipeOutputStream	pipeOutputStream
(package private) boolean	released
(package private) long	remaining
(package private) int	window

Constructor Summary

Constructors

Constructor and Description
OutboundMessage(short messageId, RemoteConnectionChannel channel, int window, long maxOutboundMessageSize)

Method Summary

Modifier and Type	Method and Description
(package private) void	acknowledge(int count)
(package private) org.xnio.Pooled<java.nio.ByteBuffer>	allocate(byte protoId)
MessageOutputStream	cancel() Cancel this message stream.
void	close() Close this message stream.
(package private) void	dumpState(java.lang.StringBuilder b)
void	flush() Flush this message stream.
private java.io.IOException	overrun()
(package private) void	remoteClosed()
java.lang.String	toString()
void	write(byte[] b)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.lang.Object

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

Field Detail

messageId

final short messageId

channel

final RemoteConnectionChannel channel

pipeOutputStream

final org.xnio.streams.BufferPipeOutputStream pipeOutputStream

maximumWindow

final int maximumWindow

window

int window

closeCalled

boolean closeCalled

closeReceived

boolean closeReceived

cancelled

boolean cancelled

cancelSent

boolean cancelSent

eofSent

boolean eofSent

released

boolean released

remaining

long remaining

bufferWriter

final org.xnio.streams.BufferPipeOutputStream.BufferWriter bufferWriter

INDEXER

static final IntIndexer<OutboundMessage> INDEXER

Constructor Detail

OutboundMessage

OutboundMessage(short messageId,
                RemoteConnectionChannel channel,
                int window,
                long maxOutboundMessageSize)

Method Detail

allocate

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

acknowledge

void acknowledge(int count)

remoteClosed

void remoteClosed()

write

public void write(int b)
           throws java.io.IOException

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

overrun

private java.io.IOException overrun()

write

public void write(byte[] b)
           throws java.io.IOException

Overrides:

write in class java.io.OutputStream

Throws:

java.io.IOException

write

public void write(byte[] b,
                  int off,
                  int len)
           throws java.io.IOException

Overrides:

write in class java.io.OutputStream

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException

Description copied from class: MessageOutputStream

Flush this message stream. Any unwritten, buffered bytes are sent to the remote side.

Specified by:

flush in interface java.io.Flushable

Specified by:

flush in class MessageOutputStream

Throws:

java.io.IOException - if an error occurs while flushing the stream

close

public void close()
           throws java.io.IOException

Description copied from class: MessageOutputStream

Close this message stream. If the stream is already closed or cancelled, this method has no effect. After this method is called, any further attempts to write to the stream will result in an exception.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in class MessageOutputStream

Throws:

java.io.IOException - if a error occurs while closing the stream

cancel

public MessageOutputStream cancel()

Description copied from class: MessageOutputStream

Cancel this message stream. If the stream is already closed or cancelled, this method has no effect. After this method is called, any further attempts to write to the stream will result in an exception.

Specified by:

cancel in interface org.xnio.Cancellable

Specified by:

cancel in class MessageOutputStream

Returns:

this stream

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

dumpState

void dumpState(java.lang.StringBuilder b)