Package | Description |
---|---|
io.siddhi.core.stream.output.sink | |
io.siddhi.core.stream.output.sink.distributed | |
io.siddhi.core.util.transport |
Modifier and Type | Method and Description |
---|---|
void |
LogSink.publish(Object payload,
DynamicOptions transportOptions) |
abstract void |
Sink.publish(Object payload,
DynamicOptions transportOptions)
Sending events via output transport
|
void |
InMemorySink.publish(Object payload,
DynamicOptions dynamicOptions) |
Modifier and Type | Method and Description |
---|---|
List<Integer> |
PartitionedDistributionStrategy.getDestinationsToPublish(Object payload,
DynamicOptions transportOptions)
This method tells the ID(s) of the destination(s) to which a given messages should be sent.
|
abstract List<Integer> |
DistributionStrategy.getDestinationsToPublish(Object payload,
DynamicOptions transportOptions)
This method tells the ID(s) of the destination(s) to which a given messages should be sent.
|
List<Integer> |
BroadcastDistributionStrategy.getDestinationsToPublish(Object payload,
DynamicOptions transportOptions)
This method tells the ID(s) of the destination(s) to which a given messages should be sent.
|
List<Integer> |
RoundRobinDistributionStrategy.getDestinationsToPublish(Object payload,
DynamicOptions transportOptions)
This method tells the ID(s) of the destination(s) to which a given messages should be sent.
|
void |
DistributedTransport.publish(Object payload,
DynamicOptions transportOptions) |
abstract void |
DistributedTransport.publish(Object payload,
DynamicOptions transportOptions,
Integer destinationId) |
Modifier and Type | Method and Description |
---|---|
String |
Option.getValue(DynamicOptions dynamicOptions) |
void |
MultiClientDistributedSink.publish(Object payload,
DynamicOptions transportOptions,
Integer destinationId) |
void |
SingleClientDistributedSink.publish(Object payload,
DynamicOptions transportOptions,
Integer destinationId) |
Copyright © 2019. All rights reserved.