- DATA_AGENT_CONF_FILE_NAME - Static variable in class org.wso2.carbon.databridge.agent.util.DataEndpointConstants
-
- DATA_AGENT_CONF_FILE_PATH - Static variable in class org.wso2.carbon.databridge.agent.util.DataEndpointConstants
-
- DataAgentsConfiguration - Class in org.wso2.carbon.databridge.agent.conf
-
Wrapper class for the Agent Configuration which are loaded from data-agent-config.xml.
- DataAgentsConfiguration() - Constructor for class org.wso2.carbon.databridge.agent.conf.DataAgentsConfiguration
-
- DataEndpoint - Class in org.wso2.carbon.databridge.agent.endpoint
-
Abstract class for DataEndpoint, and this is a main class that needs to be implemented
for supporting different transports to DataPublisher.
- DataEndpoint() - Constructor for class org.wso2.carbon.databridge.agent.endpoint.DataEndpoint
-
- DataEndpoint.State - Enum in org.wso2.carbon.databridge.agent.endpoint
-
- DataEndpointAgent - Class in org.wso2.carbon.databridge.agent
-
One agent is created for a specific data endpoint type,and this has the resources such as transport pool, etc
which are shared by all the data publishers created for the endpoint type.
- DataEndpointAgent(AgentConfiguration) - Constructor for class org.wso2.carbon.databridge.agent.DataEndpointAgent
-
- DataEndpointAgentConfigurationException - Exception in org.wso2.carbon.databridge.agent.exception
-
Exception to be thrown for DataEndpointAgentConfiguration which was specified in the data-agent-config.xml
- DataEndpointAgentConfigurationException(String) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointAgentConfigurationException
-
- DataEndpointAgentConfigurationException(String, Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointAgentConfigurationException
-
- DataEndpointAgentConfigurationException(Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointAgentConfigurationException
-
- DataEndpointAuthenticationException - Exception in org.wso2.carbon.databridge.agent.exception
-
Exception to be thrown when connecting the Data Endpoint.
- DataEndpointAuthenticationException(String) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointAuthenticationException
-
- DataEndpointAuthenticationException(String, Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointAuthenticationException
-
- DataEndpointAuthenticationException(Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointAuthenticationException
-
- DataEndpointConfiguration - Class in org.wso2.carbon.databridge.agent.conf
-
- DataEndpointConfiguration(String, String, String, String, GenericKeyedObjectPool, GenericKeyedObjectPool, int, int, int, int) - Constructor for class org.wso2.carbon.databridge.agent.conf.DataEndpointConfiguration
-
- DataEndpointConfiguration.Protocol - Enum in org.wso2.carbon.databridge.agent.conf
-
- DataEndpointConfigurationException - Exception in org.wso2.carbon.databridge.agent.exception
-
Exception to be thrown When parsing the Data Endpoint configurations when initializing data publisher.
- DataEndpointConfigurationException(String) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointConfigurationException
-
- DataEndpointConfigurationException(String, Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointConfigurationException
-
- DataEndpointConfigurationException(Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointConfigurationException
-
- DataEndpointConnectionWorker - Class in org.wso2.carbon.databridge.agent.endpoint
-
DataEndpoint Connection worker class implementation.
- DataEndpointConnectionWorker() - Constructor for class org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker
-
- DataEndpointConstants - Class in org.wso2.carbon.databridge.agent.util
-
Class to define the constants that are used.
- DataEndpointException - Exception in org.wso2.carbon.databridge.agent.exception
-
Exception to be thrown when communicating with DataEndpoint.
- DataEndpointException(String) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointException
-
- DataEndpointException(String, Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointException
-
- DataEndpointException(Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointException
-
- DataEndpointFailureCallback - Interface in org.wso2.carbon.databridge.agent.endpoint
-
This interface is used to implement a call back for get the notifications upon the unsuccessful event publishing.
- DataEndpointGroup - Class in org.wso2.carbon.databridge.agent.endpoint
-
This class holds the endpoints associated within a group.
- DataEndpointGroup(DataEndpointGroup.HAType, DataEndpointAgent) - Constructor for class org.wso2.carbon.databridge.agent.endpoint.DataEndpointGroup
-
- DataEndpointGroup.HAType - Enum in org.wso2.carbon.databridge.agent.endpoint
-
- DataEndpointSecurityException - Exception in org.wso2.carbon.databridge.agent.exception
-
Security Exception thrown when communicating with Data Endpoint.
- DataEndpointSecurityException(String) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointSecurityException
-
- DataEndpointSecurityException(String, Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointSecurityException
-
- DataEndpointSecurityException(Throwable) - Constructor for exception org.wso2.carbon.databridge.agent.exception.DataEndpointSecurityException
-
- DataPublisher - Class in org.wso2.carbon.databridge.agent
-
API Used to communicate with Data Receivers WSO2 BAM/CEP.
- DataPublisher(String, String, String) - Constructor for class org.wso2.carbon.databridge.agent.DataPublisher
-
Creates the DataPublisher instance for a specific user, and the it creates
connection asynchronously to receiver endpoint.
- DataPublisher(String, String, String, String, String) - Constructor for class org.wso2.carbon.databridge.agent.DataPublisher
-
Creates the DataPublisher instance for a specific user, and the it creates
connection asynchronously to receiver endpoint.
- DataPublisherUtil - Class in org.wso2.carbon.databridge.agent.util
-
A Util class which holds all the utility processing methods in the data publisher operation.
- DEFAULT_AUTH_PORT_OFFSET - Static variable in class org.wso2.carbon.databridge.agent.util.DataEndpointConstants
-
- DEFAULT_DATA_AGENT_BATCH_SIZE - Static variable in class org.wso2.carbon.databridge.agent.util.DataEndpointConstants
-
- destroyObject(Object, Object) - Method in class org.wso2.carbon.databridge.agent.client.AbstractClientPoolFactory
-
- disconnect(DataEndpointConfiguration) - Method in class org.wso2.carbon.databridge.agent.endpoint.DataEndpointConnectionWorker
-
- terminateClient(Object) - Method in class org.wso2.carbon.databridge.agent.client.AbstractClientPoolFactory
-
Terminates the connection between the client and the endpoint.
- terminateClient(Object) - Method in class org.wso2.carbon.databridge.agent.endpoint.binary.BinaryClientPoolFactory
-
- terminateClient(Object) - Method in class org.wso2.carbon.databridge.agent.endpoint.binary.BinarySecureClientPoolFactory
-
- terminateClient(Object) - Method in class org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftClientPoolFactory
-
- terminateClient(Object) - Method in class org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftSecureClientPoolFactory
-
- THRIFT_DATA_AGENT_TYPE - Static variable in class org.wso2.carbon.databridge.agent.util.DataEndpointConstants
-
- ThriftClientPoolFactory - Class in org.wso2.carbon.databridge.agent.endpoint.thrift
-
This is a Thrift Transport implementation for AbstractClientPoolFactory for Thrift Endpoint.
- ThriftClientPoolFactory() - Constructor for class org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftClientPoolFactory
-
- ThriftDataEndpoint - Class in org.wso2.carbon.databridge.agent.endpoint.thrift
-
This is the DataEndpoint Implementation for thrift transport.
- ThriftDataEndpoint() - Constructor for class org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftDataEndpoint
-
- ThriftEventConverter - Class in org.wso2.carbon.databridge.agent.endpoint.thrift
-
Util class used to convert Events to thrift format.
- ThriftSecureClientPoolFactory - Class in org.wso2.carbon.databridge.agent.endpoint.thrift
-
This is a Thrift secure transport implementation for AbstractSecureClientPoolFactory
to be used by the Thrift Endpoint.
- ThriftSecureClientPoolFactory(String, String) - Constructor for class org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftSecureClientPoolFactory
-
- toString() - Method in enum org.wso2.carbon.databridge.agent.conf.DataEndpointConfiguration.Protocol
-
- toString() - Method in class org.wso2.carbon.databridge.agent.conf.DataEndpointConfiguration
-
- toString() - Method in class org.wso2.carbon.databridge.agent.endpoint.DataEndpoint
-
- toString() - Method in class org.wso2.carbon.databridge.agent.endpoint.DataEndpointGroup
-
- toString() - Method in class org.wso2.carbon.databridge.agent.endpoint.WrappedEventFactory.WrappedEvent
-
- toThriftEventBundle(Event, ThriftEventBundle, String) - Static method in class org.wso2.carbon.databridge.agent.endpoint.thrift.ThriftEventConverter
-
- tryPublish(Event) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(Event, long) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(String, Object[], Object[], Object[], long) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(String, Object[], Object[], Object[], Map<String, String>, long) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(String, long, Object[], Object[], Object[], long) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(String, long, Object[], Object[], Object[], Map<String, String>, long) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(String, Object[], Object[], Object[]) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
* Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(String, Object[], Object[], Object[], Map<String, String>) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
* Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(String, long, Object[], Object[], Object[]) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
* Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(String, long, Object[], Object[], Object[], Map<String, String>) - Method in class org.wso2.carbon.databridge.agent.DataPublisher
-
* Publish an event based on the event properties that are passed
for all receiver groups which has been specified in the DataPublisher.
- tryPublish(Event) - Method in class org.wso2.carbon.databridge.agent.endpoint.DataEndpointGroup
-
- tryPublish(Event, long) - Method in class org.wso2.carbon.databridge.agent.endpoint.DataEndpointGroup
-
- tryResendEvents(List<Event>) - Method in interface org.wso2.carbon.databridge.agent.endpoint.DataEndpointFailureCallback
-
Notifies the The failed events, and should try to send the events again successfully.
- tryResendEvents(List<Event>) - Method in class org.wso2.carbon.databridge.agent.endpoint.DataEndpointGroup
-