| Package | Description |
|---|---|
| io.openmessaging |
| Modifier and Type | Method and Description |
|---|---|
StreamingConsumer |
MessagingAccessPoint.createStreamingConsumer()
Creates a new
StreamingConsumer for the specified MessagingAccessPoint. |
StreamingConsumer |
MessagingAccessPoint.createStreamingConsumer(KeyValue attributes)
Creates a new
StreamingConsumer for the specified MessagingAccessPoint with some preset
attributes. |
Copyright © 2017–2018 OpenMessaging. All rights reserved.