public interface Channel
Represents a channel to a subject on the Liberator.
A Channel provides a bi-directional communication channel between a StreamLink application and a DataSource adapter. Using a Channel in both DataSource and StreamLink provides a simplified method of communication between the two components and can allow you just to use the Caplin platform as a bi-directional messaging pipe.
Modifier and Type | Method and Description |
---|---|
void |
closeChannel()
Closes the channel to the Liberator.
|
java.lang.String |
getSubject()
Returns the subject name to which the channel relates.
|
void |
send(java.util.Map<java.lang.String,java.lang.String> fields,
CommandListener commandListener)
Sends fields to the channel subject
|
java.lang.String getSubject()
Returns the subject name to which the channel relates.
void closeChannel()
Closes the channel to the Liberator. This will result in a corresponding call to onChannelClose declared in ChannelListener on the DataSource. The delay before onChannelClose is called is defined by the Liberator configuration item, active-discard-timeout.
void send(java.util.Map<java.lang.String,java.lang.String> fields, CommandListener commandListener)
fields
- the fields to sendcommandListener
- optional callback for command completion (can set to null).Please send bug reports and comments to Caplin support