org.jacorb.notification.queue

Class DefaultMessageQueueAdapter

public class DefaultMessageQueueAdapter extends Object implements MessageQueueAdapter

Version: $Id: DefaultMessageQueueAdapter.java,v 1.1 2006/02/25 15:28:40 alphonse.bendt Exp $

Author: Alphonse Bendt

Constructor Summary
DefaultMessageQueueAdapter(MessageQueue queue)
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)
StringtoString()

Constructor Detail

DefaultMessageQueueAdapter

public DefaultMessageQueueAdapter(MessageQueue queue)

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)

toString

public String toString()