public class ConnectorPublisher extends PublisherBase
configContext, publisher
Constructor and Description |
---|
ConnectorPublisher() |
Modifier and Type | Method and Description |
---|---|
protected void |
addMetaDataAttributes(org.wso2.carbon.databridge.commons.StreamDefinition definition)
Adds meta data attributes to the stream definition.
|
protected void |
addPayloadDataAttributes(org.wso2.carbon.databridge.commons.StreamDefinition definition)
Adds the Payload data attributes to the stream definition.
|
protected String |
getDataStreamName()
get the data stream name for data stream.
|
void |
publish(ConnectorMonitoringEvent e)
Publish connector monitoring event.
|
createStreamDefinition, isPublishable, mapNull, mapNull, mapNull, publish
public ConnectorPublisher() throws BAMPublisherConfigurationException
protected void addPayloadDataAttributes(org.wso2.carbon.databridge.commons.StreamDefinition definition)
PublisherBase
addPayloadDataAttributes
in class PublisherBase
definition
- the Stream definitionprotected void addMetaDataAttributes(org.wso2.carbon.databridge.commons.StreamDefinition definition)
PublisherBase
addMetaDataAttributes
in class PublisherBase
definition
- the Stream definitionprotected String getDataStreamName()
PublisherBase
getDataStreamName
in class PublisherBase
public void publish(ConnectorMonitoringEvent e) throws MonitoringPublisherException
e
- the connector monitoring event.MonitoringPublisherException
Copyright © 2019 WSO2. All rights reserved.