public class ProxyPullSupplierImpl extends AbstractProxySupplier implements ProxyPullSupplierOperations
JMXManageable.JMXCallback
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
ProxyPullSupplierImpl(IAdmin admin,
ORB orb,
POA poa,
Configuration config,
TaskProcessor taskProcessor,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin) |
Modifier and Type | Method and Description |
---|---|
void |
connect_any_pull_consumer(PullConsumer consumer) |
void |
deliverPendingData() |
void |
disableDelivery() |
void |
disconnect_pull_supplier() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
void |
enableDelivery() |
protected long |
getCost() |
ProxyType |
MyType() |
Servant |
newServant() |
Any |
pull() |
Any |
try_pull(BooleanHolder hasEvent) |
clearPendingMessageQueue, clientDisconnected, compareTo, connectClient, dispose, enqueue, getAllMessages, getAtLeastMessages, getDiscardPolicy, getErrorThreshold, getMaxEventsPerConsumer, getMessageBlocking, getMessageConsumer, getMessageNoBlock, getMessageQueueFactory, getNumberOfDiscardedMessages, getOrderPolicy, getPendingMessagesCount, getSubsequentFilterStages, getUpToMessages, hasMessageConsumer, hasPendingData, isRetryAllowed, messageQueued, MyAdmin, obtain_offered_types, queueMessage, 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
destroy, isDestroyed
public ProxyPullSupplierImpl(IAdmin admin, ORB orb, POA poa, Configuration config, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin) throws ConfigurationException
ConfigurationException
public ProxyType MyType()
MyType
in interface ProxySupplierOperations
MyType
in class AbstractProxy
public void disconnect_pull_supplier()
disconnect_pull_supplier
in interface PullSupplierOperations
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public Any pull() throws Disconnected
pull
in interface PullSupplierOperations
Disconnected
public Any try_pull(BooleanHolder hasEvent) throws Disconnected
try_pull
in interface PullSupplierOperations
Disconnected
public void connect_any_pull_consumer(PullConsumer consumer) throws AlreadyConnected
connect_any_pull_consumer
in interface ProxyPullSupplierOperations
AlreadyConnected
public void enableDelivery()
public void disableDelivery()
public void deliverPendingData()
public Servant newServant()
newServant
in interface IServantLifecyle
protected long getCost()
getCost
in class AbstractProxySupplier
Copyright © 2017 JacORB. All rights reserved.