public abstract class AbstractProxySupplier extends AbstractProxy implements MessageConsumer, NotifySubscribeOperations, AbstractProxySupplierMBean
JMXManageable.JMXCallback
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Modifier | Constructor and Description |
---|---|
protected |
AbstractProxySupplier(IAdmin admin,
ORB orb,
POA poa,
org.jacorb.config.Configuration conf,
TaskProcessor taskProcessor,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin) |
Modifier and Type | Method and Description |
---|---|
void |
clearPendingMessageQueue() |
protected void |
clientDisconnected() |
int |
compareTo(java.lang.Object o) |
void |
connectClient(Object client) |
void |
dispose() |
protected void |
enqueue(Message message)
put a copy of the Message in the queue of pending Messages.
|
protected Message[] |
getAllMessages() |
protected Message[] |
getAtLeastMessages(int min) |
protected abstract long |
getCost() |
java.lang.String |
getDiscardPolicy() |
int |
getErrorThreshold() |
int |
getMaxEventsPerConsumer() |
Message |
getMessageBlocking() |
MessageConsumer |
getMessageConsumer()
get the associated MessageConsumer or null.
|
protected Message |
getMessageNoBlock() |
protected EventQueueFactory |
getMessageQueueFactory() |
int |
getNumberOfDiscardedMessages() |
java.lang.String |
getOrderPolicy() |
int |
getPendingMessagesCount() |
java.util.List |
getSubsequentFilterStages() |
protected Message[] |
getUpToMessages(int max) |
boolean |
hasMessageConsumer()
check if this FilterStage has a MessageConsumer associcated.
|
boolean |
hasPendingData() |
boolean |
isRetryAllowed() |
protected void |
messageQueued()
this is an extension point.
|
ConsumerAdmin |
MyAdmin() |
EventType[] |
obtain_offered_types(ObtainInfoMode obtainInfoMode) |
void |
queueMessage(Message message)
Deliver a Message to the associated Consumer.
|
protected void |
removeListener() |
void |
setMaxEventsPerConsumer(int max) |
void |
subscription_change(EventType[] added,
EventType[] removed) |
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
destroy, getClientIOR, getConnected, getErrorCounter, getInterFilterGroupOperator, getStatus, resetErrorCounter
newServant
protected AbstractProxySupplier(IAdmin admin, ORB orb, POA poa, org.jacorb.config.Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin) throws org.jacorb.config.ConfigurationException
org.jacorb.config.ConfigurationException
protected EventQueueFactory getMessageQueueFactory()
public int getPendingMessagesCount()
getPendingMessagesCount
in interface AbstractProxySupplierMBean
public final java.lang.String getOrderPolicy()
getOrderPolicy
in interface AbstractProxySupplierMBean
public final java.lang.String getDiscardPolicy()
getDiscardPolicy
in interface AbstractProxySupplierMBean
public final int getMaxEventsPerConsumer()
getMaxEventsPerConsumer
in interface AbstractProxySupplierMBean
public void setMaxEventsPerConsumer(int max)
setMaxEventsPerConsumer
in interface AbstractProxySupplierMBean
public int getNumberOfDiscardedMessages()
getNumberOfDiscardedMessages
in interface AbstractProxySupplierMBean
public boolean hasPendingData()
protected void enqueue(Message message)
message
- the Message
to queue.public Message getMessageBlocking() throws java.lang.InterruptedException
java.lang.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(java.lang.Object o)
compareTo
in interface java.lang.Comparable
public final boolean hasMessageConsumer()
FilterStage
hasMessageConsumer
in interface FilterStage
public final java.util.List getSubsequentFilterStages()
getSubsequentFilterStages
in interface FilterStageSource
public final MessageConsumer getMessageConsumer()
FilterStage
getMessageConsumer
in interface FilterStage
public void clearPendingMessageQueue()
clearPendingMessageQueue
in interface AbstractProxySupplierMBean