org.jacorb.notification.servant
Class SupplierAdminImpl

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

public class SupplierAdminImpl
extends AbstractSupplierAdmin
implements SupplierAdminOperations, Disposable, SupplierAdminImplMBean

Version:
$Id: SupplierAdminImpl.java,v 1.12 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
SupplierAdminImpl(IEventChannel channelServant, ORB orb, POA poa, org.jacorb.config.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.jacorb.config.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)


push_consumers

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


obtain_notification_pull_consumer

public ProxyConsumer obtain_notification_pull_consumer(ClientType clientType,
                                                       IntHolder intHolder)
                                                throws AdminLimitExceeded
Throws:
AdminLimitExceeded

get_proxy_consumer

public ProxyConsumer get_proxy_consumer(int id)
                                 throws ProxyNotFound
Throws:
ProxyNotFound

obtain_notification_push_consumer

public ProxyConsumer obtain_notification_push_consumer(ClientType clienttype,
                                                       IntHolder intHolder)
                                                throws AdminLimitExceeded
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