public class SequenceProxyPushConsumerImpl extends AbstractProxyConsumer implements SequenceProxyPushConsumerOperations, IProxyConsumer
JMXManageable.JMXCallback
supplierAdmin_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
SequenceProxyPushConsumerImpl(IAdmin admin,
ORB orb,
POA poa,
org.jacorb.config.Configuration conf,
TaskProcessor taskProcessor,
MessageFactory mf,
SupplierAdmin supplierAdmin,
OfferManager offerManager,
SubscriptionManager subscriptionManager) |
Modifier and Type | Method and Description |
---|---|
void |
connect_sequence_push_supplier(SequencePushSupplier supplier) |
void |
disconnect_sequence_push_consumer() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
ProxyType |
MyType() |
Servant |
newServant() |
void |
push_structured_events(StructuredEvent[] events) |
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
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
getFirstStage, getStartTimeSupported, getStopTimeSupported
public SequenceProxyPushConsumerImpl(IAdmin admin, ORB orb, POA poa, org.jacorb.config.Configuration conf, TaskProcessor taskProcessor, MessageFactory mf, SupplierAdmin supplierAdmin, OfferManager offerManager, SubscriptionManager subscriptionManager)
public ProxyType MyType()
MyType
in interface ProxyConsumerOperations
MyType
in class AbstractProxy
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public void connect_sequence_push_supplier(SequencePushSupplier supplier) throws AlreadyConnected
connect_sequence_push_supplier
in interface SequenceProxyPushConsumerOperations
AlreadyConnected
public void push_structured_events(StructuredEvent[] events) throws Disconnected
push_structured_events
in interface SequencePushConsumerOperations
Disconnected
public void disconnect_sequence_push_consumer()
disconnect_sequence_push_consumer
in interface SequencePushConsumerOperations
public Servant newServant()
newServant
in interface IServantLifecyle