org.wso2.carbon.analytics.spark.event.internal

Class SparkEventingPublisherManagementService

java.lang.Object

org.wso2.carbon.event.processor.manager.core.EventPublisherManagementService

org.wso2.carbon.analytics.spark.event.internal.SparkEventingPublisherManagementService

All Implemented Interfaces:

org.wso2.carbon.event.processor.manager.core.Manager

public class SparkEventingPublisherManagementService
extends org.wso2.carbon.event.processor.manager.core.EventPublisherManagementService

EventPublisherManagementService implementation to check whether the current node is the active node or not.

Nested Class Summary

Nested classes/interfaces inherited from interface org.wso2.carbon.event.processor.manager.core.Manager

org.wso2.carbon.event.processor.manager.core.Manager.ManagerType

Constructor Summary

Constructors

Constructor and Description
SparkEventingPublisherManagementService()

Method Summary

Modifier and Type	Method and Description
boolean	isDrop()
void	setDrop(boolean drop)

Methods inherited from class org.wso2.carbon.event.processor.manager.core.EventPublisherManagementService

getType

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkEventingPublisherManagementService

public SparkEventingPublisherManagementService()

Method Detail

isDrop

public boolean isDrop()

Specified by:

isDrop in class org.wso2.carbon.event.processor.manager.core.EventPublisherManagementService

setDrop

public void setDrop(boolean drop)

Specified by:

setDrop in class org.wso2.carbon.event.processor.manager.core.EventPublisherManagementService