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.