org.objectweb.dream.message.codec
Class MessageCodecOptimizedStreamImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.message.codec.AbstractMessageCodecDataStream
          extended byorg.objectweb.dream.message.codec.AbstractMessageCodecObjectStream
              extended byorg.objectweb.dream.message.codec.MessageCodecOptimizedStreamImpl
All Implemented Interfaces:
AttributeController, BindingController, LifeCycleController, Loggable, MessageCodec, MessageCodecObjectStreamAttributeController

public class MessageCodecOptimizedStreamImpl
extends AbstractMessageCodecObjectStream

Optimized implementation of message codec for extensible message.
Requirements :


Field Summary
static String CHUNK_TYPE_POOL_ITF_NAME
          The name of the ChunkTypepool client interface name
protected  ObjectPool chunkTypePoolItf
           
 
Fields inherited from class org.objectweb.dream.message.codec.AbstractMessageCodecDataStream
messageManagerItf
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, componentDesc, fcState, firstStart, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.dream.message.codec.MessageCodec
ITF_NAME
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
MessageCodecOptimizedStreamImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
protected  Message doDecodeSingleMessage(DataInput input)
          Abstract method used by AbstractMessageCodecDataStream.doDecode(DataInput)to decode a single message.
protected  void doEncodeSingleMessage(Message message, DataOutput output)
          Abstract method used by AbstractMessageCodecDataStream.doEncode(Message, DataOutput)to encode a single message.
 String[] listFc()
           
 
Methods inherited from class org.objectweb.dream.message.codec.AbstractMessageCodecObjectStream
decode, encode, getReuseObjectStream, setReuseObjectStream
 
Methods inherited from class org.objectweb.dream.message.codec.AbstractMessageCodecDataStream
doDecode, doEncode
 
Methods inherited from class org.objectweb.dream.AbstractComponent
beforeFirstStart, getFcState, initComponent, lookupFc, setLogger, startFc, stopFc, unbindFc
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

CHUNK_TYPE_POOL_ITF_NAME

public static final String CHUNK_TYPE_POOL_ITF_NAME
The name of the ChunkTypepool client interface name

See Also:
Constant Field Values

chunkTypePoolItf

protected ObjectPool chunkTypePoolItf
Constructor Detail

MessageCodecOptimizedStreamImpl

public MessageCodecOptimizedStreamImpl()
Method Detail

doDecodeSingleMessage

protected Message doDecodeSingleMessage(DataInput input)
                                 throws IOException
Description copied from class: AbstractMessageCodecDataStream
Abstract method used by AbstractMessageCodecDataStream.doDecode(DataInput)to decode a single message. This method decode only chunks of message.

Specified by:
doDecodeSingleMessage in class AbstractMessageCodecDataStream
Parameters:
input - the input from which message is decoded.
Returns:
a message.
Throws:
IOException - if an error occurs.
See Also:
AbstractMessageCodecDataStream.doDecodeSingleMessage(DataInput)

doEncodeSingleMessage

protected void doEncodeSingleMessage(Message message,
                                     DataOutput output)
                              throws IOException
Description copied from class: AbstractMessageCodecDataStream
Abstract method used by AbstractMessageCodecDataStream.doEncode(Message, DataOutput)to encode a single message. This method encode only chunks of message.

Specified by:
doEncodeSingleMessage in class AbstractMessageCodecDataStream
Parameters:
message - a message to encode.
output - the output to use to encode the message.
Throws:
IOException - if an error occurs.
See Also:
AbstractMessageCodecDataStream.doEncodeSingleMessage(Message, DataOutput)

listFc

public String[] listFc()
Specified by:
listFc in interface BindingController
Overrides:
listFc in class AbstractMessageCodecDataStream
See Also:
BindingController.listFc()

bindFc

public void bindFc(String clientItfName,
                   Object serverItf)
            throws NoSuchInterfaceException,
                   IllegalBindingException,
                   IllegalLifeCycleException
Specified by:
bindFc in interface BindingController
Overrides:
bindFc in class AbstractMessageCodecDataStream
Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
See Also:
BindingController.bindFc(String, Object)


Copyright © 2003, 2004 - INRIA Rhone-Alpes - All Rights Reserved.