Data Subscription SDK Reference¶

For Real-time Data Subscription¶

Subscription Client Class: EosClient¶

Function	Description	Parameter	Response
EosClient(String host, Integer port, String accessKey, String secretKey)	The constructor function.	host: The subscription service host. port accessKey secretKey: The secret of the accessKey.	EosClient instance
getDataService()	Get the basic alert data subscription service instance.	N/A	IDataService instance
getAdvancedAlertService()	Get the advanced alert data subscription service instance.	无	IAdvancedAlertService instance

Real-time Data Subscription Service Class: IDataService¶

Function

Description

Parameter

Response

subscribe(IDataHandler dataHandler, String subId)

Get the subscribed real-time data of subID (this subscription client belongs to the default consumer group).

dataHandler: The data processing object.
subId: The subscription ID.

null

subscribe(IDataHandler dataHandler, String subId, String consumerGroup)

Get the subscribed real-time data of the subID and define the consumer group.

The “consumerGroup” parameter specifies the consumer group of the current client.
The clients in a same group can process subscribed data together, which improves the capability of data processing.
A message can be consumed by only 1 client in a consumer group.

dataHandler: The real-time data processing object.
subId: The subscription ID.
consumerGroup: The consumer group (if null is specified, the system uses “DefaultConsumerGroup” by default. If you specify a value manually, avoid using “DefaultConsumerGroup” as the “consumerGroup” value).

null

Real-time Data Handling Class: IDataHandler¶

Function	Description	Parameter	Response
dataRead(StreamMessage message)	Read the subscribed real-time data.	message: The subscribed real-time data.	null

For Alert Data Subscription¶

Subscription Client Class: EosClient¶

Function	Description	Parameter	Response
EosClient(String host, Integer port, String accessKey, String secretKey)	The constructor function.	host: The subscription service host. port accessKey secretKey: The secret of the accessKey.	EosClient instance
getAlertService()	Get alert data subscription service instance.	N/A	IAlertService instance

Basic Alert Data Subscription Service Class: IAlertService¶

Function

Description

Parameter

Response

subscribe(IAlertHandler alertHandler, String subId)

Get the subscribed alert data of the subID (this subscription client belongs to the default consumer group).

alertHandler: The data processing object.
subId: The subscription ID.

null

subscribe(IAlertHandler alertHandler, String subId, String consumerGroup)

Get the subscribed alert data of the subID and define the consumer group.

The “consumerGroup” parameter specifies the consumer group of the current client.
The clients in a same group can process subscribed data together, which improves the capability of data processing.
A message can be consumed by only 1 client in a consumer group.

alertHandler: The alert data processing object.
subId: The subscription ID.
consumerGroup: The consumer group (if null is specified, the system uses “DefaultConsumerGroup” by default. If you specify a value manually, avoid using “DefaultConsumerGroup” as the “consumerGroup” value).

null

Basic Subscription Data Handling Class: IAlertHandler¶

Function	Description	Parameter	Response
alertRead(Alert alert)	Read the subscribed alert data	alert: The subscribed alert data.	null

Advanced Alert Data Subscription Service Class: IAdvancedAlertService¶

Function

Description

Parameter

Response

subscribe(IAdvancedAlertHandler alertHandler, String subId)

Get the subscribed alert data of the subID (this subscription client belongs to the default consumer group).

AdvancedAlertHandler: The data processing object.
subId: The subscription ID.

null

subscribe(IAdvancedAlertHandler alertHandler, String subId, String consumerGroup)

Get the subscribed alert data of the subID and define the consumer group.

The “consumerGroup” parameter specifies the consumer group of the current client.
The clients in a same group can process subscribed data together, which improves the capability of data processing.
A message can be consumed by only 1 client in a consumer group.

AdvancedAlertHandler: The alert data processing object.
subId: The subscription ID.
consumerGroup: The consumer group (if null is specified, the system uses “DefaultConsumerGroup” by default. If you specify a value manually, avoid using “DefaultConsumerGroup” as the “consumerGroup” value).

null

Advanced Subscription Data Handling Class: IAdvancedAlertHandler¶

Function	Description	Parameter	Response
AdvancedAlertRead(Alert alert)	Read the subscribed advanced alert data	alert: The subscribed advanced alert data.	null

For Offline Data Subscription (EnOS Cloud only)¶

Subscription Client Class: EosClient¶

Function	Description	Parameter	Response
EosClient(String host, Integer port, String accessKey, String secretKey)	The constructor function.	host: The subscription service host. port accessKey secretKey: The secret of the accessKey.	EosClient instance
getOfflineDataService()	Get the offline data subscription service instance.	N/A	IDataService instance

Offline Data Subscription Service Class: IDataService¶

Function

Description

Parameter

Response

subscribe(IDataHandler dataHandler, String subId)

Get the subscribed offline data of the subID (this subscription client belongs to the default consumer group).

dataHandler: The data processing object.
subId: The subscription ID.

null

subscribe(IDataHandler dataHandler, String subId, String consumerGroup)

Get subscribed offline data of subID and define the consumer group.

The “consumerGroup” parameter specifies the consumer group of the current client.
The clients in a same group can process subscribed data together, which improves the capability of data processing.
A message can be consumed by only 1 client in a consumer group.

dataHandler: The offline data processing object.
subId: The subscription ID.
consumerGroup: The consumer group (if null is specified, the system uses “DefaultConsumerGroup” by default. If you specify a value manually, avoid using “DefaultConsumerGroup” as the “consumerGroup” value).

null

Offline Data Handling Class: IDataHandler¶

Function	Description	Parameter	Response
dataRead(StreamMessage message)	Read the subscribed offline data.	message: The subscribed offline data.	null

For Event Data Subscription¶

Subscription Client Class: EosClient¶

Function	Description	Parameter	Response
EosClient(String host, Integer port, String accessKey, String secretKey)	The constructor function.	host: The subscription service host. port accessKey secretKey: The secret of the accessKey.	EosClient instance
getEventService()	Get event data subscription service instance.	N/A	IEventService instance

Event Data Subscription Service Class: IEventService¶

Function

Description

Parameter

Response

subscribe(IEventHandler eventHandler, String subId)

Get the subscribed event data of the subID (this subscription client belongs to the default consumer group).

eventHandler: The data processing object.
subId: The subscription ID.

null

subscribe(IEventHandler eventHandler, String subId, String consumerGroup)

Get the subscribed event data of the subID and define the consumer group.

The “consumerGroup” parameter specifies the consumer group of the current client.
The clients in a same group can process subscribed data together, which improves the capability of data processing.
A message can be consumed by only 1 client in a consumer group.

eventHandler: The event data processing object.
subId: The subscription ID.
consumerGroup: The consumer group (if null is specified, the system uses “DefaultConsumerGroup” by default. If you specify a value manually, avoid using “DefaultConsumerGroup” as the “consumerGroup” value).

null

Event Data Handling Class: IEventHandler¶

Function	Description	Parameter	Response
eventRead(Event event)	Read the subscribed event data.	event: The subscribed event data.	null

For Device Event Report Subscription (EnOS Cloud only)¶

Subscription Client Class: EosClient¶

Function	Description	Parameter	Response
EosClient(String host, Integer port, String accessKey, String secretKey)	The constructor function.	host: The subscription service host. port: The subscription service port. accessKey: accessKey secretKey: The secret of the accessKey.	EosClient instance
getReportService()	Get the device event report service instance.	N/A	IReportService instance

Device Event Report Service Class: IReportService¶

Function

Description

Parameter

Response

subscribe(IReportHandler reportHandler, String subId)

Get the subscribed device event report of subID (this subscription client belongs to the default consumer group).

dataHandler: The device event report processing object.
subId: The cloud-configured subId.

null

subscribe(IReportHandler reportHandler, String subId, String consumerGroup)

Get the subscribed device event report of the subID and define the consumer group.

The “consumerGroup” parameter specifies the consumer group of the current client.
The clients in a same group can process subscribed data together, which improves the capability of data processing.
A message can be consumed by only 1 client in a consumer group.

reportHandler: The device event report processing object.
subId: The cloud-configured subId.
consumerGroup: The consumer group (if null is specified, the system uses “DefaultConsumerGroup” by default. If you specify a value manually, avoid using “DefaultConsumerGroup” as the “consumerGroup” value).

null

Device Event Report Handling Class: IReportHandler¶

Function	Description	Parameter	Response
eventRead(Report message)	Read the subscribed device event report.	message: The subscribed device event report.	null