org.objectweb.dream.queue
Class IncomingHandlerRemovingImpl

java.lang.Object
  extended by org.objectweb.dream.AbstractComponent
      extended by org.objectweb.dream.queue.IncomingHandlerRemovingImpl
All Implemented Interfaces:
ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, Push, BindingController, LifeCycleController

public class IncomingHandlerRemovingImpl
extends AbstractComponent
implements Push

An incoming handler that adds pushed messages into a buffer bound to it. For each pushed message, this component uses BufferAdd.tryAdd(Message) non blocking calls for trying to add the pushed message into the buffer:


Field Summary
protected  BufferAdd bufferAdd
          The buffer into which pushed messages are added.
protected  BufferRemove bufferRemove
          The buffer from which message may be removed.
protected static String[] CLIENT_INTERFACE_NAMES
          The names of client interfaces.
protected  MessageManager messageManager
          Used to delete dropped messages.
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, fcNeedAsyncStart, fcState, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.dream.Push
IN_PUSH_ITF_NAME, INCOMING_IN_PUSH_ITF_NAME, INCOMING_OUT_PUSH_ITF_NAME, OUT_PUSH_ITF_NAME, OUTGOING_IN_PUSH_ITF_NAME, OUTGOING_OUT_PUSH_ITF_NAME
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
IncomingHandlerRemovingImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 String[] listFc()
           
 void push(Message message)
           
 
Methods inherited from class org.objectweb.dream.AbstractComponent
beforeFirstStart, bindFc, getFcNeedAsyncStart, getFcState, initComponent, lookupFc, prepareStopFc, setLogger, startFc, stopFc, unbindFc
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

CLIENT_INTERFACE_NAMES

protected static final String[] CLIENT_INTERFACE_NAMES
The names of client interfaces.


messageManager

protected MessageManager messageManager
Used to delete dropped messages.


bufferAdd

protected BufferAdd bufferAdd
The buffer into which pushed messages are added.


bufferRemove

protected BufferRemove bufferRemove
The buffer from which message may be removed.

Constructor Detail

IncomingHandlerRemovingImpl

public IncomingHandlerRemovingImpl()
Method Detail

push

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

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
Overrides:
bindFc in class AbstractComponent
Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
See Also:
BindingController.bindFc(String, Object)


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