org.jacorb.notification.servant

Class ConsumerAdminTieImpl

Implemented Interfaces:
Configurable, ConsumerAdminOperations, ConsumerAdminOperations, Disposable, FilterAdminOperations, FilterStage, ManageableServant, NotifySubscribeOperations, ProxyEventListener, QoSAdminOperations

public class ConsumerAdminTieImpl
extends AbstractAdmin
implements ConsumerAdminOperations, Disposable, ProxyEventListener

Version:
$Id: ConsumerAdminTieImpl.java,v 1.8 2004/05/06 12:39:59 nicolas Exp $

Author:
Alphonse Bendt

Field Summary

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

DEFAULT_FILTER_GROUP_OPERATOR, logger_, modifyProxiesLock_, offerManager_, pullServants_, pushServants_, subscriptionManager_

Constructor Summary

ConsumerAdminTieImpl(ChannelContext channelContext)

Method Summary

void
actionProxyCreated(ProxyEvent event)
void
actionProxyCreationRequest(ProxyEvent event)
void
actionProxyDisposed(ProxyEvent event)
Object
activate()
MessageConsumer
getMessageConsumer()
ConsumerAdmin never has a MessageConsumer
Servant
getServant()
List
getSubsequentFilterStages()
ProxySupplier
get_proxy_supplier(int key)
boolean
hasMessageConsumer()
ConsumerAdmin never has a MessageConsumer
MappingFilter
lifetime_filter()
void
lifetime_filter(MappingFilter lifetimeFilter)
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

MyChannel, MyID, MyOperator, _default_POA, addProxyEventListener, addProxyToMap, add_filter, configure, configureEventStyleID, configureInterFilterGroupOperator, configureManagers, configureNotifyStyleID, configureQoS, deactivate, destroy, dispose, fireCreateProxyRequestEvent, getChannelContext, getChannelServant, getFilters, getID, getLifetimeFilter, getMessageFactory, getORB, getPOA, getPriorityFilter, getProxies, getProxy, getServant, get_all_filters, get_all_notify_proxies, get_filter, get_qos, hasInterFilterGroupOperatorOR, hasLifetimeFilter, hasPriorityFilter, isDisposed, preActivate, removeProxyEventListener, remove_all_filters, remove_filter, setDisposeHook, setID, setInterFilterGroupOperator, setIsIDPublic, setORB, setOfferManager, setPOA, setSubscriptionManager, set_qos, validate_qos

Constructor Details

ConsumerAdminTieImpl

public ConsumerAdminTieImpl(ChannelContext channelContext)

Method Details

actionProxyCreated

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


actionProxyCreationRequest

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


actionProxyDisposed

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


activate

public Object activate()
Specified by:
activate in interface ManageableServant


getMessageConsumer

public MessageConsumer getMessageConsumer()
ConsumerAdmin never has a MessageConsumer
Specified by:
getMessageConsumer in interface FilterStage


getServant

public Servant getServant()
Overrides:
getServant in interface AbstractAdmin


getSubsequentFilterStages

public List getSubsequentFilterStages()
Specified by:
getSubsequentFilterStages in interface FilterStage


get_proxy_supplier

public ProxySupplier get_proxy_supplier(int key)
            throws ProxyNotFound
Specified by:
get_proxy_supplier in interface ConsumerAdminOperations


hasMessageConsumer

public boolean hasMessageConsumer()
ConsumerAdmin never has a MessageConsumer
Specified by:
hasMessageConsumer in interface FilterStage


lifetime_filter

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


lifetime_filter

public void lifetime_filter(MappingFilter lifetimeFilter)
Specified by:
lifetime_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


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


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


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


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


subscription_change

public void subscription_change(EventType added,
                                EventType removed)
            throws InvalidEventType