public class ConsumerAdminImpl extends AbstractAdmin implements ConsumerAdminOperations, Disposable, ProxyEventListener
JMXManageable.JMXCallback
container_, DEFAULT_FILTER_GROUP_OPERATOR, logger_, modifyProxiesLock_, offerManager_, pullServants_, pushServants_, servantLifecycle_, subscriptionManager_
Constructor and Description |
---|
ConsumerAdminImpl(IEventChannel channelServant,
ORB orb,
POA poa,
org.jacorb.config.Configuration config,
MessageFactory messageFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager) |
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, MyChannel, MyID, MyOperator
get_qos, set_qos, validate_qos
add_filter, get_all_filters, get_filter, remove_all_filters, remove_filter
public ConsumerAdminImpl(IEventChannel channelServant, ORB orb, POA poa, org.jacorb.config.Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
public Servant newServant()
newServant
in interface IServantLifecyle
public void subscription_change(EventType[] added, EventType[] removed) throws InvalidEventType
subscription_change
in interface NotifySubscribeOperations
InvalidEventType
public ProxySupplier get_proxy_supplier(int key) throws ProxyNotFound
ProxyNotFound
public void lifetime_filter(MappingFilter lifetimeFilter)
public MappingFilter lifetime_filter()
public MappingFilter priority_filter()
public void priority_filter(MappingFilter priorityFilter)
public ProxySupplier obtain_notification_pull_supplier(ClientType clientType, IntHolder intHolder) throws AdminLimitExceeded
AdminLimitExceeded
protected void configureMappingFilters(AbstractProxySupplier servant)
public int[] pull_suppliers()
public int[] push_suppliers()
public ProxySupplier obtain_notification_push_supplier(ClientType clientType, IntHolder intHolder) throws AdminLimitExceeded
AdminLimitExceeded
public ProxyPullSupplier obtain_pull_supplier()
obtain_pull_supplier
in interface ConsumerAdminOperations
public ProxyPushSupplier obtain_push_supplier()
obtain_push_supplier
in interface ConsumerAdminOperations
public java.util.List getSubsequentFilterStages()
getSubsequentFilterStages
in interface FilterStageSource
public MessageConsumer getMessageConsumer()
getMessageConsumer
in interface FilterStage
public boolean hasMessageConsumer()
hasMessageConsumer
in interface FilterStage
public void actionProxyCreationRequest(ProxyEvent event)
ProxyEventListener
actionProxyCreationRequest
in interface ProxyEventListener
public void actionProxyDisposed(ProxyEvent event)
actionProxyDisposed
in interface ProxyEventListener
public void actionProxyCreated(ProxyEvent event)
actionProxyCreated
in interface ProxyEventListener
public java.lang.String getMBeanType()
getMBeanType
in class AbstractAdmin