org.jacorb.notification.servant
Class SupplierAdminImpl

java.lang.Object
  org.jacorb.notification.servant.AbstractAdmin
      org.jacorb.notification.servant.AbstractSupplierAdmin
          org.jacorb.notification.servant.SupplierAdminImpl

All Implemented Interfaces:

org.picocontainer.Disposable, Disposable, FilterAdminOperations, FilterStage, FilterStageSource, ManageableServant, NotifyPublishOperations, QoSAdminOperations, SupplierAdminOperations, SupplierAdminOperations

Direct Known Subclasses:

TypedSupplierAdminImpl

public class SupplierAdminImpl

extends AbstractSupplierAdmin

implements SupplierAdminOperations, Disposable

Version:

$Id: SupplierAdminImpl.java,v 1.6 2005/04/10 14:28:58 alphonse.bendt Exp $

Author:

Alphonse Bendt

Field Summary

Fields inherited from class org.jacorb.notification.servant.AbstractAdmin

channelID_, container_, DEFAULT_FILTER_GROUP_OPERATOR, logger_, modifyProxiesLock_, offerManager_, pullServants_, pushServants_, 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

Object	activate()
protected Servant	createServant()
ProxyConsumer	get_proxy_consumer(int id)
MessageConsumer	getMessageConsumer() SupplierAdmin does not ever have a MessageConsumer.
Servant	getServant()
java.util.List	getSubsequentFilterStages()
boolean	hasInterFilterGroupOperatorOR() check if this FilterStage has OR Semantic enabled.
boolean	hasMessageConsumer() SupplierAdmin does not ever have a MessageConsumer.
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

_default_POA, add_filter, addDisposeHook, addProxyEventListener, addProxyToMap, configureInterFilterGroupOperator, configureQoS, deactivate, destroy, dispose, fireCreateProxyRequestEvent, get_all_filters, get_all_notify_proxies, get_filter, get_qos, getFilters, getID, getLifetimeFilter, getMessageFactory, getORB, getPOA, getPriorityFilter, getProxies, getProxy, hasLifetimeFilter, hasPriorityFilter, isDisposed, MyChannel, MyID, MyOperator, newComponentAdapter, newContainerForEventStyleProxy, newContainerForNotifyStyleProxy, newContainerForTypedProxy, remove_all_filters, remove_filter, removeProxyEventListener, set_qos, setInterFilterGroupOperator, 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

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

createServant

protected Servant createServant()

getServant

public Servant getServant()

Specified by:

getServant in class AbstractAdmin

activate

public Object activate()

Specified by:

activate in interface ManageableServant

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