org.springframework.messaging.simp.broker

Class AbstractSubscriptionRegistry

  • java.lang.Object
    • org.springframework.messaging.simp.broker.AbstractSubscriptionRegistry
    • Field Detail

      • logger

        protected final Log logger
    • Constructor Detail

      • AbstractSubscriptionRegistry

        public AbstractSubscriptionRegistry()
    • Method Detail

      • findSubscriptions

        public final MultiValueMap<java.lang.String,java.lang.String> findSubscriptions(Message<?> message)
        Description copied from interface: SubscriptionRegistry
        Find all subscriptions that should receive the given message. The map returned is safe to iterate and will never be modified.
        Specified by:
        findSubscriptions in interface SubscriptionRegistry
        Parameters:
        message - the message
        Returns:
        a MultiValueMap with sessionId-subscriptionId pairs (possibly empty)
      • addSubscriptionInternal

        protected abstract void addSubscriptionInternal(java.lang.String sessionId,
                                                        java.lang.String subscriptionId,
                                                        java.lang.String destination,
                                                        Message<?> message)
      • removeSubscriptionInternal

        protected abstract void removeSubscriptionInternal(java.lang.String sessionId,
                                                           java.lang.String subscriptionId,
                                                           Message<?> message)
      • findSubscriptionsInternal

        protected abstract MultiValueMap<java.lang.String,java.lang.String> findSubscriptionsInternal(java.lang.String destination,
                                                                                                      Message<?> message)