alma.alarmsystem.clients

Class SourceClient

java.lang.Object

alma.alarmsystem.clients.SourceClient

All Implemented Interfaces:

AcsEventSubscriber.Callback<ACSJMSMessageEntity>

public class SourceClient
extends java.lang.Object
implements AcsEventSubscriber.Callback<ACSJMSMessageEntity>

Constructor Summary

Constructors

Constructor and Description
SourceClient(ContainerServices svc)

Method Summary

Modifier and Type	Method and Description
void	addAlarmListener(SourceListener newListener) Add a listener for the alarms.
void	close() Frees all the resources
void	connect() Connect to the sources NC
protected void	finalize() Ensure that the resources have been released before destroying the object
java.lang.Class<ACSJMSMessageEntity>	getEventType() This method is needed for adding event-specific subscriptions and for the type-safety of this API (based on java generics), and should be implemented like
void	receive(ACSJMSMessageEntity msg, EventDescription eventDescrip) The method receives all the messages published in the NC For each message received it check if its content is right i.e.
boolean	removeListener(SourceListener listener) Remove a listener from the list of listeners to be notified when a new alarm is received

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceClient

public SourceClient(ContainerServices svc)
             throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

connect

public void connect()
             throws java.lang.Exception

Connect to the sources NC

Throws:

java.lang.Exception

receive

public void receive(ACSJMSMessageEntity msg,
                    EventDescription eventDescrip)

The method receives all the messages published in the NC For each message received it check if its content is right i.e. the name of the class, the member and the code contains the number of the message in the sequence. In this way it also checks if the messages are received in the same order they were sent. The method also checks if all the messages have been received and prints a message if receives more messages then the messages pushed

Specified by:

receive in interface AcsEventSubscriber.Callback<ACSJMSMessageEntity>

Parameters:

msg - The message received from the NC

eventDescrip - Event meta data.

See Also:

alma.acs.nc.Consumer

getEventType

public java.lang.Class<ACSJMSMessageEntity> getEventType()

Description copied from interface: AcsEventSubscriber.Callback

This method is needed for adding event-specific subscriptions and for the type-safety of this API (based on java generics), and should be implemented like

 public Class<MyEvent> getEventType() {
     return MyEvent.class;
 }
 

Specified by:

getEventType in interface AcsEventSubscriber.Callback<ACSJMSMessageEntity>

addAlarmListener

public void addAlarmListener(SourceListener newListener)

Add a listener for the alarms. Add the listeners to the set of listeners to be notified when a new alarms is received from the categories.

Parameters:

newListener - The listener for alarms from categories

removeListener

public boolean removeListener(SourceListener listener)

Remove a listener from the list of listeners to be notified when a new alarm is received

Parameters:

listener - The not null listener to remove

Returns:

true if the list of listeners contained the specified listener

close

public void close()

Frees all the resources

finalize

protected void finalize()
                 throws java.lang.Throwable

Ensure that the resources have been released before destroying the object

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable