public abstract class AbstractProxySupplier extends AbstractProxy implements MessageConsumer, NotifySubscribeOperations
JMXManageable.JMXCallback
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Modifier | Constructor and Description |
---|---|
protected |
AbstractProxySupplier(IAdmin admin,
ORB orb,
POA poa,
Configuration conf,
TaskProcessor taskProcessor,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin) |
activate, add_filter, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, connectionResumed, connectionSuspended, deactivate, destroy, disconnectClient, 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
destroy, isDestroyed
newServant
protected AbstractProxySupplier(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin) throws ConfigurationException
ConfigurationException
protected EventQueueFactory getMessageQueueFactory()
public int getPendingMessagesCount()
public final String getOrderPolicy()
public final String getDiscardPolicy()
public final int getMaxEventsPerConsumer()
public void setMaxEventsPerConsumer(int max)
public int getNumberOfDiscardedMessages()
public boolean hasPendingData()
protected void enqueue(Message message)
message
- the Message
to queue.public Message getMessageBlocking() throws InterruptedException
InterruptedException
protected Message getMessageNoBlock()
protected Message[] getAllMessages()
public void queueMessage(Message message)
MessageConsumer
queueMessage
in interface MessageConsumer
protected void messageQueued()
protected Message[] getUpToMessages(int max)
max
- maximum number of messagesprotected Message[] getAtLeastMessages(int min)
min
- minimum number of messagespublic int getErrorThreshold()
public final void dispose()
dispose
in class AbstractProxy
public final ConsumerAdmin MyAdmin()
public final void subscription_change(EventType[] added, EventType[] removed) throws InvalidEventType
subscription_change
in interface NotifySubscribeOperations
InvalidEventType
public final EventType[] obtain_offered_types(ObtainInfoMode obtainInfoMode)
protected void removeListener()
removeListener
in class AbstractProxy
protected final void clientDisconnected()
clientDisconnected
in class AbstractProxy
public void connectClient(Object client)
connectClient
in class AbstractProxy
public boolean isRetryAllowed()
protected abstract long getCost()
public int compareTo(Object o)
compareTo
in interface Comparable
public final boolean hasMessageConsumer()
FilterStage
hasMessageConsumer
in interface FilterStage
public final List getSubsequentFilterStages()
getSubsequentFilterStages
in interface FilterStageSource
public final MessageConsumer getMessageConsumer()
FilterStage
getMessageConsumer
in interface FilterStage
public void clearPendingMessageQueue()
Copyright © 2017 JacORB. All rights reserved.