Interface SubscriptionRegistry

    • Method Detail

      • registerSubscription

        void registerSubscription​(Message<?> subscribeMessage)
        Register a subscription represented by the given message.
        Parameters:
        subscribeMessage - the subscription request
      • unregisterSubscription

        void unregisterSubscription​(Message<?> unsubscribeMessage)
        Unregister a subscription.
        Parameters:
        unsubscribeMessage - the request to unsubscribe
      • findSubscriptions

        MultiValueMap<String,​StringfindSubscriptions​(Message<?> message)
        Find all subscriptions that should receive the given message. The map returned is safe to iterate and will never be modified.
        Parameters:
        message - the message
        Returns:
        a MultiValueMap with sessionId-subscriptionId pairs (possibly empty)