public abstract class AbstractProxyConsumer extends AbstractProxy implements IProxyConsumer, NotifyPublishOperations
JMXManageable.JMXCallback
Modifier and Type | Field and Description |
---|---|
protected SupplierAdmin |
supplierAdmin_ |
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Modifier | Constructor and Description |
---|---|
protected |
AbstractProxyConsumer(IAdmin admin,
ORB orb,
POA poa,
Configuration conf,
TaskProcessor taskProcessor,
MessageFactory messageFactory,
SupplierAdmin supplierAdmin,
OfferManager offerManager,
SubscriptionManager subscriptionManager) |
Modifier and Type | Method and Description |
---|---|
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()
get the associated MessageConsumer or null.
|
int |
getMessageCount() |
protected MessageFactory |
getMessageFactory() |
boolean |
getStartTimeSupported() |
boolean |
getStopTimeSupported() |
List |
getSubsequentFilterStages() |
boolean |
hasMessageConsumer()
check if this FilterStage has a MessageConsumer associcated.
|
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.
|
protected void |
schedulePullTask(MessageSupplier target) |
void |
setSubsequentDestinations(List list) |
activate, add_filter, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, connectionResumed, connectionSuspended, deactivate, destroy, disconnectClient, dispose, get_all_filters, get_filter, get_qos, getClientIOR, getConnected, getErrorCounter, getFilters, getID, getInterFilterGroupOperator, getJMXNotificationTypes, getJMXObjectName, getLifetimeFilter, getMBeanName, getMBeanType, getORB, getPOA, getPriorityFilter, getStatus, getTaskProcessor, handleDisconnected, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, incErrorCounter, isDestroyed, isIDPublic, isSuspended, lifetime_filter, lifetime_filter, MyType, priority_filter, priority_filter, registerDisposable, remove_all_filters, remove_filter, resetErrorCounter, resume_connection, sendNotification, sendNotification, set_qos, setJMXCallback, suspend_connection, validate_event_qos, validate_qos
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
newServant
protected final SupplierAdmin supplierAdmin_
protected AbstractProxyConsumer(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, SupplierAdmin supplierAdmin, OfferManager offerManager, SubscriptionManager subscriptionManager)
protected MessageFactory getMessageFactory()
public final List getSubsequentFilterStages()
getSubsequentFilterStages
in interface FilterStageSource
public void setSubsequentDestinations(List list)
protected void schedulePullTask(MessageSupplier target)
protected void checkMessageProperties(Message m)
public FilterStage getFirstStage()
getFirstStage
in interface IProxyConsumer
public boolean getStopTimeSupported()
getStopTimeSupported
in interface IProxyConsumer
public boolean getStartTimeSupported()
getStartTimeSupported
in interface IProxyConsumer
public final SupplierAdmin MyAdmin()
public final MessageConsumer getMessageConsumer()
FilterStage
getMessageConsumer
in interface FilterStage
public final boolean hasMessageConsumer()
FilterStage
hasMessageConsumer
in interface FilterStage
public void offer_change(EventType[] added, EventType[] removed) throws InvalidEventType
offer_change
in interface NotifyPublishOperations
InvalidEventType
public final EventType[] obtain_subscription_types(ObtainInfoMode obtainInfoMode)
protected void removeListener()
removeListener
in class AbstractProxy
protected final void clientDisconnected()
clientDisconnected
in class AbstractProxy
protected void connectClient(Object client)
connectClient
in class AbstractProxy
protected void processMessage(Message mesg)
public final int getMessageCount()
protected Message[] newMessages(StructuredEvent[] events)
Copyright © 2017 JacORB. All rights reserved.