org.jacorb.notification.queue

Class RWLockEventQueueDecorator

public class RWLockEventQueueDecorator extends Object implements MessageQueueAdapter

Version: $Id: RWLockEventQueueDecorator.java,v 1.8 2006/03/03 19:54:48 alphonse.bendt Exp $

Author: Alphonse Bendt

Constructor Summary
RWLockEventQueueDecorator(MessageQueueAdapter initialDelegate)
Method Summary
voidaddDiscardListener(MessageQueue.DiscardListener listener)
voidclear()
voidenqeue(Message message)
Message[]getAllMessages()
Message[]getAtLeastMessages(int min)
StringgetDiscardPolicyName()
MessagegetMessageBlocking()
MessagegetMessageNoBlock()
StringgetOrderPolicyName()
intgetPendingMessagesCount()
Message[]getUpToMessages(int max)
booleanhasPendingMessages()
voidremoveDiscardListener(MessageQueue.DiscardListener listener)
voidreplaceDelegate(MessageQueueAdapter newDelegate)
StringtoString()

Constructor Detail

RWLockEventQueueDecorator

public RWLockEventQueueDecorator(MessageQueueAdapter initialDelegate)

Method Detail

addDiscardListener

public void addDiscardListener(MessageQueue.DiscardListener listener)

clear

public void clear()

enqeue

public void enqeue(Message message)

getAllMessages

public Message[] getAllMessages()

getAtLeastMessages

public Message[] getAtLeastMessages(int min)

getDiscardPolicyName

public String getDiscardPolicyName()

getMessageBlocking

public Message getMessageBlocking()

getMessageNoBlock

public Message getMessageNoBlock()

getOrderPolicyName

public String getOrderPolicyName()

getPendingMessagesCount

public int getPendingMessagesCount()

getUpToMessages

public Message[] getUpToMessages(int max)

hasPendingMessages

public boolean hasPendingMessages()

removeDiscardListener

public void removeDiscardListener(MessageQueue.DiscardListener listener)

replaceDelegate

public void replaceDelegate(MessageQueueAdapter newDelegate)

toString

public String toString()