org.jacorb.notification.servant
public abstract class AbstractProxyConsumer extends AbstractProxy implements IProxyConsumer, NotifyPublishOperations, AbstractProxyConsumerMBean
Version: $Id: AbstractProxyConsumer.java,v 1.21 2006/07/07 12:38:44 alphonse.bendt Exp $
UNKNOWN: extends = "AbstractProxyMBean"
Field Summary | |
---|---|
protected SupplierAdmin | supplierAdmin_ |
Constructor Summary | |
---|---|
protected | AbstractProxyConsumer(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, SupplierAdmin supplierAdmin, OfferManager offerManager, SubscriptionManager subscriptionManager) |
Method Summary | |
---|---|
protected void | checkMessageProperties(Message m)
check if a Message is acceptable to the QoS Settings of this ProxyConsumer |
protected void | clientDisconnected() |
protected void | connectClient(Object client) |
FilterStage | getFirstStage() |
MessageConsumer | getMessageConsumer() |
int | getMessageCount() |
protected MessageFactory | getMessageFactory() |
boolean | getStartTimeSupported() |
boolean | getStopTimeSupported() |
List | getSubsequentFilterStages() |
boolean | hasMessageConsumer() |
SupplierAdmin | MyAdmin() |
protected Message[] | newMessages(StructuredEvent[] events) |
EventType[] | obtain_subscription_types(ObtainInfoMode obtainInfoMode) |
void | offer_change(EventType[] added, EventType[] removed) |
protected void | processMessage(Message mesg) |
protected void | removeListener()
removes the listener. subscription_change will no more be issued to the connected Supplier |
protected void | schedulePullTask(MessageSupplier target) |
void | setSubsequentDestinations(List list) |
UNKNOWN: description = "Total number of Messages received by this ProxyConsumer" access = "read-only"
UNKNOWN: description = "Does this ProxyConsumer support the per Message Option StartTime" access = "read-only"
UNKNOWN: description = "Does this ProxyConsumer support the per Message Option TimeOut" access = "read-only"