fr.esrf.TangoApi.events
Class EventConsumer

java.lang.Object
  org.omg.PortableServer.Servant
      org.omg.CosNotifyComm.StructuredPushConsumerPOA
          fr.esrf.TangoApi.events.EventConsumer

All Implemented Interfaces:

IEventConsumer, TangoConst, java.lang.Runnable, org.omg.CORBA.portable.InvokeHandler, org.omg.CosNotifyComm.NotifyPublishOperations, org.omg.CosNotifyComm.StructuredPushConsumerOperations

public class EventConsumer
extends org.omg.CosNotifyComm.StructuredPushConsumerPOA
implements TangoConst, java.lang.Runnable, IEventConsumer

Author:

pascal_verdier

Field Summary

Fields inherited from interface fr.esrf.TangoDs.TangoConst

ACCESS_READ, ACCESS_SERVICE, ACCESS_WRITE, ARCHIVE_EVENT, ATT_CONF_EVENT, Attr_AdmName, Attr_Description, Attr_Name, Attr_State, Attr_Status, Attr_Unknown, ATTRIBUTE, BY_CLASS, BY_DEVICE, BY_PROCESS, CHANGE_EVENT, COMMAND, CONTROL_SYSTEM, DATA_READY_EVENT, DEFAULT_LOCK_VALIDITY, eventNames, LOGGING_CONSOLE_TARGET, LOGGING_CONSOLE_TARGET_ID, LOGGING_DEBUG, LOGGING_DEF_RFT, LOGGING_DEVICE_TARGET, LOGGING_DEVICE_TARGET_ID, LOGGING_ERROR, LOGGING_FATAL, LOGGING_FILE_TARGET, LOGGING_FILE_TARGET_ID, LOGGING_INFO, LOGGING_LEVELS, LOGGING_MAX_RFT, LOGGING_MIN_RFT, LOGGING_OFF, LOGGING_SEPARATOR, LOGGING_UNKNOWN_TARGET_ID, LOGGING_WARN, NO_SYNC, NOT_STATELESS, NotANumber, Op_BlackBox, Op_Command, Op_Command_2, Op_Command_inout, Op_Command_inout_2, Op_Command_inout_history_2, Op_Command_list, Op_Command_list_2, Op_Get_Attr_Config, Op_Get_Attr_Config_2, Op_Info, Op_Ping, Op_Read_Attr, Op_Read_Attr_2, Op_Read_Attr_history_2, Op_Set_Attr_Config, Op_Unknown, Op_Write_Attr, PERIODIC_EVENT, QUALITY_EVENT, Req_Attribute, Req_Operation, Req_Unknown, SERVICE_PROP_NAME, STATELESS, Tango_AllAttr, Tango_AllAttr_3, Tango_AlrmValueNotSpec, Tango_AssocWritNotSpec, Tango_AttrDataFormatName, Tango_CLNT_TIMEOUT, Tango_CmdArgTypeName, Tango_CONST_DEV_STRING, Tango_DbObjName, Tango_DEFAULT_POLL_OLD_FACTOR, Tango_DEFAULT_TIMEOUT, Tango_DEFAULT_TIMEOUT_SEC, Tango_DefaultBlackBoxDepth, Tango_DefaultDocUrl, Tango_DefaultPollRingDepth, Tango_DefaultWritableProp, Tango_DELTA_T, Tango_DescNotSet, Tango_DescNotSpec, Tango_DEV_BOOLEAN, Tango_DEV_CHAR, Tango_DEV_DOUBLE, Tango_DEV_ENCODED, Tango_DEV_FLOAT, Tango_DEV_INT, Tango_DEV_LONG, Tango_DEV_LONG64, Tango_DEV_SHORT, Tango_DEV_STATE, Tango_DEV_STRING, Tango_DEV_UCHAR, Tango_DEV_ULONG, Tango_DEV_ULONG64, Tango_DEV_USHORT, Tango_DEV_VOID, Tango_DevStateName, Tango_DEVVAR_CHARARRAY, Tango_DEVVAR_DOUBLEARRAY, Tango_DEVVAR_DOUBLESTRINGARRAY, Tango_DEVVAR_FLOATARRAY, Tango_DEVVAR_LONG64ARRAY, Tango_DEVVAR_LONGARRAY, Tango_DEVVAR_LONGSTRINGARRAY, Tango_DEVVAR_SHORTARRAY, Tango_DEVVAR_STRINGARRAY, Tango_DEVVAR_ULONG64ARRAY, Tango_DEVVAR_ULONGARRAY, Tango_DEVVAR_USHORTARRAY, Tango_DevVersion, Tango_DISCARD_THRESHOLD, Tango_DispUnitNotSpec, Tango_DSDeviceDomain, Tango_EXPERT_ATTR, Tango_EXPERT_CMD, Tango_FormatNotSpec, Tango_InitialOutput, Tango_LabelNotSpec, TANGO_LOG_PATH, Tango_MAX_TRANSFER_SIZE, Tango_MaxServerNameLength, Tango_MIN_POLL_PERIOD, Tango_OPERATOR_ATTR, Tango_OPERATOR_CMD, Tango_POLL_ADD_OBJ, Tango_POLL_ATTR, Tango_POLL_CMD, Tango_POLL_REM_DEV, Tango_POLL_REM_OBJ, Tango_POLL_START, Tango_POLL_STOP, Tango_POLL_UPD_PERIOD, Tango_PollAttribute, Tango_PollCommand, Tango_QualityName, Tango_REL_1, Tango_REL_2, Tango_ResNotDefined, Tango_StdUnitNotSpec, Tango_SysProperty, Tango_TG_IMP_MINOR_DEVFAILED, Tango_TG_IMP_MINOR_NON_DEVFAILED, Tango_TG_IMP_MINOR_TO, Tango_TgLibVers, Tango_UnitNotSpec, USER_EVENT

Method Summary

void	connect(DeviceProxy device_proxy)
static EventConsumer	create() Creates a new instance of EventConsumer
void	disconnect_structured_push_consumer()
void	offer_change(org.omg.CosNotification.EventType[] added, org.omg.CosNotification.EventType[] removed)
void	push_structured_event(org.omg.CosNotification.StructuredEvent notification)
void	run() activate POA and go into endless lopp waiting for events to be pushed
int	subscribe_event(DeviceProxy device, java.lang.String attribute, int event, CallBack callback, int max_size, java.lang.String[] filters, boolean stateless)
int	subscribe_event(DeviceProxy device, java.lang.String attribute, int event, CallBack callback, java.lang.String[] filters, boolean stateless)
int	subscribe_event(DeviceProxy device, java.lang.String attribute, int event, int max_size, java.lang.String[] filters, boolean stateless)
void	unsubscribe_event(int event_id)
void	updateDatabaseObject() Creates a new instance of EventConsumer

Methods inherited from class org.omg.CosNotifyComm.StructuredPushConsumerPOA

_all_interfaces, _invoke, _this, _this

Methods inherited from class org.omg.PortableServer.Servant

_default_POA, _get_delegate, _get_interface_def, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object

Methods inherited from class java.lang.Object

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

Method Detail

create

public static EventConsumer create()
                            throws DevFailed

Creates a new instance of EventConsumer

Throws:

DevFailed

updateDatabaseObject

public void updateDatabaseObject()
                          throws DevFailed

Description copied from interface: IEventConsumer

Creates a new instance of EventConsumer

Specified by:

updateDatabaseObject in interface IEventConsumer

Throws:

DevFailed

disconnect_structured_push_consumer

public void disconnect_structured_push_consumer()

Specified by:

disconnect_structured_push_consumer in interface IEventConsumer

Specified by:

disconnect_structured_push_consumer in interface org.omg.CosNotifyComm.StructuredPushConsumerOperations

offer_change

public void offer_change(org.omg.CosNotification.EventType[] added,
                         org.omg.CosNotification.EventType[] removed)
                  throws org.omg.CosNotifyComm.InvalidEventType

Specified by:

offer_change in interface org.omg.CosNotifyComm.NotifyPublishOperations

Throws:

org.omg.CosNotifyComm.InvalidEventType

push_structured_event

public void push_structured_event(org.omg.CosNotification.StructuredEvent notification)

Specified by:

push_structured_event in interface org.omg.CosNotifyComm.StructuredPushConsumerOperations

subscribe_event

public int subscribe_event(DeviceProxy device,
                           java.lang.String attribute,
                           int event,
                           CallBack callback,
                           java.lang.String[] filters,
                           boolean stateless)
                    throws DevFailed

Specified by:

subscribe_event in interface IEventConsumer

Throws:

DevFailed

subscribe_event

public int subscribe_event(DeviceProxy device,
                           java.lang.String attribute,
                           int event,
                           int max_size,
                           java.lang.String[] filters,
                           boolean stateless)
                    throws DevFailed

Specified by:

subscribe_event in interface IEventConsumer

Throws:

DevFailed

subscribe_event

public int subscribe_event(DeviceProxy device,
                           java.lang.String attribute,
                           int event,
                           CallBack callback,
                           int max_size,
                           java.lang.String[] filters,
                           boolean stateless)
                    throws DevFailed

Specified by:

subscribe_event in interface IEventConsumer

Throws:

DevFailed

unsubscribe_event

public void unsubscribe_event(int event_id)
                       throws DevFailed

Specified by:

unsubscribe_event in interface IEventConsumer

Throws:

DevFailed

connect

public void connect(DeviceProxy device_proxy)
             throws DevFailed

Specified by:

connect in interface IEventConsumer

Throws:

DevFailed

run

public void run()

activate POA and go into endless lopp waiting for events to be pushed

Specified by:

run in interface IEventConsumer

Specified by:

run in interface java.lang.Runnable