@@ -143,22 +143,6 @@ private void onComplete(
143143 }
144144 }
145145
146- private GatewayMessage validateQualifier (GatewayMessage msg ) {
147- if (msg .qualifier () == null ) {
148- throw WebsocketContextException .badRequest ("qualifier is missing" , msg );
149- }
150- return msg ;
151- }
152-
153- private GatewayMessage validateSid (WebsocketGatewaySession session , GatewayMessage msg ) {
154- if (session .containsSid (msg .streamId ())) {
155- throw WebsocketContextException .badRequest (
156- "sid=" + msg .streamId () + " is already registered" , msg );
157- } else {
158- return msg ;
159- }
160- }
161-
162146 private Mono <?> onCancel (WebsocketGatewaySession session , GatewayMessage msg ) {
163147 if (!msg .hasSignal (Signal .CANCEL )) {
164148 return Mono .just (msg );
@@ -175,6 +159,22 @@ private Mono<?> onCancel(WebsocketGatewaySession session, GatewayMessage msg) {
175159 return session .send (cancelAck ); // no need to subscribe here since flatMap will do
176160 }
177161
162+ private GatewayMessage validateQualifier (GatewayMessage msg ) {
163+ if (msg .qualifier () == null ) {
164+ throw WebsocketContextException .badRequest ("qualifier is missing" , msg );
165+ }
166+ return msg ;
167+ }
168+
169+ private GatewayMessage validateSid (WebsocketGatewaySession session , GatewayMessage msg ) {
170+ if (session .containsSid (msg .streamId ())) {
171+ throw WebsocketContextException .badRequest (
172+ "sid=" + msg .streamId () + " is already registered" , msg );
173+ } else {
174+ return msg ;
175+ }
176+ }
177+
178178 private GatewayMessage validateSid (GatewayMessage msg ) {
179179 if (msg .streamId () == null ) {
180180 throw WebsocketContextException .badRequest ("sid is missing" , msg );
0 commit comments