Class CamelMessageReceiver

  • All Implemented Interfaces:
    com.google.cloud.pubsub.v1.MessageReceiver

    public class CamelMessageReceiver
    extends Object
    implements com.google.cloud.pubsub.v1.MessageReceiver
    • Constructor Detail

      • CamelMessageReceiver

        public CamelMessageReceiver​(GooglePubsubEndpoint endpoint,
                                    org.apache.camel.Processor processor)
    • Method Detail

      • receiveMessage

        public void receiveMessage​(com.google.pubsub.v1.PubsubMessage pubsubMessage,
                                   com.google.cloud.pubsub.v1.AckReplyConsumer ackReplyConsumer)
        Specified by:
        receiveMessage in interface com.google.cloud.pubsub.v1.MessageReceiver