org.objectweb.dream.channel
Class ReliableTCPChannelOutImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.channel.AbstractTCPChannelOutImpl
          extended byorg.objectweb.dream.channel.BasicTCPChannelOutImpl
              extended byorg.objectweb.dream.channel.ReliableTCPChannelOutImpl
All Implemented Interfaces:
AttributeController, BindingController, ChannelOutAttributeController, LifeCycleController, Loggable, MultiDestinationChannelOutAttributeController, Push

public class ReliableTCPChannelOutImpl
extends BasicTCPChannelOutImpl

Reliable implementation of a ChannelOut component, using TCP protocol and InetSocketAddressdestination. The ChannelOut waits for an ACK to arrive after the message has been sent.


Field Summary
 
Fields inherited from class org.objectweb.dream.channel.BasicTCPChannelOutImpl
chunkName
 
Fields inherited from class org.objectweb.dream.channel.AbstractTCPChannelOutImpl
cnxRetry, messageCodecItf, messageManagerItf
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, componentDesc, fcState, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.dream.Push
IN_PUSH_ITF_NAME, OUT_PUSH_ITF_NAME
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
ReliableTCPChannelOutImpl()
           
 
Method Summary
protected  void receiveAck(Socket sock)
          Waits for an ACK to arrive.
 
Methods inherited from class org.objectweb.dream.channel.BasicTCPChannelOutImpl
getDestinationChunkName, push, setDestinationChunkName
 
Methods inherited from class org.objectweb.dream.channel.AbstractTCPChannelOutImpl
bindFc, closeSocket, connectSocket, getConnectionRetry, listFc, setConnectionRetry, setSocketOption
 
Methods inherited from class org.objectweb.dream.AbstractComponent
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
 
Methods inherited from interface org.objectweb.dream.channel.ChannelOutAttributeController
getConnectionRetry, setConnectionRetry
 

Constructor Detail

ReliableTCPChannelOutImpl

public ReliableTCPChannelOutImpl()
Method Detail

receiveAck

protected void receiveAck(Socket sock)
                   throws IOException
Waits for an ACK to arrive.

Overrides:
receiveAck in class BasicTCPChannelOutImpl
Parameters:
sock - the socket to be used to wait for the ack.
Throws:
IOException - if an error occurs.


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