| Package | Description |
|---|---|
| com.yahoo.bullet.pubsub | |
| com.yahoo.bullet.pubsub.rest |
| Modifier and Type | Class and Description |
|---|---|
class |
BufferingSubscriber
This implements a
Subscriber that provides a base subscriber that buffers a fixed number of messages read. |
| Modifier and Type | Method and Description |
|---|---|
abstract Subscriber |
PubSub.getSubscriber()
Get a
Subscriber instance wired to read from all allocated partitions in the appropriate queue (See
PubSub.context). |
| Modifier and Type | Method and Description |
|---|---|
abstract List<Subscriber> |
PubSub.getSubscribers(int n)
Get a list of n
Subscriber instances with allocated partitions from the appropriate queue
(See PubSub.context) split as evenly as possible among them. |
| Modifier and Type | Class and Description |
|---|---|
class |
RESTSubscriber |
| Modifier and Type | Method and Description |
|---|---|
Subscriber |
RESTPubSub.getSubscriber() |
| Modifier and Type | Method and Description |
|---|---|
List<Subscriber> |
RESTPubSub.getSubscribers(int n) |
Copyright © 2021. All rights reserved.