org.wso2.analytics.apim.integration.common.clients

Class DataPublisherClient

java.lang.Object

org.wso2.analytics.apim.integration.common.clients.DataPublisherClient

public class DataPublisherClient
extends Object

Constructor Summary

Constructors

Constructor and Description
DataPublisherClient()
DataPublisherClient(String url)

Method Summary

Methods

Modifier and Type	Method and Description
void	publish(String streamName, String version, org.wso2.carbon.databridge.commons.Event event)
void	publish(String streamName, String version, List<org.wso2.carbon.databridge.commons.Event> events)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

DataPublisherClient

public DataPublisherClient(String url)
                    throws Exception

Throws:

Exception

DataPublisherClient

public DataPublisherClient()
                    throws Exception

Throws:

Exception

Method Detail

shutdown

public void shutdown()
              throws org.wso2.carbon.databridge.agent.exception.DataEndpointException

Throws:

org.wso2.carbon.databridge.agent.exception.DataEndpointException

publish

public void publish(String streamName,
           String version,
           List<org.wso2.carbon.databridge.commons.Event> events)
             throws org.wso2.carbon.databridge.agent.exception.DataEndpointException

Throws:

org.wso2.carbon.databridge.agent.exception.DataEndpointException

publish

public void publish(String streamName,
           String version,
           org.wso2.carbon.databridge.commons.Event event)
             throws org.wso2.carbon.databridge.agent.exception.DataEndpointException

Throws:

org.wso2.carbon.databridge.agent.exception.DataEndpointException