Interface PartitionSubscriberFactory (1.0.0) 

public interface PartitionSubscriberFactory extends Serializable

Implements

Serializable

Methods

newSubscriber(Partition partition, Offset offset, Consumer<List<SequencedMessage>> message_consumer)

public abstract Subscriber newSubscriber(Partition partition, Offset offset, Consumer<List<SequencedMessage>> message_consumer)
Parameters
Name Description
partition com.google.cloud.pubsublite.Partition
offset com.google.cloud.pubsublite.Offset
message_consumer Consumer<List<com.google.cloud.pubsublite.SequencedMessage>>
Returns
Type Description
com.google.cloud.pubsublite.internal.wire.Subscriber
Exceptions
Type Description
ApiException