org.wso2.carbon.device.mgt.analytics.data.publisher.service

Class EventsPublisherServiceImpl

java.lang.Object

org.wso2.carbon.device.mgt.analytics.data.publisher.service.EventsPublisherServiceImpl

All Implemented Interfaces:

EventsPublisherService

public class EventsPublisherServiceImpl
extends Object
implements EventsPublisherService

This is the implementation of Osgi Service which can be used to publish and retireved event/records.

Constructor Summary

Constructors

Constructor and Description
EventsPublisherServiceImpl()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	publishEvent(String streamName, String version, Object[] metaDataArray, Object[] correlationDataArray, Object[] payloadDataArray) This is used to publish an event to DAS.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventsPublisherServiceImpl

public EventsPublisherServiceImpl()

Method Detail

publishEvent

public boolean publishEvent(String streamName,
                   String version,
                   Object[] metaDataArray,
                   Object[] correlationDataArray,
                   Object[] payloadDataArray)
                     throws DataPublisherConfigurationException

Description copied from interface: EventsPublisherService

This is used to publish an event to DAS.

Specified by:

publishEvent in interface EventsPublisherService

Parameters:

streamName - is the name of the stream that the data needs to pushed

version - is the version of the stream

metaDataArray - - meta data that needs to pushed

correlationDataArray - - correlation data that needs to be pushed

payloadDataArray - - payload data that needs to be pushed

Returns:

Throws:

DataPublisherConfigurationException