org.objectweb.dream.channel
Class GenericPushChannelOutImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.channel.GenericPushChannelOutImpl
All Implemented Interfaces:
BindingController, LifeCycleController, Loggable, Push

public class GenericPushChannelOutImpl
extends AbstractComponent
implements Push

Generic Push ChannelOut. The push method retreive a socket using the bound SocketManagerinterface. it send the message using the bound MessageCodecinterface. Then if the "wait-ack-opt" client interface is bound, it use it to wait an acknowledgment from the ChannelIn. Finaly the socket is released and the message is deleted.


Field Summary
protected  MessageCodec messageCodecItf
           
protected  MessageManager messageManagerItf
           
protected  SocketManager socketManagerItf
           
static String WAIT_ACK_OPT_ITF_NAME
          The name of the optional client interface used by this coponent to wait for an acknowlegdment
protected  WaitByte waitAckOptItf
           
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, componentDesc, fcState, firstStart, 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
GenericPushChannelOutImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 String[] listFc()
           
 void push(Message message, Map context)
           
 void unbindFc(String clientItfName)
           
 
Methods inherited from class org.objectweb.dream.AbstractComponent
beforeFirstStart, getFcState, initComponent, lookupFc, setLogger, startFc, stopFc
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

WAIT_ACK_OPT_ITF_NAME

public static final String WAIT_ACK_OPT_ITF_NAME
The name of the optional client interface used by this coponent to wait for an acknowlegdment

See Also:
Constant Field Values

messageManagerItf

protected MessageManager messageManagerItf

messageCodecItf

protected MessageCodec messageCodecItf

socketManagerItf

protected SocketManager socketManagerItf

waitAckOptItf

protected WaitByte waitAckOptItf
Constructor Detail

GenericPushChannelOutImpl

public GenericPushChannelOutImpl()
Method Detail

push

public void push(Message message,
                 Map context)
          throws PushException
Specified by:
push in interface Push
Throws:
PushException
See Also:
Push.push(Message, Map)

listFc

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

bindFc

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

unbindFc

public void unbindFc(String clientItfName)
              throws NoSuchInterfaceException,
                     IllegalBindingException,
                     IllegalLifeCycleException
Specified by:
unbindFc in interface BindingController
Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
See Also:
BindingController.unbindFc(String)


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