org.objectweb.dream.queue
Class PushOutgoingHandlerActiveImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.queue.PushOutgoingHandlerActiveImpl
All Implemented Interfaces:
BindingController, LifeCycleController, Loggable

public class PushOutgoingHandlerActiveImpl
extends AbstractComponent

Basic implementation of a Pull outgoing handler.


Field Summary
protected  Buffer bufferItf
           
protected  BufferRemoveFirstLast bufferRemoveFirstLastItf
           
protected  MessageManager messageManagerItf
           
protected  Push outPushItf
           
protected  Task queueTask
           
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, componentDesc, fcState, firstStart, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
PushOutgoingHandlerActiveImpl()
           
 
Method Summary
protected  void beforeFirstStart(Component componentItf)
           
 void bindFc(String clientItfName, Object serverItf)
           
protected  void handlePushException(Message message, PushException exception)
          Handles a PushExceptionoccuring when the activity try to push a message.
 String[] listFc()
           
 
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
 

Field Detail

messageManagerItf

protected MessageManager messageManagerItf

outPushItf

protected Push outPushItf

bufferItf

protected Buffer bufferItf

bufferRemoveFirstLastItf

protected BufferRemoveFirstLast bufferRemoveFirstLastItf

queueTask

protected Task queueTask
Constructor Detail

PushOutgoingHandlerActiveImpl

public PushOutgoingHandlerActiveImpl()
Method Detail

beforeFirstStart

protected void beforeFirstStart(Component componentItf)
                         throws IllegalLifeCycleException
Throws:
IllegalLifeCycleException
See Also:
AbstractComponent.beforeFirstStart(org.objectweb.fractal.api.Component)

handlePushException

protected void handlePushException(Message message,
                                   PushException exception)
Handles a PushExceptionoccuring when the activity try to push a message. This implementation simlpy delete message using message manger.

Parameters:
message - the pushed message
exception - the exceptino thrown during the push call.

bindFc

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

listFc

public String[] listFc()
See Also:
BindingController.listFc()


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