Uses of Interface
com.google.cloud.pubsublite.MessageTransformer
-
Packages that use MessageTransformer Package Description com.google.cloud.pubsublite.cloudpubsub com.google.cloud.pubsublite.cloudpubsub.internal -
-
Uses of MessageTransformer in com.google.cloud.pubsublite.cloudpubsub
Methods in com.google.cloud.pubsublite.cloudpubsub that return MessageTransformer Modifier and Type Method Description static MessageTransformer<com.google.pubsub.v1.PubsubMessage,Message>MessageTransforms. fromCpsPublishTransformer(KeyExtractor keyExtractor)static MessageTransformer<Message,com.google.pubsub.v1.PubsubMessage>MessageTransforms. toCpsPublishTransformer()static MessageTransformer<SequencedMessage,com.google.pubsub.v1.PubsubMessage>MessageTransforms. toCpsSubscribeTransformer()Methods in com.google.cloud.pubsublite.cloudpubsub with parameters of type MessageTransformer Modifier and Type Method Description abstract PublisherSettings.BuilderPublisherSettings.Builder. setMessageTransformer(MessageTransformer<com.google.pubsub.v1.PubsubMessage,Message> messageTransformer)A MessageTransformer for constructing wire messages from Cloud Pub/Sub PubsubMessages.abstract SubscriberSettings.BuilderSubscriberSettings.Builder. setTransformer(MessageTransformer<SequencedMessage,com.google.pubsub.v1.PubsubMessage> transformer)The MessageTransformer to get PubsubMessages from Pub/Sub Lite wire messages. -
Uses of MessageTransformer in com.google.cloud.pubsublite.cloudpubsub.internal
Constructors in com.google.cloud.pubsublite.cloudpubsub.internal with parameters of type MessageTransformer Constructor Description SinglePartitionSubscriber(com.google.cloud.pubsub.v1.MessageReceiver receiver, MessageTransformer<SequencedMessage,com.google.pubsub.v1.PubsubMessage> transformer, com.google.cloud.pubsublite.cloudpubsub.internal.AckSetTracker ackSetTracker, NackHandler nackHandler, ResettableSubscriberFactory wireSubscriberFactory, FlowControlSettings flowControlSettings)WrappingPublisher(Publisher<MessageMetadata> wirePublisher, MessageTransformer<com.google.pubsub.v1.PubsubMessage,Message> transformer)
-