public class TypedProxyPushConsumerImpl extends AbstractProxyConsumer implements TypedProxyPushConsumerOperations, ITypedProxy
JMXManageable.JMXCallback
supplierAdmin_
config_, eventTypes_, logger_, offerManager_, qosSettings_, subscriptionManager_
Constructor and Description |
---|
TypedProxyPushConsumerImpl(ITypedAdmin admin,
SupplierAdmin supplierAdmin,
ORB orb,
POA poa,
org.jacorb.config.Configuration conf,
TaskProcessor taskProcessor,
MessageFactory messageFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
Repository repository) |
Modifier and Type | Method and Description |
---|---|
void |
connect_typed_push_supplier(PushSupplier pushSupplier) |
void |
disconnect_push_consumer() |
void |
disconnectClient()
invoke the proxy specific disconnect method.
|
Object |
get_typed_consumer() |
java.lang.String |
getSupportedInterface() |
ProxyType |
MyType() |
Servant |
newServant() |
void |
push(Any any) |
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 TypedProxyPushConsumerImpl(ITypedAdmin admin, SupplierAdmin supplierAdmin, ORB orb, POA poa, org.jacorb.config.Configuration conf, TaskProcessor taskProcessor, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, Repository repository) throws InterfaceNotSupported
InterfaceNotSupported
public ProxyType MyType()
MyType
in interface ProxyConsumerOperations
MyType
in class AbstractProxy
public void connect_typed_push_supplier(PushSupplier pushSupplier) throws AlreadyConnected
connect_typed_push_supplier
in interface TypedProxyPushConsumerOperations
AlreadyConnected
public void push(Any any) throws Disconnected
push
in interface PushConsumerOperations
Disconnected
public Object get_typed_consumer()
get_typed_consumer
in interface TypedPushConsumerOperations
public void disconnect_push_consumer()
disconnect_push_consumer
in interface PushConsumerOperations
public void disconnectClient()
AbstractProxy
disconnectClient
in class AbstractProxy
public Servant newServant()
newServant
in interface IServantLifecyle
public java.lang.String getSupportedInterface()