alma.acs.alarm.gui.senderpanel

Class ParallelAlarmSender

java.lang.Object

alma.acs.alarm.gui.senderpanel.ParallelAlarmSender

All Implemented Interfaces:

java.lang.Runnable

public class ParallelAlarmSender
extends java.lang.Object
implements java.lang.Runnable

Sends alarms in parallel by sending each alarm to a different sender.

There is upper limit in the number of alarms sent each second in maxNumberOfAlarmsPerSecond and implemented by a ArrayBlockingQueue bounded to maxNumberOfAlarmsPerSecond.

The alarms are sent by the thread that loops once per second (aprox) and empties the queue.

The ArrayBlockingQueue control the max number of alarms queued and ready to be sent in the next second. However it does not prevent to add new alarms while the thread is sending alarms (i.e. the thread gets a alarm out of the queue so a new room is available and the send pushes a new alarm).
To be sure that the number of alarms sent each second is at most maxNumberOfAlarmsPerSecond, the thread counts the number of alarms it get out of the queue at each iteration.

Since:

ACS 11.0

Author:

acaproni

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ParallelAlarmSender.AlarmToSend An alarm to send.

Constructor Summary

Constructors

Constructor and Description
ParallelAlarmSender(ContainerServices svcs, int numOfSenders, long timeBetweenAlarms) Constructor

Method Summary

Modifier and Type	Method and Description
void	addListener(AlarmSentListener listener) Add a listener
void	close() Close the sender and the threads
void	removeListener(AlarmSentListener listener) Remove a listener
void	run()
void	send(SenderPanelUtils.Triplet triplet, SenderPanelUtils.AlarmDescriptorType descriptor, java.util.Properties props) Send the specified alarm to on of the AlarmSender to be sent to the service.
void	start() Start the threads.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelAlarmSender

public ParallelAlarmSender(ContainerServices svcs,
                           int numOfSenders,
                           long timeBetweenAlarms)
                    throws ACSASFactoryNotInitedEx,
                           SourceCreationErrorEx

Constructor

Parameters:

svcs - The ContainerServices

numOfSenders - The number of AlarmSender to run in parallel

timeBetweenAlarms - The time between 2 send by each AlarmSender

Throws:

SourceCreationErrorEx

ACSASFactoryNotInitedEx

Method Detail

start

public void start()

Start the threads.

close

public void close()

Close the sender and the threads

addListener

public void addListener(AlarmSentListener listener)

Add a listener

Parameters:

listener - The listener to notify when an alarm has been sent

removeListener

public void removeListener(AlarmSentListener listener)

Remove a listener

Parameters:

listener - The listener to notify when an alarm has been sent

send

public void send(SenderPanelUtils.Triplet triplet,
                 SenderPanelUtils.AlarmDescriptorType descriptor,
                 java.util.Properties props)
          throws java.lang.InterruptedException

Send the specified alarm to on of the AlarmSender to be sent to the service.

This method return immediately: each alarm is queued and sent later on by the thread.

If the queue of alarms contains more then , the caller waits until the thread frees the queue.

Parameters:

triplet - The triplet in the form FF,FM,FC

The - descriptor

props - The user properties

Throws:

java.lang.InterruptedException - If interrupted while awaiting to put the alarm in the queue

See Also:

AlarmSender#send(alma.acs.alarm.gui.senderpanel.SenderPanelUtils.Triplet, alma.acs.alarm.gui.senderpanel.SenderPanelUtils.AlarmDescriptorType, java.util.Properties)

run

public void run()

Specified by:

run in interface java.lang.Runnable