acs.benchmark.nc.comp

Class CorbaNotifyBaseImpl<T>

java.lang.Object

alma.acs.component.ComponentImplBase

acs.benchmark.nc.comp.CorbaNotifyBaseImpl<T>

Type Parameters:

T - AcsEventSubscriber or AcsEventPublisher. Allows sharing code between the two subclasses.

All Implemented Interfaces:

ComponentLifecycle

Direct Known Subclasses:

CorbaNotifyConsumerImpl, CorbaNotifySupplierImpl

public abstract class CorbaNotifyBaseImpl<T>
extends ComponentImplBase

Author:

hsommer

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	cancel Flag set by interrupt method
protected java.util.concurrent.atomic.AtomicInteger	logMultiplesOfEventCount value <= 0: No event logging (default) 1: log every event value > 1: log every Nth event
protected java.util.Map<java.lang.String,T>	subsOrPubs The component stores here all NCs it is connected to, together with the publisher or subscriber object it uses.

Fields inherited from class alma.acs.component.ComponentImplBase

m_containerServices, m_instanceName, m_logger

Constructor Summary

Constructors

Constructor and Description
CorbaNotifyBaseImpl()

Method Summary

Modifier and Type	Method and Description
protected abstract T	createNcParticipant(java.lang.String ncName) Encapsulates difference between AcsEventSubscriber and AcsEventPublisher.
protected abstract void	disconnectNcParticipant(T subOrPub) Encapsulates difference between AcsEventSubscriber and AcsEventPublisher.
void	interrupt()
void	ncConnect(java.lang.String[] ncNames) Subscriber or publisher connection.
void	ncDisconnect()
void	setEventLogging(int multiplesOfEventCount)

Methods inherited from class alma.acs.component.ComponentImplBase

aboutToAbort, cleanUp, componentState, execute, initialize, name

Methods inherited from class java.lang.Object

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

Field Detail

subsOrPubs

protected final java.util.Map<java.lang.String,T> subsOrPubs

The component stores here all NCs it is connected to, together with the publisher or subscriber object it uses. key = NC name, value = publisher or subscriber object

cancel

protected volatile boolean cancel

Flag set by interrupt method

logMultiplesOfEventCount

protected final java.util.concurrent.atomic.AtomicInteger logMultiplesOfEventCount

• value <= 0: No event logging (default)
• 1: log every event
• value > 1: log every Nth event

See Also:

setEventLogging(int)

Constructor Detail

CorbaNotifyBaseImpl

public CorbaNotifyBaseImpl()

Method Detail

createNcParticipant

protected abstract T createNcParticipant(java.lang.String ncName)
                                  throws AcsJContainerServicesEx

Encapsulates difference between AcsEventSubscriber and AcsEventPublisher.

Throws:

AcsJContainerServicesEx

disconnectNcParticipant

protected abstract void disconnectNcParticipant(T subOrPub)
                                         throws AcsJIllegalStateEventEx,
                                                AcsJCouldntPerformActionEx

Encapsulates difference between AcsEventSubscriber and AcsEventPublisher.

Throws:

AcsJIllegalStateEventEx

AcsJCouldntPerformActionEx

ncConnect

public void ncConnect(java.lang.String[] ncNames)
               throws CouldntPerformActionEx

Subscriber or publisher connection.

Throws:

CouldntPerformActionEx

ncDisconnect

public void ncDisconnect()
                  throws CouldntPerformActionEx

Throws:

CouldntPerformActionEx

interrupt

public void interrupt()

setEventLogging

public void setEventLogging(int multiplesOfEventCount)