Dfyjkt

I have the following websocket configuration in my Spring Boot app:

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfiguration implements WebSocketMessageBrokerConfigurer 

 public static final String WEBSOCKET_HANDSHAKE_ENDPOINT_URI = "/api/wsocket";
 public static final String QUOTE_CHANNEL_URI = "/quote";

 @Autowired
 private RabbitTemplate rabbitTemplate;

 @Override
 public void configureMessageBroker(MessageBrokerRegistry config) 
 config.enableSimpleBroker(QUOTE_CHANNEL_URI); /*Enable a simple in-memory broker for the clients to subscribe to channels and receive messages*/
 config.setApplicationDestinationPrefixes("/app"); /*The prefix for the message mapping endpoints in the controller*/
 

 @Override
 public void registerStompEndpoints(StompEndpointRegistry registry) 
 /*websocket handshaking endpoint*/
 registry.addEndpoint(WEBSOCKET_HANDSHAKE_ENDPOINT_URI)
 /*TODO remove this after development*/
 .setAllowedOrigins("http://localhost:8080");
 

 @Override
 public void configureClientInboundChannel(ChannelRegistration registeration) 
 registeration.interceptors(new SubscriptionInterceptor(rabbitTemplate));
 

and the following interceptor:

public class SubscriptionInterceptor implements ChannelInterceptor 

 final private SubscriptionValidator validators;
 final private QuoteChannelServiceImpl quoteChannelService;

 public SubscriptionInterceptor(RabbitTemplate rabbitTemplate) 
 this.validators = new SubscriptionValidator new QuoteSubscriptionValidator() ;
 this.quoteChannelService = QuoteChannelServiceImpl.getInstance(rabbitTemplate);
 

 @Override
 public Message<?> preSend(Message<?> message, MessageChannel channel) command.equals(StompCommand.DISCONNECT)) 
 quoteChannelService.subscriberLeft(headerAccessor.getDestination().replaceFirst(
 WebSocketConfiguration.QUOTE_CHANNEL_URI.concat("/"), ""));// TODO can we move "/" into the QUOTE_CHANNEL_URI? 
 
 return message;
 

 private void validate(Message<?> message) 
 StompHeaderAccessor headerAccessor = StompHeaderAccessor.wrap(message);
 Arrays.stream(validators)
 .filter(validator -> validator.supports(headerAccessor)
 && validator.validate(headerAccessor)).findFirst()
 .orElseThrow(() -> new MessagingException(message));
 

I would like to know if it is possible that I have different interceptors for different brokers. I