Interface BaseSubscriptionConfiguration.MessageCallback

  • All Superinterfaces:
    java.util.function.BiConsumer<PubSubMessage,​java.lang.Object>
    Enclosing class:
    BaseSubscriptionConfiguration

    public static interface BaseSubscriptionConfiguration.MessageCallback
    extends java.util.function.BiConsumer<PubSubMessage,​java.lang.Object>
    Callback called for every incoming message. It should be a fast, non-blocking operation to avoid issues. A next call could happen even before then the previous call complete.
    The callback arguments are:
    1. A received PubSubMessage.
    2. A user-defined BaseSubscriptionConfiguration.context or null if not configured.
    • Method Summary

      • Methods inherited from interface java.util.function.BiConsumer

        accept, andThen