public class SequenceProxyPullSupplierImpl extends AbstractProxySupplier implements SequenceProxyPullSupplierOperations
JMXManageable.JMXCallback
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
SequenceProxyPullSupplierImpl(IAdmin admin,
ORB orb,
POA poa,
Configuration conf,
TaskProcessor taskProcessor,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
ConsumerAdmin consumerAdmin) |
Modifier and Type | Method and Description |
---|---|
void |
connect_sequence_pull_consumer(SequencePullConsumer consumer) |
void |
disconnect_sequence_pull_supplier() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
protected long |
getCost() |
ProxyType |
MyType() |
Servant |
newServant() |
StructuredEvent[] |
pull_structured_events(int number) |
StructuredEvent[] |
try_pull_structured_events(int number,
BooleanHolder success) |
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 SequenceProxyPullSupplierImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, ConsumerAdmin consumerAdmin) throws ConfigurationException
ConfigurationException
public ProxyType MyType()
MyType
in interface ProxySupplierOperations
MyType
in class AbstractProxy
public void connect_sequence_pull_consumer(SequencePullConsumer consumer) throws AlreadyConnected
connect_sequence_pull_consumer
in interface SequenceProxyPullSupplierOperations
AlreadyConnected
public StructuredEvent[] pull_structured_events(int number) throws Disconnected
pull_structured_events
in interface SequencePullSupplierOperations
Disconnected
public StructuredEvent[] try_pull_structured_events(int number, BooleanHolder success) throws Disconnected
try_pull_structured_events
in interface SequencePullSupplierOperations
Disconnected
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public void disconnect_sequence_pull_supplier()
disconnect_sequence_pull_supplier
in interface SequencePullSupplierOperations
public Servant newServant()
newServant
in interface IServantLifecyle
protected long getCost()
getCost
in class AbstractProxySupplier
Copyright © 2016 JacORB. All rights reserved.