| Modifier and Type | Method and Description |
|---|---|
Future<TopicSubscription> |
EmpConnector.subscribe(String topic,
long replayFrom,
Consumer<Map<String,Object>> consumer)
Subscribe to a topic, receiving events after the replayFrom position
|
Future<TopicSubscription> |
EmpConnector.subscribeEarliest(String topic,
Consumer<Map<String,Object>> consumer)
Subscribe to a topic, receiving events from the earliest event position in the stream
|
Future<TopicSubscription> |
EmpConnector.subscribeTip(String topic,
Consumer<Map<String,Object>> consumer)
Subscribe to a topic, receiving events from the latest event position in the stream
|
Copyright © 2025 WSO2. All rights reserved.