| Modifier and Type | Method and Description |
|---|---|
DataEndpoint |
DataEndpointAgent.getNewDataEndpoint() |
void |
DataPublisher.shutdown()
Graceful shutdown of all the operations of the data publisher.
|
static void |
AgentHolder.shutdown() |
void |
DataEndpointAgent.shutDown() |
void |
DataPublisher.shutdownWithAgent()
Graceful shutdown of all the operations of the data publisher, and also
if there is no other data publishers registered with the associated then
it will shutdown the agent as well.
|
| Constructor and Description |
|---|
DataPublisher(String receiverURLSet,
String username,
String password)
Creates the DataPublisher instance for a specific user, and the it creates
connection asynchronously to receiver endpoint.
|
DataPublisher(String type,
String receiverURLSet,
String authURLSet,
String username,
String password)
Creates the DataPublisher instance for a specific user, and the it creates
connection asynchronously to receiver endpoint.
|
| Modifier and Type | Method and Description |
|---|---|
abstract Object |
AbstractClientPoolFactory.createClient(String protocol,
String hostName,
int port)
Make a connection to the receiver and return the client.
|
Object |
AbstractClientPoolFactory.makeObject(Object key) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataEndpoint.initialize(DataEndpointConfiguration dataEndpointConfiguration) |
void |
DataEndpointConnectionWorker.initialize(DataEndpoint dataEndpoint,
DataEndpointConfiguration dataEndpointConfiguration)
Initialize the data endpoint connection worker.
|
protected abstract void |
DataEndpoint.send(Object client,
List<org.wso2.carbon.databridge.commons.Event> events)
Send the list of events to the actual endpoint.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
BinarySecureClientPoolFactory.createClient(String protocol,
String hostName,
int port) |
Object |
BinaryClientPoolFactory.createClient(String protocol,
String hostName,
int port) |
protected void |
BinaryDataEndpoint.send(Object client,
List<org.wso2.carbon.databridge.commons.Event> events) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ThriftClientPoolFactory.createClient(String protocol,
String hostName,
int port) |
protected void |
ThriftDataEndpoint.send(Object client,
List<org.wso2.carbon.databridge.commons.Event> events) |
Copyright © 2017 WSO2. All rights reserved.