org.objectweb.dream.queue
Interface PushQueueAttributeController

All Superinterfaces:
AttributeController, QueueAttributeController
All Known Subinterfaces:
PushPullQueueAttributeController
All Known Implementing Classes:
AbstractPushQueueImpl, BasicPushPullQueueImpl, NotSynchronizedPushPullQueueImpl

public interface PushQueueAttributeController
extends QueueAttributeController

Attribute controller for queue implementation with a push input. It defines an overflow policy attribute with three default values (specific implementations can define other).


Field Summary
static String BLOCK_OVERFLOW_POLICY
          An overflow policy that block incomming messages until a message is delivered on the output.
static String DROP_OVERFLOW_POLICY
          An overflow policy that drops the new message and does not modify the queue.
static String EXCEPTION_OVERFLOW_POLICY
          An overflow policy that cause the Push server interface to throw a BufferOverflowException
 
Method Summary
 String getOverflowPolicy()
          Returns the overflow policy.
 void setOverflowPolicy(String policy)
          Sets the overflow policy.
 
Methods inherited from interface org.objectweb.dream.queue.QueueAttributeController
getCurrentSize, getMaxCapacity, setMaxCapacity
 

Field Detail

BLOCK_OVERFLOW_POLICY

public static final String BLOCK_OVERFLOW_POLICY
An overflow policy that block incomming messages until a message is delivered on the output.
Warning when using this overflow policy a InterruptedPushExceptionmay be thrown.

See Also:
Constant Field Values

DROP_OVERFLOW_POLICY

public static final String DROP_OVERFLOW_POLICY
An overflow policy that drops the new message and does not modify the queue.

See Also:
Constant Field Values

EXCEPTION_OVERFLOW_POLICY

public static final String EXCEPTION_OVERFLOW_POLICY
An overflow policy that cause the Push server interface to throw a BufferOverflowException

See Also:
Constant Field Values
Method Detail

getOverflowPolicy

public String getOverflowPolicy()
Returns the overflow policy.

Returns:
the overflow policy.

setOverflowPolicy

public void setOverflowPolicy(String policy)
Sets the overflow policy.

Parameters:
policy - the overflow policy.
Throws:
IllegalArgumentException - if the given string is not reconized as a valid policy.


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