public class StructuredProxyPullConsumerImpl extends AbstractProxyConsumer implements StructuredProxyPullConsumerOperations, MessageSupplier, MessageSupplierDelegate
MessageSupplierDelegate.PullResult
JMXManageable.JMXCallback
supplierAdmin_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
StructuredProxyPullConsumerImpl(IAdmin admin,
ORB orb,
POA poa,
Configuration config,
TaskProcessor taskProcessor,
MessageFactory mf,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
SupplierAdmin supplierAdmin) |
Modifier and Type | Method and Description |
---|---|
void |
connect_structured_pull_supplier(StructuredPullSupplier pullSupplier) |
void |
connectionResumed()
this is an extension point.
|
protected void |
connectionSuspended()
this is an extension point.
|
void |
disconnect_structured_pull_consumer() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
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.
|
protected void |
startTask() |
protected void |
stopTask() |
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, 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 StructuredProxyPullConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration config, TaskProcessor taskProcessor, MessageFactory mf, OfferManager offerManager, SubscriptionManager subscriptionManager, SupplierAdmin supplierAdmin)
public ProxyType MyType()
MyType
in interface ProxyConsumerOperations
MyType
in class AbstractProxy
public void disconnect_structured_pull_consumer()
disconnect_structured_pull_consumer
in interface StructuredPullConsumerOperations
public void connect_structured_pull_supplier(StructuredPullSupplier pullSupplier) throws AlreadyConnected
connect_structured_pull_supplier
in interface StructuredProxyPullConsumerOperations
AlreadyConnected
protected void connectionSuspended()
AbstractProxy
connectionSuspended
in class AbstractProxy
public void connectionResumed()
AbstractProxy
connectionResumed
in class AbstractProxy
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
protected void startTask()
protected void stopTask()
public Servant newServant()
newServant
in interface IServantLifecyle
public MessageSupplierDelegate.PullResult pullMessages() throws Disconnected
MessageSupplierDelegate
pullMessages
in interface MessageSupplierDelegate
Disconnected
public void queueMessages(MessageSupplierDelegate.PullResult data)
queueMessages
in interface MessageSupplierDelegate
public void runPullMessage() throws Disconnected
MessageSupplier
runPullMessage
in interface MessageSupplier
Disconnected
Copyright © 2016 JacORB. All rights reserved.