org.jacorb.notification.servant
Class ConsumerAdminImpl

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

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

Version:
$Id: ConsumerAdminImpl.java,v 1.10 2006/01/12 22:34:54 alphonse.bendt Exp $
Author:
Alphonse Bendt

Nested Class Summary
 
Nested classes inherited from class 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.apache.avalon.framework.configuration.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.apache.avalon.framework.configuration.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
Specified by:
get_proxy_supplier in interface ConsumerAdminOperations
Throws:
ProxyNotFound

lifetime_filter

public void lifetime_filter(MappingFilter lifetimeFilter)
Specified by:
lifetime_filter in interface ConsumerAdminOperations

lifetime_filter

public MappingFilter lifetime_filter()
Specified by:
lifetime_filter in interface ConsumerAdminOperations

priority_filter

public MappingFilter priority_filter()
Specified by:
priority_filter in interface ConsumerAdminOperations

priority_filter

public void priority_filter(MappingFilter priorityFilter)
Specified by:
priority_filter in interface ConsumerAdminOperations

obtain_notification_pull_supplier

public ProxySupplier obtain_notification_pull_supplier(ClientType clientType,
                                                       IntHolder intHolder)
                                                throws AdminLimitExceeded
Specified by:
obtain_notification_pull_supplier in interface ConsumerAdminOperations
Throws:
AdminLimitExceeded

configureMappingFilters

protected void configureMappingFilters(AbstractProxySupplier servant)

pull_suppliers

public int[] pull_suppliers()
Specified by:
pull_suppliers in interface ConsumerAdminOperations

push_suppliers

public int[] push_suppliers()
Specified by:
push_suppliers in interface ConsumerAdminOperations

obtain_notification_push_supplier

public ProxySupplier obtain_notification_push_supplier(ClientType clientType,
                                                       IntHolder intHolder)
                                                throws AdminLimitExceeded
Specified by:
obtain_notification_push_supplier in interface ConsumerAdminOperations
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