public class SupplierAdminImpl extends AbstractSupplierAdmin implements SupplierAdminOperations, Disposable
JMXManageable.JMXCallback
container_, DEFAULT_FILTER_GROUP_OPERATOR, logger_, modifyProxiesLock_, offerManager_, pullServants_, pushServants_, servantLifecycle_, subscriptionManager_
Constructor and Description |
---|
SupplierAdminImpl(IEventChannel channelServant,
ORB orb,
POA poa,
Configuration config,
MessageFactory messageFactory,
OfferManager offerManager,
SubscriptionManager subscriptionManager) |
Modifier and Type | Method and Description |
---|---|
ProxyConsumer |
get_proxy_consumer(int id) |
String |
getMBeanType() |
MessageConsumer |
getMessageConsumer()
SupplierAdmin does not ever have a MessageConsumer.
|
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) |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, MyChannel, MyID, MyOperator
get_qos, set_qos, validate_qos
add_filter, get_all_filters, get_filter, remove_all_filters, remove_filter
public SupplierAdminImpl(IEventChannel channelServant, ORB orb, POA poa, Configuration config, MessageFactory messageFactory, OfferManager offerManager, SubscriptionManager subscriptionManager)
public Servant newServant()
newServant
in interface IServantLifecyle
public void offer_change(EventType[] added, EventType[] removed) throws InvalidEventType
offer_change
in interface NotifyPublishOperations
InvalidEventType
public int[] pull_consumers()
public int[] push_consumers()
public ProxyConsumer obtain_notification_pull_consumer(ClientType clientType, IntHolder intHolder) throws AdminLimitExceeded
AdminLimitExceeded
public ProxyConsumer get_proxy_consumer(int id) throws ProxyNotFound
ProxyNotFound
public ProxyConsumer obtain_notification_push_consumer(ClientType clienttype, IntHolder intHolder) throws AdminLimitExceeded
AdminLimitExceeded
public ProxyPushConsumer obtain_push_consumer()
obtain_push_consumer
in interface SupplierAdminOperations
public ProxyPullConsumer obtain_pull_consumer()
obtain_pull_consumer
in interface SupplierAdminOperations
public List getSubsequentFilterStages()
getSubsequentFilterStages
in interface FilterStageSource
public void setSubsequentFilterStageSource(FilterStageSource source)
setSubsequentFilterStageSource
in class AbstractSupplierAdmin
public MessageConsumer getMessageConsumer()
getMessageConsumer
in interface FilterStage
public boolean hasMessageConsumer()
hasMessageConsumer
in interface FilterStage
public boolean hasInterFilterGroupOperatorOR()
FilterStage
hasInterFilterGroupOperatorOR
in interface FilterStage
hasInterFilterGroupOperatorOR
in class AbstractAdmin
public String getMBeanType()
getMBeanType
in class AbstractAdmin
Copyright © 2017 JacORB. All rights reserved.