org.objectweb.dream.queue
Class PushIncomingHandlerOverflowImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.queue.AbstractPushIncomingHandlerOverflowImpl
org.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.
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 |
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PushIncomingHandlerOverflowImpl
public PushIncomingHandlerOverflowImpl()
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.