org.objectweb.dream.queue
Class PushIncomingHandlerOverflowImpl

java.lang.Object
  extended byorg.objectweb.dream.AbstractComponent
      extended byorg.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
          extended byorg.objectweb.dream.queue.PushIncomingHandlerOverflowImpl
All Implemented Interfaces:
AttributeController, BindingController, LifeCycleController, Loggable, Push, PushQueueAttributeController

public class PushIncomingHandlerOverflowImpl
extends AbstractPushIncomingHandlerOverflowImpl

Basic implementation of a Push incoming handler.


Field Summary
 
Fields inherited from class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
BLOCK_OVERFLOW_POLICY_ID, bufferAddFirstLastItf, bufferItf, bufferRemoveFirstLastItf, DROP_FIRST_OVERFLOW_POLICY_ID, DROP_LAST_OVERFLOW_POLICY_ID, DROP_PROCESSED_MESSAGE_OVERFLOW_POLICY_ID, DROP_QUEUE_MESSAGE_OVERFLOW_POLICY_ID, EXCEPTION_OVERFLOW_POLICY_ID, messageManagerItf, overflowPolicy, overflowPolicyId
 
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.dream.queue.PushQueueAttributeController
BLOCK_OVERFLOW_POLICY, DROP_FIRST_OVERFLOW_POLICY, DROP_LAST_OVERFLOW_POLICY, DROP_PROCESSED_MESSAGE_OVERFLOW_POLICY, DROP_QUEUE_MESSAGE_OVERFLOW_POLICY, EXCEPTION_OVERFLOW_POLICY
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
PushIncomingHandlerOverflowImpl()
           
 
Method Summary
protected  boolean canAdd(Message message)
          Checks whether the given message can be added into the buffer.
protected  void doAdd(Message message)
          Adds a message to the buffer.
 
Methods inherited from class org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
bindFc, getOverflowPolicy, listFc, push, setOverflowPolicy
 
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
 

Constructor Detail

PushIncomingHandlerOverflowImpl

public PushIncomingHandlerOverflowImpl()
Method Detail

canAdd

protected boolean canAdd(Message message)
Description copied from class: AbstractPushIncomingHandlerOverflowImpl
Checks whether the given message can be added into the buffer.

Specified by:
canAdd in class AbstractPushIncomingHandlerOverflowImpl
Parameters:
message - the message to be tested.
Returns:
true if the message can be added.
See Also:
AbstractPushIncomingHandlerOverflowImpl.canAdd(org.objectweb.dream.message.Message)

doAdd

protected void doAdd(Message message)
              throws InterruptedException
Description copied from class: AbstractPushIncomingHandlerOverflowImpl
Adds a message to the buffer. This method should not check if there is enough available space provided it has already been done.

Specified by:
doAdd in class AbstractPushIncomingHandlerOverflowImpl
Parameters:
message - the message to be added.
Throws:
InterruptedException - if it is interrupted while removing the message.
See Also:
AbstractPushIncomingHandlerOverflowImpl.doAdd(org.objectweb.dream.message.Message)


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