org.jacorb.notification.servant
Class SupplierAdminImpl

java.lang.Object
  extended byorg.jacorb.notification.servant.AbstractAdmin
      extended byorg.jacorb.notification.servant.AbstractSupplierAdmin
          extended byorg.jacorb.notification.servant.SupplierAdminImpl
All Implemented Interfaces:
AbstractAdminMBean, Disposable, org.picocontainer.Disposable, FilterAdminOperations, FilterStage, FilterStageSource, IServantLifecyle, JMXManageable, NotifyingDisposable, NotifyPublishOperations, QoSAdminOperations, SupplierAdminImplMBean, SupplierAdminOperations, SupplierAdminOperations
Direct Known Subclasses:
TypedSupplierAdminImpl

public class SupplierAdminImpl
extends AbstractSupplierAdmin
implements SupplierAdminOperations, Disposable, SupplierAdminImplMBean

Version:
$Id: SupplierAdminImpl.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
SupplierAdminImpl(IEventChannel channelServant, ORB orb, POA poa, org.apache.avalon.framework.configuration.Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
           
 
Method Summary
 ProxyConsumer get_proxy_consumer(int id)
           
 java.lang.String getMBeanType()
           
 MessageConsumer getMessageConsumer()
          SupplierAdmin does not ever have a MessageConsumer.
 java.util.List getSubsequentFilterStages()
           
 boolean hasInterFilterGroupOperatorOR()
          check if this FilterStage has OR Semantic enabled.
 boolean hasMessageConsumer()
          SupplierAdmin does not ever have a MessageConsumer.
 Servant newServant()
           
 ProxyConsumer obtain_notification_pull_consumer(ClientType clientType, IntHolder intHolder)
           
 ProxyConsumer obtain_notification_push_consumer(ClientType clienttype, IntHolder intHolder)
           
 ProxyPullConsumer obtain_pull_consumer()
          get a ProxyPullConsumer (EventService Style)
 ProxyPushConsumer obtain_push_consumer()
          get a ProxyPushConsumer (EventService Style)
 void offer_change(EventType[] added, EventType[] removed)
           
 int[] pull_consumers()
          access the ids of all PullConsumers (NotifyStyle)
 int[] push_consumers()
          access the ids of all PushConsumers (NotifyStyle)
 void setSubsequentFilterStageSource(FilterStageSource source)
           
 
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, 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.SupplierAdminOperations
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

SupplierAdminImpl

public SupplierAdminImpl(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

offer_change

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

pull_consumers

public int[] pull_consumers()
access the ids of all PullConsumers (NotifyStyle)

Specified by:
pull_consumers in interface SupplierAdminOperations

push_consumers

public int[] push_consumers()
access the ids of all PushConsumers (NotifyStyle)

Specified by:
push_consumers in interface SupplierAdminOperations

obtain_notification_pull_consumer

public ProxyConsumer obtain_notification_pull_consumer(ClientType clientType,
                                                       IntHolder intHolder)
                                                throws AdminLimitExceeded
Specified by:
obtain_notification_pull_consumer in interface SupplierAdminOperations
Throws:
AdminLimitExceeded

get_proxy_consumer

public ProxyConsumer get_proxy_consumer(int id)
                                 throws ProxyNotFound
Specified by:
get_proxy_consumer in interface SupplierAdminOperations
Throws:
ProxyNotFound

obtain_notification_push_consumer

public ProxyConsumer obtain_notification_push_consumer(ClientType clienttype,
                                                       IntHolder intHolder)
                                                throws AdminLimitExceeded
Specified by:
obtain_notification_push_consumer in interface SupplierAdminOperations
Throws:
AdminLimitExceeded

obtain_push_consumer

public ProxyPushConsumer obtain_push_consumer()
get a ProxyPushConsumer (EventService Style)

Specified by:
obtain_push_consumer in interface SupplierAdminOperations

obtain_pull_consumer

public ProxyPullConsumer obtain_pull_consumer()
get a ProxyPullConsumer (EventService Style)

Specified by:
obtain_pull_consumer in interface SupplierAdminOperations

getSubsequentFilterStages

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

setSubsequentFilterStageSource

public void setSubsequentFilterStageSource(FilterStageSource source)
Specified by:
setSubsequentFilterStageSource in class AbstractSupplierAdmin

getMessageConsumer

public MessageConsumer getMessageConsumer()
SupplierAdmin does not ever have a MessageConsumer.

Specified by:
getMessageConsumer in interface FilterStage

hasMessageConsumer

public boolean hasMessageConsumer()
SupplierAdmin does not ever have a MessageConsumer.

Specified by:
hasMessageConsumer in interface FilterStage

hasInterFilterGroupOperatorOR

public boolean hasInterFilterGroupOperatorOR()
Description copied from interface: FilterStage
check if this FilterStage has OR Semantic enabled.

Specified by:
hasInterFilterGroupOperatorOR in interface FilterStage
Overrides:
hasInterFilterGroupOperatorOR in class AbstractAdmin

getMBeanType

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