| java.lang.Object
 org.jacorb.notification.servant.AbstractProxy
org.jacorb.notification.servant.AbstractProxySupplier
All known Subclasses: org.jacorb.notification.servant.SequenceProxyPullSupplierImpl, org.jacorb.notification.servant.ProxyPullSupplierImpl, org.jacorb.notification.servant.AbstractProxyPushSupplier, org.jacorb.notification.servant.StructuredProxyPullSupplierImpl, org.jacorb.notification.servant.TypedProxyPullSupplierImpl,
| AbstractProxySupplier | | abstract public class AbstractProxySupplier extends AbstractProxy implements MessageConsumer,NotifySubscribeOperations,AbstractProxySupplierMBean(Code) | | Abstract base class for ProxySuppliers. This class provides base functionality
for the different ProxySuppliers:
- queue management,
- error threshold settings.
author:
Alphonse Bendt
version:
$Id: AbstractProxySupplier.java,v 1.31 2006/05/23 10:50:35 alphonse.bendt Exp $ |
| MyAdmin | | final public ConsumerAdmin MyAdmin()(Code) | | |
| clearPendingMessageQueue | | public void clearPendingMessageQueue()(Code) | | |
| clientDisconnected | | final protected void clientDisconnected()(Code) | | |
| dispose | | final public void dispose()(Code) | | |
| enqueue | | protected void enqueue(Message message)(Code) | | put a copy of the Message in the queue of pending Messages.
Parameters:
message - the Message to queue. |
| getAtLeastMessages | | protected Message[] getAtLeastMessages(int min)(Code) | |
Parameters:
min - minimum number of messages an array containing the requested number of Messages or null |
| getCost | | abstract protected long getCost()(Code) | | |
| getDiscardPolicy | | final public String getDiscardPolicy()(Code) | | |
| getErrorThreshold | | public int getErrorThreshold()(Code) | | |
| getMaxEventsPerConsumer | | final public int getMaxEventsPerConsumer()(Code) | | |
| getNumberOfDiscardedMessages | | public int getNumberOfDiscardedMessages()(Code) | | |
| getOfferListener | | final NotifyPublishOperations getOfferListener()(Code) | | |
| getPendingMessagesCount | | public int getPendingMessagesCount()(Code) | | |
| getSubsequentFilterStages | | final public List getSubsequentFilterStages()(Code) | | |
| getUpToMessages | | protected Message[] getUpToMessages(int max)(Code) | |
Parameters:
max - maximum number of messages an array containing at most max Messages |
| hasMessageConsumer | | final public boolean hasMessageConsumer()(Code) | | |
| hasPendingData | | public boolean hasPendingData()(Code) | | |
| isRetryAllowed | | public boolean isRetryAllowed()(Code) | | |
| messageQueued | | protected void messageQueued()(Code) | | this is an extension point.
|
| obtain_offered_types | | final public EventType[] obtain_offered_types(ObtainInfoMode obtainInfoMode)(Code) | | |
| removeListener | | protected void removeListener()(Code) | | |
| setMaxEventsPerConsumer | | public void setMaxEventsPerConsumer(int max)(Code) | | |
| subscription_change | | final public void subscription_change(EventType[] added, EventType[] removed) throws InvalidEventType(Code) | | |
|
|