alma.acs.nsstatistics

Class AdminConsumer

java.lang.Object

alma.acs.nc.AcsEventSubscriberImplBase<T>

alma.acs.nc.NCSubscriber<org.omg.CORBA.portable.IDLEntity>

alma.acs.nsstatistics.AdminConsumer

All Implemented Interfaces:

AcsEventSubscriber<org.omg.CORBA.portable.IDLEntity>, ReconnectableParticipant, AcsScxmlActionExecutor<EventSubscriberAction>

public class AdminConsumer
extends NCSubscriber<org.omg.CORBA.portable.IDLEntity>

Nested Class Summary

Nested classes/interfaces inherited from class alma.acs.nc.NCSubscriber

NCSubscriber.AdminReuseCompatibilityHack

Nested classes/interfaces inherited from interface alma.acs.nc.AcsEventSubscriber

AcsEventSubscriber.Callback<U>, AcsEventSubscriber.GenericCallback

Field Summary

Fields inherited from class alma.acs.nc.NCSubscriber

anyAide, autoreconnect, channel, channelName, channelNotifyServiceDomainName, handlerTimeoutMap, helper, PROXIES_PER_ADMIN, proxySupplier, sharedConsumerAdmin, subscriptionsFilters

Fields inherited from class alma.acs.nc.AcsEventSubscriberImplBase

clientName, EVENT_QUEUE_CAPACITY, eventType, genericReceiver, logger, processTimeLogRepeatGuard, receivers, services, stateMachine, stateMachineSignalDispatcher

Constructor Summary

Constructors

Constructor and Description
AdminConsumer(java.lang.String channelName, ContainerServicesBase services, org.omg.CosNaming.NamingContext namingService, java.util.concurrent.BlockingQueue<EventData> equeue)

Method Summary

Modifier and Type	Method and Description
static boolean	getPrintDetails()
static long	getTotalEventCount()
boolean	push_structured_event_called(StructuredEvent evt) Users can override this method to get notified of raw events, for additional statistics, to handle event data given as a sequence of IDL structs (exceptional case in acssamp), or for DynAny access (eventGUI).
static void	setPrintDetails(boolean printDetails)

Methods inherited from class alma.acs.nc.NCSubscriber

addFilter, createConnectionAction, createEnvironmentAction, destroyConnectionAction, destroyEnvironmentAction, disconnect_structured_push_consumer, getFilterLanguage, getMaxProcessTimeSeconds, getNotificationFactoryName, isTraceEventsEnabled, logEventProcessingTimeExceeded, logEventProcessingTooSlowForEventRate, logEventReceiveHandlerException, logNoEventReceiver, logQueueShutdownError, notifyFirstSubscription, notifyNoSubscription, notifySubscriptionRemoved, offer_change, push_structured_event, reconnect, resumeAction, setAutoreconnect, setConnectionCheckerFreq, setEventReceptionTimeout, suspendAction

Methods inherited from class alma.acs.nc.AcsEventSubscriberImplBase

addGenericSubscription, addSubscription, disconnect, execute, getLifecycleState, getNumberOfReceivers, hasGenericReceiver, isDisconnected, isSuspended, processEvent, processEventAsync, removeGenericSubscription, removeSubscription, resume, startReceivingEvents, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AdminConsumer

public AdminConsumer(java.lang.String channelName,
                     ContainerServicesBase services,
                     org.omg.CosNaming.NamingContext namingService,
                     java.util.concurrent.BlockingQueue<EventData> equeue)
              throws AcsJException

Throws:

AcsJException

Method Detail

push_structured_event_called

public boolean push_structured_event_called(StructuredEvent evt)

Description copied from class: NCSubscriber

Users can override this method to get notified of raw events, for additional statistics, to handle event data given as a sequence of IDL structs (exceptional case in acssamp), or for DynAny access (eventGUI).

Usually this method should not be overridden.

Overrides:

push_structured_event_called in class NCSubscriber<org.omg.CORBA.portable.IDLEntity>

Returns:

true if normal event processing should continue, false if NCSubscriber should not process this event.

getPrintDetails

public static boolean getPrintDetails()

setPrintDetails

public static void setPrintDetails(boolean printDetails)

getTotalEventCount

public static long getTotalEventCount()