XCOMMONS-3425: The Netflux WebSocket endpoint delays replies for no good reason

mflorea · mflorea · commit 52c2daabb1b7 · 2025-09-23T10:12:55.000+03:00
diff --git a/xwiki-platform-core/xwiki-platform-netflux/xwiki-platform-netflux-api/src/main/java/org/xwiki/netflux/internal/EntityChannelScriptAuthorBot.java b/xwiki-platform-core/xwiki-platform-netflux/xwiki-platform-netflux-api/src/main/java/org/xwiki/netflux/internal/EntityChannelScriptAuthorBot.java
@@ -84,7 +84,7 @@ public void onChannelMessage(Channel channel, User sender, String messageType, S
     {
         // We're interested only in messages that have content (we want to ignore for instance join, leave or ping
         // messages).
-        if (MessageDispatcher.COMMAND_MSG.equals(messageType)) {
+        if (MessageBuilder.COMMAND_MSG.equals(messageType)) {
             this.entityChannels.getChannel(channel.getKey())
                 .ifPresent(entityChannel -> this.webSocketContext.run(sender.getSession(), () -> {
                     UserReference senderUserReference = this.currentUserResolver.resolve(CurrentUserReference.INSTANCE);

Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,7 @@ public void onChannelMessage(Channel channel, User sender, String messageType, S`
`84`	`84`	`{`
`85`	`85`	`// We're interested only in messages that have content (we want to ignore for instance join, leave or ping`
`86`	`86`	`// messages).`
`87`		`- if (MessageDispatcher.COMMAND_MSG.equals(messageType)) {`
	`87`	`+ if (MessageBuilder.COMMAND_MSG.equals(messageType)) {`
`88`	`88`	`this.entityChannels.getChannel(channel.getKey())`
`89`	`89`	`.ifPresent(entityChannel -> this.webSocketContext.run(sender.getSession(), () -> {`
`90`	`90`	`UserReference senderUserReference = this.currentUserResolver.resolve(CurrentUserReference.INSTANCE);`