public class TypedProxyPullConsumerImpl extends AbstractProxyConsumer implements TypedProxyPullConsumerOperations, MessageSupplier, MessageSupplierDelegate, ITypedProxy
MessageSupplierDelegate.PullResult
JMXManageable.JMXCallback
supplierAdmin_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
TypedProxyPullConsumerImpl(ITypedAdmin admin,
SupplierAdmin supplierAdmin,
ORB orb,
POA poa,
org.jacorb.config.Configuration config,
TaskProcessor taskProcessor,
MessageFactory messageFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager) |
Modifier and Type | Method and Description |
---|---|
void |
connect_typed_pull_supplier(TypedPullSupplier typedPullSupplier) |
void |
disconnect_pull_consumer() |
void |
disconnectClient()
invoke the proxy specific disconnect method.
|
java.lang.String |
getSupportedInterface() |
ProxyType |
MyType() |
Servant |
newServant() |
MessageSupplierDelegate.PullResult |
pullMessages()
the implementation pulls one or more events from its Supplier
and hands over the pulled events to the TaskProcessor.
|
void |
queueMessages(MessageSupplierDelegate.PullResult data) |
void |
runPullMessage()
pull one or more events from the Supplier
and hands over the pulled events to the TaskProcessor.
|
checkMessageProperties, clientDisconnected, connectClient, getFirstStage, getMessageConsumer, getMessageCount, getMessageFactory, getStartTimeSupported, getStopTimeSupported, getSubsequentFilterStages, hasMessageConsumer, MyAdmin, newMessages, obtain_subscription_types, offer_change, processMessage, removeListener, schedulePullTask, setSubsequentDestinations
activate, add_filter, checkDestroyStatus, checkIsConnected, checkIsNotConnected, checkStillConnected, configure, connectionResumed, connectionSuspended, deactivate, destroy, dispose, 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
resume_connection, suspend_connection
MyAdmin, obtain_subscription_types, validate_event_qos
get_qos, set_qos, validate_qos
add_filter, get_all_filters, get_filter, remove_all_filters, remove_filter
offer_change
destroy
getConnected, isSuspended
public TypedProxyPullConsumerImpl(ITypedAdmin admin, SupplierAdmin supplierAdmin, ORB orb, POA poa, org.jacorb.config.Configuration config, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
public void connect_typed_pull_supplier(TypedPullSupplier typedPullSupplier) throws AlreadyConnected, TypeError
connect_typed_pull_supplier
in interface TypedProxyPullConsumerOperations
AlreadyConnected
TypeError
public MessageSupplierDelegate.PullResult pullMessages()
MessageSupplierDelegate
pullMessages
in interface MessageSupplierDelegate
public void queueMessages(MessageSupplierDelegate.PullResult data)
queueMessages
in interface MessageSupplierDelegate
public void disconnect_pull_consumer()
disconnect_pull_consumer
in interface PullConsumerOperations
public ProxyType MyType()
MyType
in interface ProxyConsumerOperations
MyType
in class AbstractProxy
public void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public Servant newServant()
newServant
in interface IServantLifecyle
public java.lang.String getSupportedInterface()
public void runPullMessage() throws Disconnected
MessageSupplier
runPullMessage
in interface MessageSupplier
Disconnected