public class ProxyPushConsumerImpl extends AbstractProxyConsumer implements ProxyPushConsumerOperations
JMXManageable.JMXCallback
supplierAdmin_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
ProxyPushConsumerImpl(IAdmin admin,
ORB orb,
POA poa,
Configuration conf,
TaskProcessor taskProcessor,
MessageFactory messageFactory,
SupplierAdmin supplierAdmin,
OfferManager offerManager,
SubscriptionManager subscriptionManager) |
Modifier and Type | Method and Description |
---|---|
void |
connect_any_push_supplier(PushSupplier pushSupplier) |
void |
disconnect_push_consumer() |
protected void |
disconnectClient()
invoke the proxy specific disconnect method.
|
ProxyType |
MyType() |
Servant |
newServant() |
void |
push(Any event)
Supplier sends data to the consumer (this object) using this call.
|
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
public ProxyPushConsumerImpl(IAdmin admin, ORB orb, POA poa, Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, SupplierAdmin supplierAdmin, OfferManager offerManager, SubscriptionManager subscriptionManager)
public ProxyType MyType()
MyType
in interface ProxyConsumerOperations
MyType
in class AbstractProxy
public void disconnect_push_consumer()
disconnect_push_consumer
in interface PushConsumerOperations
protected void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public void push(Any event) throws Disconnected
push
in interface PushConsumerOperations
Disconnected
public void connect_any_push_supplier(PushSupplier pushSupplier) throws AlreadyConnected
connect_any_push_supplier
in interface ProxyPushConsumerOperations
AlreadyConnected
public Servant newServant()
newServant
in interface IServantLifecyle
Copyright © 2016 JacORB. All rights reserved.