org.jredis.ri.alphazero.protocol

Class ProtocolBase.StreamBufferRequest

java.lang.Object

org.jredis.ri.alphazero.protocol.ProtocolBase.StreamBufferRequest

All Implemented Interfaces:

Message, Request

Enclosing class:

ProtocolBase

public static class ProtocolBase.StreamBufferRequest
extends java.lang.Object
implements Request

SimpleRequest implements the required Message.read(InputStream) using a (likely) shared data buffer. It is not thread safe and can only be used by connections that serialized request processing through a single requesting thread.

Specifically, if an instance of this class is obtained and not immediately used (by calling read) before the user has obtained another instance of the same, data corruption is guaranteed.

Since:

alpha.0

Version:

alpha.0, 04/02/09

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.io.ByteArrayOutputStream	buffer

Constructor Summary

Constructors

Constructor and Description
StreamBufferRequest(java.io.ByteArrayOutputStream buffer)

Method Summary

Modifier and Type	Method and Description
void	read(java.io.InputStream in) Reads itself from the provided InputStream
void	reset(java.io.ByteArrayOutputStream buffer)
void	write(java.io.OutputStream out) Writes the entire content of the message to the output stream and flushes it.

Methods inherited from class java.lang.Object

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

Field Detail

buffer

java.io.ByteArrayOutputStream buffer

Constructor Detail

StreamBufferRequest

public StreamBufferRequest(java.io.ByteArrayOutputStream buffer)

Parameters:

buffer -

Method Detail

reset

public void reset(java.io.ByteArrayOutputStream buffer)

read

public void read(java.io.InputStream in)
          throws ClientRuntimeException,
                 ProviderException

Description copied from interface: Message

Reads itself from the provided InputStream

Specified by:

read in interface Message

Parameters:

in - the steam to read from.

Throws:

ClientRuntimeException - to indicate a system error, potentially network related and hopefully recoverable. Typically used to wrap and propagate the IO stream's thrown IOExceptions.

ProviderException - to indicate operational error not directly related to the stream, and should be treated as a bug.

write

public void write(java.io.OutputStream out)
           throws ClientRuntimeException,
                  ProviderException

Writes the entire content of the message to the output stream and flushes it.

Specified by:

write in interface Message

Parameters:

out - the stream to write the Request message to.

Throws:

ClientRuntimeException - to indicate a system error, potentially network related and hopefully recoverable. Typically used to wrap and propagate the IO stream's thrown IOExceptions.

ProviderException - to indicate operational error not directly related to the stream, and should be treated as a bug.