implement websocket infrastructure adapter

hr-microservice-hexagonal/pom.xml

@@ -77,6 +77,10 @@
 			<!-- <exclusions> <exclusion> <groupId>org.junit.vintage</groupId> <artifactId>junit-vintage-engine</artifactId> 
 				</exclusion> </exclusions> -->
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-websocket</artifactId>
+		</dependency>
 	</dependencies>
 
 	<build>

hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EventPuslisherAdapter.java → hr-microservice-hexagonal/src/main/java/com/example/hr/adapter/EventPuslisherWebsocketAdapter.java

@@ -1,5 +1,7 @@
 package com.example.hr.adapter;
 
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.stereotype.Service;
 
 import com.example.hr.events.BusinessEvent;
@@ -11,12 +13,12 @@
  *
  */
 @Service
-public class EventPuslisherAdapter implements EventPushlisher {
-
+public class EventPuslisherWebsocketAdapter implements EventPushlisher {
+	@Autowired private SimpMessagingTemplate messagingTemplate;
+
 	@Override
 	public void publishEvent(BusinessEvent event) {
-		// TODO Auto-generated method stub
-
+		messagingTemplate.convertAndSend("changes", event);
 	}
 
 }

hr-microservice-hexagonal/src/main/java/com/example/hr/config/WebsocketConfig.java

@@ -0,0 +1,23 @@
+package com.example.hr.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.simp.config.MessageBrokerRegistry;
+import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
+import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
+import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
+
+@Configuration
+@EnableWebSocketMessageBroker
+public class WebsocketConfig implements WebSocketMessageBrokerConfigurer {
+
+	@Override
+	public void configureMessageBroker(MessageBrokerRegistry registry) {
+		registry.enableSimpleBroker("/topic");
+		registry.setApplicationDestinationPrefixes("/ws");
+	}
+
+	@Override
+	public void registerStompEndpoints(StompEndpointRegistry registry) {
+		registry.addEndpoint("/changes").setAllowedOrigins("*").withSockJS();
+	}
+}

hr-microservice-hexagonal/src/main/resources/application.properties

@@ -1,10 +1,14 @@
+spring.main.banner-mode=off
 # REST API URL BASE
-# http://localhost:7001/hr/api/v1
+# http(s)://localhost:7001/hr/api/v1
 server.address=localhost
 server.port=7001
 server.servlet.context-path=/hr
 spring.mvc.servlet.path=/api/v1
 
+# WebSocket URL
+# ws://localhost:7001/hr/api/v1/changes
+
 major.version=1
 minor.version=0
 timestamp=1581420934