From 527ee1200a70027c61b09c2501f52d365132d10d Mon Sep 17 00:00:00 2001 From: Fabio Formosa Date: Sun, 11 Dec 2022 20:38:55 +0100 Subject: [PATCH] #103 added some comments --- .../api/configuration/WebsocketConfig.java | 11 +++++++---- .../api/controllers/WebsocketController.java | 5 ++++- .../api/websockets/WebSocketLogsNotifier.java | 2 +- 3 files changed, 12 insertions(+), 6 deletions(-) diff --git a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/configuration/WebsocketConfig.java b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/configuration/WebsocketConfig.java index 67b07d3..2580bfe 100644 --- a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/configuration/WebsocketConfig.java +++ b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/configuration/WebsocketConfig.java @@ -1,5 +1,6 @@ package it.fabioformosa.quartzmanager.api.configuration; +import it.fabioformosa.quartzmanager.api.common.config.QuartzManagerPaths; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.messaging.simp.config.MessageBrokerRegistry; @@ -14,14 +15,16 @@ public class WebsocketConfig extends AbstractWebSocketMessageBrokerConfigurer { @Override public void configureMessageBroker(MessageBrokerRegistry config) { - config.enableSimpleBroker("/topic"); - config.setApplicationDestinationPrefixes("/job"); + config.enableSimpleBroker("/topic"); //enable a simple memory-based message broker + // on destinations prefixed with /topic + config.setApplicationDestinationPrefixes("/job"); // it designates the prefix for messages + // that are bound for methods annotated with @MessageMapping } @Override public void registerStompEndpoints(StompEndpointRegistry registry) { - registry.addEndpoint("/quartz-manager/logs").setAllowedOrigins("/**").withSockJS(); - registry.addEndpoint("/quartz-manager/progress").setAllowedOrigins("/**").withSockJS(); + registry.addEndpoint(QuartzManagerPaths.QUARTZ_MANAGER_BASE_CONTEXT_PATH + "/logs").setAllowedOrigins("/**").withSockJS(); + registry.addEndpoint(QuartzManagerPaths.QUARTZ_MANAGER_BASE_CONTEXT_PATH + "/progress").setAllowedOrigins("/**").withSockJS(); } } diff --git a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/controllers/WebsocketController.java b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/controllers/WebsocketController.java index 8afe860..3baf7af 100644 --- a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/controllers/WebsocketController.java +++ b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/controllers/WebsocketController.java @@ -8,7 +8,10 @@ import org.springframework.stereotype.Controller; @Controller public class WebsocketController { - @MessageMapping({ QuartzManagerPaths.QUARTZ_MANAGER_BASE_CONTEXT_PATH + "/logs", QuartzManagerPaths.QUARTZ_MANAGER_BASE_CONTEXT_PATH + "/progress" }) + @MessageMapping({ + QuartzManagerPaths.QUARTZ_MANAGER_BASE_CONTEXT_PATH + "/logs", + QuartzManagerPaths.QUARTZ_MANAGER_BASE_CONTEXT_PATH + "/progress" + }) @SendTo("/topic/logs") public String subscribe() { return "subscribed"; diff --git a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/websockets/WebSocketLogsNotifier.java b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/websockets/WebSocketLogsNotifier.java index e5f93de..9ced563 100644 --- a/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/websockets/WebSocketLogsNotifier.java +++ b/quartz-manager-parent/quartz-manager-starter-api/src/main/java/it/fabioformosa/quartzmanager/api/websockets/WebSocketLogsNotifier.java @@ -14,7 +14,7 @@ public class WebSocketLogsNotifier implements WebhookSender { private SimpMessageSendingOperations messagingTemplate; @Override - public void send(LogRecord logRecord) { + public void send(LogRecord logRecord) { messagingTemplate.convertAndSend(TOPIC_LOGS, logRecord); } }