org.jacorb.notification.servant
Class ConsumerAdminImpl

java.lang.Object
  extended by org.jacorb.notification.servant.AbstractAdmin
      extended by org.jacorb.notification.servant.ConsumerAdminImpl
All Implemented Interfaces:
FilterStage, FilterStageSource, JMXManageable, NotifyingDisposable, ProxyEventListener, IServantLifecyle, AbstractAdminMBean, ConsumerAdminImplMBean, ConsumerAdminOperations, QoSAdminOperations, NotifySubscribeOperations, FilterAdminOperations, org.picocontainer.Disposable
Direct Known Subclasses:
TypedConsumerAdminImpl

public class ConsumerAdminImpl
extends AbstractAdmin
implements ConsumerAdminOperations, Disposable, ProxyEventListener, ConsumerAdminImplMBean

Version:
$Id: ConsumerAdminImpl.java,v 1.13 2009-05-03 21:34:47 andre.spiegel Exp $
Author:
Alphonse Bendt

Nested Class Summary
 
Nested classes/interfaces inherited from interface org.jacorb.notification.interfaces.JMXManageable
JMXManageable.JMXCallback
 
Field Summary
 
Fields inherited from class org.jacorb.notification.servant.AbstractAdmin
container_, DEFAULT_FILTER_GROUP_OPERATOR, logger_, modifyProxiesLock_, offerManager_, pullServants_, pushServants_, servantLifecycle_, subscriptionManager_
 
Constructor Summary
ConsumerAdminImpl(IEventChannel channelServant, ORB orb, POA poa, org.jacorb.config.Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
           
 
Method Summary
 void actionProxyCreated(ProxyEvent event)
           
 void actionProxyCreationRequest(ProxyEvent event)
          This event is fired if a Admin wants to create a new Proxy.
 void actionProxyDisposed(ProxyEvent event)
           
protected  void configureMappingFilters(AbstractProxySupplier servant)
           
 ProxySupplier get_proxy_supplier(int key)
           
 java.lang.String getMBeanType()
           
 MessageConsumer getMessageConsumer()
          ConsumerAdmin never has a MessageConsumer
 java.util.List getSubsequentFilterStages()
           
 boolean hasMessageConsumer()
          ConsumerAdmin never has a MessageConsumer
 MappingFilter lifetime_filter()
           
 void lifetime_filter(MappingFilter lifetimeFilter)
           
 Servant newServant()
           
 ProxySupplier obtain_notification_pull_supplier(ClientType clientType, IntHolder intHolder)
           
 ProxySupplier obtain_notification_push_supplier(ClientType clientType, IntHolder intHolder)
           
 ProxyPullSupplier obtain_pull_supplier()
           
 ProxyPushSupplier obtain_push_supplier()
          get ProxyPushSupplier (EventStyle)
 MappingFilter priority_filter()
           
 void priority_filter(MappingFilter priorityFilter)
           
 int[] pull_suppliers()
           
 int[] push_suppliers()
           
 void subscription_change(EventType[] added, EventType[] removed)
           
 
Methods inherited from class org.jacorb.notification.servant.AbstractAdmin
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.omg.CosNotifyChannelAdmin.ConsumerAdminOperations
destroy, MyChannel, MyID, MyOperator
 
Methods inherited from interface org.omg.CosNotification.QoSAdminOperations
get_qos, set_qos, validate_qos
 
Methods inherited from interface org.omg.CosNotifyFilter.FilterAdminOperations
add_filter, get_all_filters, get_filter, remove_all_filters, remove_filter
 
Methods inherited from interface org.picocontainer.Disposable
dispose
 
Methods inherited from interface org.jacorb.notification.servant.AbstractAdminMBean
destroy, getID, getInterFilterGroupOperator
 

Constructor Detail

ConsumerAdminImpl

public ConsumerAdminImpl(IEventChannel channelServant,
                         ORB orb,
                         POA poa,
                         org.jacorb.config.Configuration config,
                         MessageFactory messageFactory,
                         OfferManager offerManager,
                         SubscriptionManager subscriptionManager)
Method Detail

newServant

public Servant newServant()
Specified by:
newServant in interface IServantLifecyle

subscription_change

public void subscription_change(EventType[] added,
                                EventType[] removed)
                         throws InvalidEventType
Specified by:
subscription_change in interface NotifySubscribeOperations
Throws:
InvalidEventType

get_proxy_supplier

public ProxySupplier get_proxy_supplier(int key)
                                 throws ProxyNotFound
Throws:
ProxyNotFound

lifetime_filter

public void lifetime_filter(MappingFilter lifetimeFilter)

lifetime_filter

public MappingFilter lifetime_filter()

priority_filter

public MappingFilter priority_filter()

priority_filter

public void priority_filter(MappingFilter priorityFilter)

obtain_notification_pull_supplier

public ProxySupplier obtain_notification_pull_supplier(ClientType clientType,
                                                       IntHolder intHolder)
                                                throws AdminLimitExceeded
Throws:
AdminLimitExceeded

configureMappingFilters

protected void configureMappingFilters(AbstractProxySupplier servant)

pull_suppliers

public int[] pull_suppliers()

push_suppliers

public int[] push_suppliers()

obtain_notification_push_supplier

public ProxySupplier obtain_notification_push_supplier(ClientType clientType,
                                                       IntHolder intHolder)
                                                throws AdminLimitExceeded
Throws:
AdminLimitExceeded

obtain_pull_supplier

public ProxyPullSupplier obtain_pull_supplier()
Specified by:
obtain_pull_supplier in interface ConsumerAdminOperations

obtain_push_supplier

public ProxyPushSupplier obtain_push_supplier()
get ProxyPushSupplier (EventStyle)

Specified by:
obtain_push_supplier in interface ConsumerAdminOperations

getSubsequentFilterStages

public java.util.List getSubsequentFilterStages()
Specified by:
getSubsequentFilterStages in interface FilterStageSource

getMessageConsumer

public MessageConsumer getMessageConsumer()
ConsumerAdmin never has a MessageConsumer

Specified by:
getMessageConsumer in interface FilterStage

hasMessageConsumer

public boolean hasMessageConsumer()
ConsumerAdmin never has a MessageConsumer

Specified by:
hasMessageConsumer in interface FilterStage

actionProxyCreationRequest

public void actionProxyCreationRequest(ProxyEvent event)
Description copied from interface: ProxyEventListener
This event is fired if a Admin wants to create a new Proxy. A Listener may throw AdminLimitExceeded if the creation of more Proxies exeeds a limit.

Specified by:
actionProxyCreationRequest in interface ProxyEventListener

actionProxyDisposed

public void actionProxyDisposed(ProxyEvent event)
Specified by:
actionProxyDisposed in interface ProxyEventListener

actionProxyCreated

public void actionProxyCreated(ProxyEvent event)
Specified by:
actionProxyCreated in interface ProxyEventListener

getMBeanType

public java.lang.String getMBeanType()
Specified by:
getMBeanType in class AbstractAdmin