public class TypedProxyPullSupplierImpl extends AbstractProxySupplier implements TypedProxyPullSupplierOperations, ITypedProxy
JMXManageable.JMXCallback
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
TypedProxyPullSupplierImpl(ITypedAdmin admin,
ConsumerAdmin consumerAdmin,
ORB orb,
POA poa,
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() |
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
destroy, isDestroyed
public TypedProxyPullSupplierImpl(ITypedAdmin admin, ConsumerAdmin consumerAdmin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, OfferManager offerManager, SubscriptionManager subscriptionManager, DynAnyFactory dynAnyFactory, Repository repository) throws ConfigurationException
ConfigurationException
public int getPendingMessagesCount()
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 String getSupportedInterface()
Copyright © 2016 JacORB. All rights reserved.