diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractBrokerRegistration.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractBrokerRegistration.java index f4f8ebe90007..37c2d3b40022 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractBrokerRegistration.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/AbstractBrokerRegistration.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2017 the original author or authors. + * Copyright 2002-2021 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -42,10 +42,16 @@ public abstract class AbstractBrokerRegistration { private final List destinationPrefixes; + /** + * Create a new broker registration. + * @param clientInboundChannel the inbound channel + * @param clientOutboundChannel the outbound channel + * @param destinationPrefixes the destination prefixes + */ public AbstractBrokerRegistration(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, @Nullable String[] destinationPrefixes) { - Assert.notNull(clientOutboundChannel, "'clientInboundChannel' must not be null"); + Assert.notNull(clientInboundChannel, "'clientInboundChannel' must not be null"); Assert.notNull(clientOutboundChannel, "'clientOutboundChannel' must not be null"); this.clientInboundChannel = clientInboundChannel; diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/SimpleBrokerRegistration.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/SimpleBrokerRegistration.java index 4c11e6845523..68e60f691b5a 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/SimpleBrokerRegistration.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/SimpleBrokerRegistration.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2018 the original author or authors. + * Copyright 2002-2021 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -40,8 +40,16 @@ public class SimpleBrokerRegistration extends AbstractBrokerRegistration { private String selectorHeaderName = "selector"; - public SimpleBrokerRegistration(SubscribableChannel inChannel, MessageChannel outChannel, String[] prefixes) { - super(inChannel, outChannel, prefixes); + /** + * Create a new {@code SimpleBrokerRegistration}. + * @param clientInboundChannel the inbound channel + * @param clientOutboundChannel the outbound channel + * @param destinationPrefixes the destination prefixes + */ + public SimpleBrokerRegistration(SubscribableChannel clientInboundChannel, + MessageChannel clientOutboundChannel, String[] destinationPrefixes) { + + super(clientInboundChannel, clientOutboundChannel, destinationPrefixes); } diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/StompBrokerRelayRegistration.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/StompBrokerRelayRegistration.java index d24b63e2dd01..526c4cf4fd73 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/simp/config/StompBrokerRelayRegistration.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/config/StompBrokerRelayRegistration.java @@ -1,5 +1,5 @@ /* - * Copyright 2002-2020 the original author or authors. + * Copyright 2002-2021 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -68,6 +68,12 @@ public class StompBrokerRelayRegistration extends AbstractBrokerRegistration { private String userRegistryBroadcast; + /** + * Create a new {@code StompBrokerRelayRegistration}. + * @param clientInboundChannel the inbound channel + * @param clientOutboundChannel the outbound channel + * @param destinationPrefixes the destination prefixes + */ public StompBrokerRelayRegistration(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, String[] destinationPrefixes) {