public class TypedProxyPullSupplierImpl extends AbstractProxySupplier implements TypedProxyPullSupplierOperations, ITypedProxy, TypedProxyPullSupplierImplMBean
JMXManageable.JMXCallback
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
TypedProxyPullSupplierImpl(ITypedAdmin admin,
ConsumerAdmin consumerAdmin,
ORB orb,
POA poa,
org.jacorb.config.Configuration conf,
TaskProcessor taskProcessor,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
DynAnyFactory dynAnyFactory,
Repository repository) |
Modifier and Type | Method and Description |
---|---|
void |
connect_typed_pull_consumer(PullConsumer pullConsumer) |
void |
deliverPendingData() |
void |
disconnect_pull_supplier() |
void |
disconnectClient()
invoke the proxy specific disconnect method.
|
Object |
get_typed_supplier() |
protected long |
getCost() |
int |
getPendingMessagesCount() |
java.lang.String |
getSupportedInterface() |
ProxyType |
MyType() |
Servant |
newServant() |
Any |
pull() |
void |
queueMessage(Message message)
Deliver a Message to the associated Consumer.
|
Any |
try_pull(BooleanHolder booleanHolder) |
clearPendingMessageQueue, clientDisconnected, compareTo, connectClient, dispose, enqueue, getAllMessages, getAtLeastMessages, getDiscardPolicy, getErrorThreshold, getMaxEventsPerConsumer, getMessageBlocking, getMessageConsumer, getMessageNoBlock, getMessageQueueFactory, getNumberOfDiscardedMessages, getOrderPolicy, getSubsequentFilterStages, getUpToMessages, hasMessageConsumer, hasPendingData, isRetryAllowed, messageQueued, MyAdmin, obtain_offered_types, removeListener, setMaxEventsPerConsumer, subscription_change
activate, add_filter, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, connectionResumed, connectionSuspended, deactivate, destroy, 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, 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
lifetime_filter, lifetime_filter, MyAdmin, obtain_offered_types, priority_filter, priority_filter, validate_event_qos
get_qos, set_qos, validate_qos
add_filter, get_all_filters, get_filter, remove_all_filters, remove_filter
subscription_change
clearPendingMessageQueue, getDiscardPolicy, getMaxEventsPerConsumer, getNumberOfDiscardedMessages, getOrderPolicy, setMaxEventsPerConsumer
destroy, getClientIOR, getConnected, getErrorCounter, getInterFilterGroupOperator, getStatus, resetErrorCounter
destroy, isDestroyed
public TypedProxyPullSupplierImpl(ITypedAdmin admin, ConsumerAdmin consumerAdmin, ORB orb, POA poa, org.jacorb.config.Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, DynAnyFactory dynAnyFactory, Repository repository) throws org.jacorb.config.ConfigurationException
org.jacorb.config.ConfigurationException
public int getPendingMessagesCount()
getPendingMessagesCount
in interface AbstractProxySupplierMBean
getPendingMessagesCount
in interface TypedProxyPullSupplierImplMBean
getPendingMessagesCount
in class AbstractProxySupplier
public Any pull() throws Disconnected
pull
in interface PullSupplierOperations
Disconnected
public Any try_pull(BooleanHolder booleanHolder) throws Disconnected
try_pull
in interface PullSupplierOperations
Disconnected
public void disconnect_pull_supplier()
disconnect_pull_supplier
in interface PullSupplierOperations
public void connect_typed_pull_consumer(PullConsumer pullConsumer) throws AlreadyConnected
connect_typed_pull_consumer
in interface TypedProxyPullSupplierOperations
AlreadyConnected
public Object get_typed_supplier()
get_typed_supplier
in interface TypedPullSupplierOperations
public ProxyType MyType()
MyType
in interface ProxySupplierOperations
MyType
in class AbstractProxy
public Servant newServant()
newServant
in interface IServantLifecyle
public void queueMessage(Message message)
MessageConsumer
queueMessage
in interface MessageConsumer
queueMessage
in class AbstractProxySupplier
public void deliverPendingData()
public void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
protected long getCost()
getCost
in class AbstractProxySupplier
public java.lang.String getSupportedInterface()
getSupportedInterface
in interface TypedProxyPullSupplierImplMBean