@@ -269,13 +269,15 @@ else if (webSocketMessage instanceof BinaryMessage) {
269
269
}
270
270
271
271
for (Message <byte []> message : messages ) {
272
- try {
273
- StompHeaderAccessor headerAccessor =
274
- MessageHeaderAccessor .getAccessor (message , StompHeaderAccessor .class );
275
- Assert .state (headerAccessor != null , "No StompHeaderAccessor" );
272
+ StompHeaderAccessor headerAccessor =
273
+ MessageHeaderAccessor .getAccessor (message , StompHeaderAccessor .class );
274
+ Assert .state (headerAccessor != null , "No StompHeaderAccessor" );
275
+
276
+ StompCommand command = headerAccessor .getCommand ();
277
+ boolean isConnect = StompCommand .CONNECT .equals (command ) || StompCommand .STOMP .equals (command );
276
278
277
- StompCommand command = headerAccessor . getCommand () ;
278
- boolean isConnect = StompCommand . CONNECT . equals ( command ) || StompCommand . STOMP . equals ( command );
279
+ boolean sent = false ;
280
+ try {
279
281
280
282
headerAccessor .setSessionId (session .getId ());
281
283
headerAccessor .setSessionAttributes (session .getAttributes ());
@@ -305,7 +307,7 @@ else if (StompCommand.DISCONNECT.equals(command)) {
305
307
306
308
try {
307
309
SimpAttributesContextHolder .setAttributesFromMessage (message );
308
- boolean sent = outputChannel .send (message );
310
+ sent = outputChannel .send (message );
309
311
310
312
if (sent ) {
311
313
if (this .eventPublisher != null ) {
@@ -327,13 +329,14 @@ else if (StompCommand.UNSUBSCRIBE.equals(command)) {
327
329
}
328
330
}
329
331
catch (Throwable ex ) {
330
- if (logger .isErrorEnabled ()) {
331
- String errorText = "Failed to send message to MessageChannel in session " + session .getId ();
332
- if (logger .isDebugEnabled ()) {
333
- logger .debug (errorText , ex );
334
- }
335
- else {
336
- logger .error (errorText + ":" + ex .getMessage ());
332
+ if (logger .isDebugEnabled ()) {
333
+ logger .debug ("Failed to send message to MessageChannel in session " + session .getId (), ex );
334
+ }
335
+ else if (logger .isErrorEnabled ()) {
336
+ // Skip unsent CONNECT messages (likely auth issues)
337
+ if (!isConnect || sent ) {
338
+ logger .error ("Failed to send message to MessageChannel in session " + session .getId () +
339
+ ":" + ex .getMessage ());
337
340
}
338
341
}
339
342
handleError (session , ex , message );
0 commit comments