Interface PartitionSubscriberFactory (0.4.5)

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
NameDescription
partitioncom.google.cloud.pubsublite.Partition
offsetcom.google.cloud.pubsublite.Offset
message_consumerConsumer<List<com.google.cloud.pubsublite.SequencedMessage>>
Returns
TypeDescription
com.google.cloud.pubsublite.internal.wire.Subscriber
Exceptions
TypeDescription
ApiException