public class StructuredProxyPullSupplierImpl extends AbstractProxySupplier implements StructuredProxyPullSupplierOperations, StructuredProxyPullSupplierImplMBean
JMXManageable.JMXCallback
Modifier and Type | Field and Description |
---|---|
protected static StructuredEvent |
UNDEFINED_STRUCTURED_EVENT
undefined StructuredEvent that is returned on unsuccessful pull operations.
|
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
StructuredProxyPullSupplierImpl(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 |
connect_structured_pull_consumer(StructuredPullConsumer consumer) |
void |
deliverPendingData() |
void |
disableDelivery() |
void |
disconnect_structured_pull_supplier() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
void |
enableDelivery() |
protected long |
getCost() |
ProxyType |
MyType() |
Servant |
newServant() |
StructuredEvent |
pull_structured_event() |
StructuredEvent |
try_pull_structured_event(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, getClientIOR, getConnected, getErrorCounter, getInterFilterGroupOperator, getStatus, resetErrorCounter
destroy, isDestroyed
protected static final StructuredEvent UNDEFINED_STRUCTURED_EVENT
public StructuredProxyPullSupplierImpl(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
public ProxyType MyType()
MyType
in interface ProxySupplierOperations
MyType
in class AbstractProxy
public void connect_structured_pull_consumer(StructuredPullConsumer consumer) throws AlreadyConnected
connect_structured_pull_consumer
in interface StructuredProxyPullSupplierOperations
AlreadyConnected
public StructuredEvent pull_structured_event() throws Disconnected
pull_structured_event
in interface StructuredPullSupplierOperations
Disconnected
public StructuredEvent try_pull_structured_event(BooleanHolder hasEvent) throws Disconnected
try_pull_structured_event
in interface StructuredPullSupplierOperations
Disconnected
public void disconnect_structured_pull_supplier()
disconnect_structured_pull_supplier
in interface StructuredPullSupplierOperations
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public void disableDelivery()
public void enableDelivery()
public void deliverPendingData()
public Servant newServant()
newServant
in interface IServantLifecyle
protected long getCost()
getCost
in class AbstractProxySupplier