alma.demo.EventConsumerImpl

Class EventConsumerImpl

java.lang.Object

alma.acs.component.ComponentImplBase

alma.demo.EventConsumerImpl.EventConsumerImpl

All Implemented Interfaces:

ComponentLifecycle, AcsEventSubscriber.Callback<temperatureDataBlockEvent>

public class EventConsumerImpl
extends ComponentImplBase
implements AcsEventSubscriber.Callback<temperatureDataBlockEvent>

Implementation class of the ConsumerComp IDL interface.

Author:

dfugate

Field Summary

Fields inherited from class alma.acs.component.ComponentImplBase

m_containerServices, m_instanceName, m_logger

Constructor Summary

Constructors

Constructor and Description
EventConsumerImpl()

Method Summary

Modifier and Type	Method and Description
void	cleanUp() Disconnects the Consumer
java.lang.Class<temperatureDataBlockEvent>	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	initialize(ContainerServices containerServices) Sets up the AcsEventSubscriber.
void	receive(temperatureDataBlockEvent joe, EventDescription eventDescrip) This method will be called whenever a temperatureDataBlockEvent becomes available on the channel.

Methods inherited from class alma.acs.component.ComponentImplBase

aboutToAbort, componentState, execute, name

Methods inherited from class java.lang.Object

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

Constructor Detail

EventConsumerImpl

public EventConsumerImpl()

Method Detail

initialize

public void initialize(ContainerServices containerServices)
                throws ComponentLifecycleException

Sets up the AcsEventSubscriber.

Specified by:

initialize in interface ComponentLifecycle

Overrides:

initialize in class ComponentImplBase

Parameters:

containerServices - callback object for services provided by the container

Throws:

ComponentLifecycleException

See Also:

ComponentLifecycle.initialize(ContainerServices)

receive

public void receive(temperatureDataBlockEvent joe,
                    EventDescription eventDescrip)

This method will be called whenever a temperatureDataBlockEvent becomes available on the channel.

Specified by:

receive in interface AcsEventSubscriber.Callback<temperatureDataBlockEvent>

Parameters:

joe - The event data, e.g. an IDL-defined struct.

eventDescrip - Event meta data.

getEventType

public java.lang.Class<temperatureDataBlockEvent> 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<temperatureDataBlockEvent>

cleanUp

public void cleanUp()
             throws AcsJComponentCleanUpEx

Disconnects the Consumer

Specified by:

cleanUp in interface ComponentLifecycle

Overrides:

cleanUp in class ComponentImplBase

Throws:

AcsJComponentCleanUpEx