alma.acs.nsstatistics

Class EventModel

java.lang.Object

alma.acs.nsstatistics.EventModel

public class EventModel
extends java.lang.Object

Author:

jschwarz, hsommer $Id: EventModel.java,v 1.39 2013/02/22 15:36:44 hsommer Exp $

Method Summary

Modifier and Type	Method and Description
void	addChannelSubscription(ChannelData channelData) Called from SubscribeNCHandler.
void	closeAllConsumers()
void	closeArchiveConsumer() TODO: Call from mouse menu handler for the archiving NC
void	closeSelectedConsumer(ChannelData channelData)
java.util.concurrent.BlockingQueue<ArchiveEventData>	getArchQueue()
boolean	getChannelStatistics() Called by NotifyServiceUpdateJob (single/periodic refresh of service summary / channel tree).
ContainerServices	getContainerServices()
org.omg.DynamicAny.DynAnyFactory	getDynAnyFactory()
java.util.concurrent.BlockingQueue<EventData>	getEventQueue() Gets the event queue, for read and write access.
static EventModel	getInstance()
java.util.logging.Logger	getLogger()
NotifyServices	getNotifyServicesRoot()
boolean	isSubscribed(ChannelData channelData) Note that this method may be called very frequently, to determine whether menu items are selected/enabled, thus it must be fast.
boolean	reconnectNamingService()
protected EventChannel	resolveNotificationChannel(java.lang.String bindingName) Resolves a notification channel in the naming service.
void	tearDown()

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static EventModel getInstance()
                              throws java.lang.Throwable

Throws:

java.lang.Throwable

getLogger

public java.util.logging.Logger getLogger()

getEventQueue

public java.util.concurrent.BlockingQueue<EventData> getEventQueue()

Gets the event queue, for read and write access.

getArchQueue

public java.util.concurrent.BlockingQueue<ArchiveEventData> getArchQueue()

reconnectNamingService

public boolean reconnectNamingService()

getNotifyServicesRoot

public NotifyServices getNotifyServicesRoot()

getChannelStatistics

public boolean getChannelStatistics()

Called by NotifyServiceUpdateJob (single/periodic refresh of service summary / channel tree).

resolveNotificationChannel

protected EventChannel resolveNotificationChannel(java.lang.String bindingName)
                                           throws AcsJException

Resolves a notification channel in the naming service.

Parameters:

bindingName - Name of the event channel and trailing domain name, as the NC is registered with the CORBA Naming Service

Returns:

Reference to the event channel specified by channelName.

Throws:

AcsJException - Standard ACS Java exception.

getContainerServices

public ContainerServices getContainerServices()

addChannelSubscription

public void addChannelSubscription(ChannelData channelData)
                            throws AcsJException

Called from SubscribeNCHandler.

Throws:

AcsJException

getDynAnyFactory

public org.omg.DynamicAny.DynAnyFactory getDynAnyFactory()

closeSelectedConsumer

public void closeSelectedConsumer(ChannelData channelData)

closeAllConsumers

public void closeAllConsumers()

closeArchiveConsumer

public void closeArchiveConsumer()

TODO: Call from mouse menu handler for the archiving NC

tearDown

public void tearDown()

isSubscribed

public boolean isSubscribed(ChannelData channelData)

Note that this method may be called very frequently, to determine whether menu items are selected/enabled, thus it must be fast.