public class TypedConsumerAdminImpl extends ConsumerAdminImpl implements TypedConsumerAdminOperations
JMXManageable.JMXCallback
container_, DEFAULT_FILTER_GROUP_OPERATOR, logger_, modifyProxiesLock_, offerManager_, pullServants_, pushServants_, servantLifecycle_, subscriptionManager_
Constructor and Description |
---|
TypedConsumerAdminImpl(ORB orb,
POA poa,
org.jacorb.config.Configuration config,
MessageFactory messageFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager,
IEventChannel channelServant) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getMBeanType() |
Servant |
newServant() |
TypedProxyPullSupplier |
obtain_typed_notification_pull_supplier(java.lang.String type,
IntHolder id) |
TypedProxyPushSupplier |
obtain_typed_notification_push_supplier(java.lang.String type,
IntHolder id) |
TypedProxyPullSupplier |
obtain_typed_pull_supplier(java.lang.String type) |
ProxyPushSupplier |
obtain_typed_push_supplier(java.lang.String type) |
actionProxyCreated, actionProxyCreationRequest, actionProxyDisposed, configureMappingFilters, get_proxy_supplier, getMessageConsumer, getSubsequentFilterStages, hasMessageConsumer, lifetime_filter, lifetime_filter, obtain_notification_pull_supplier, obtain_notification_push_supplier, obtain_pull_supplier, obtain_push_supplier, priority_filter, priority_filter, pull_suppliers, push_suppliers, subscription_change
activate, add_filter, addProxyEventListener, addProxyToMap, configureInterFilterGroupOperator, configureQoS, deactivate, destroy, dispose, fireCreateProxyRequestEvent, get_all_filters, get_all_notify_proxies, get_filter, get_qos, getChannelID, getFilters, getID, getInterFilterGroupOperator, getJMXNotificationTypes, getJMXObjectName, getLifetimeFilter, getMBeanName, getMessageFactory, getORB, getPOA, getPriorityFilter, getProxy, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, isDestroyed, MyChannel, MyID, MyOperator, newContainerForEventStyleProxy, newContainerForNotifyStyleProxy, newContainerForTypedProxy, registerDisposable, remove_all_filters, remove_filter, removeProxyEventListener, sendNotification, set_qos, setInterFilterGroupOperator, setJMXCallback, validate_qos
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, get_proxy_supplier, lifetime_filter, lifetime_filter, MyChannel, MyID, MyOperator, obtain_notification_pull_supplier, obtain_notification_push_supplier, priority_filter, priority_filter, pull_suppliers, push_suppliers
get_qos, set_qos, validate_qos
subscription_change
add_filter, get_all_filters, get_filter, remove_all_filters, remove_filter
obtain_pull_supplier, obtain_push_supplier
destroy, getID, getInterFilterGroupOperator
public TypedConsumerAdminImpl(ORB orb, POA poa, org.jacorb.config.Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager, IEventChannel channelServant)
public Servant newServant()
newServant
in interface IServantLifecyle
newServant
in class ConsumerAdminImpl
public TypedProxyPullSupplier obtain_typed_notification_pull_supplier(java.lang.String type, IntHolder id)
public TypedProxyPushSupplier obtain_typed_notification_push_supplier(java.lang.String type, IntHolder id)
public ProxyPushSupplier obtain_typed_push_supplier(java.lang.String type)
obtain_typed_push_supplier
in interface TypedConsumerAdminOperations
public TypedProxyPullSupplier obtain_typed_pull_supplier(java.lang.String type)
obtain_typed_pull_supplier
in interface TypedConsumerAdminOperations
public java.lang.String getMBeanType()
getMBeanType
in class ConsumerAdminImpl