Interface SubscriberFactory
-
- All Superinterfaces:
Serializable
public interface SubscriberFactory extends Serializable
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Subscriber
newSubscriber(Consumer<List<SequencedMessage>> messageConsumer)
-
-
-
Method Detail
-
newSubscriber
Subscriber newSubscriber(Consumer<List<SequencedMessage>> messageConsumer) throws com.google.api.gax.rpc.ApiException
- Throws:
com.google.api.gax.rpc.ApiException
-
-