Commit f9ff2f0

author

Rajeev Kumar Singh

committed

Added Example for a RabbitMQ message broker

1 parent 6512583 commit f9ff2f0Copy full SHA for f9ff2f0

File tree

+37

-7

lines changed

+37

-7

lines changed

Lines changed: 23 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -14,7 +14,7 @@`
`14`	`14`	`<parent>`
`15`	`15`	`<groupId>org.springframework.boot</groupId>`
`16`	`16`	`<artifactId>spring-boot-starter-parent</artifactId>`
`17`		`- <version>1.5.4.RELEASE</version>`
	`17`	`+ <version>1.5.9.RELEASE</version>`
`18`	`18`	`<relativePath/> <!-- lookup parent from repository -->`
`19`	`19`	`</parent>`
`20`	`20`
`@@ -29,6 +29,28 @@`
`29`	`29`	`<groupId>org.springframework.boot</groupId>`
`30`	`30`	`<artifactId>spring-boot-starter-websocket</artifactId>`
`31`	`31`	`</dependency>`
	`32`	`+`
	`33`	`+ <!-- RabbitMQ Starter Dependency (Not required if you're using the simple in-memory broker for STOMP) -->`
	`34`	`+ <dependency>`
	`35`	`+ <groupId>org.springframework.boot</groupId>`
	`36`	`+ <artifactId>spring-boot-starter-amqp</artifactId>`
	`37`	`+ </dependency>`
	`38`	`+`
	`39`	`+ <!-- Following three dependencies are required for STOMP Broker Relay -->`
	`40`	`+ <dependency>`
	`41`	`+ <groupId>io.projectreactor</groupId>`
	`42`	`+ <artifactId>reactor-core</artifactId>`
	`43`	`+ </dependency>`
	`44`	`+ <dependency>`
	`45`	`+ <groupId>io.projectreactor</groupId>`
	`46`	`+ <artifactId>reactor-net</artifactId>`
	`47`	`+ </dependency>`
	`48`	`+ <dependency>`
	`49`	`+ <groupId>io.netty</groupId>`
	`50`	`+ <artifactId>netty-all</artifactId>`
	`51`	`+ <version>4.1.19.Final</version>`
	`52`	`+ </dependency>`
	`53`	`+`
`32`	`54`	`<dependency>`
`33`	`55`	`<groupId>org.springframework.boot</groupId>`
`34`	`56`	`<artifactId>spring-boot-devtools</artifactId>`

Lines changed: 9 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,14 @@ public void registerStompEndpoints(StompEndpointRegistry registry) {`
`19`	`19`	`@Override`
`20`	`20`	`public void configureMessageBroker(MessageBrokerRegistry registry) {`
`21`	`21`	`registry.setApplicationDestinationPrefixes("/app");`
`22`		`- registry.enableSimpleBroker("/channel");`
	`22`	`+ registry.enableSimpleBroker("/topic"); // Enables a simple in-memory broker`
	`23`	`+`
	`24`	`+`
	`25`	`+ // Use this for enabling a Full featured broker like RabbitMQ`
	`26`	`+ registry.enableStompBrokerRelay("/topic")`
	`27`	`+ .setRelayHost("localhost")`
	`28`	`+ .setRelayPort(61613)`
	`29`	`+ .setClientLogin("guest")`
	`30`	`+ .setClientPasscode("guest");`
`23`	`31`	`}`
`24`	`32`	`}`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -14,13 +14,13 @@`
`14`	`14`	`public class ChatController {`
`15`	`15`
`16`	`16`	`@MessageMapping("/chat.sendMessage")`
`17`		`- @SendTo("/channel/public")`
	`17`	`+ @SendTo("/topic/public")`
`18`	`18`	`public ChatMessage sendMessage(@Payload ChatMessage chatMessage) {`
`19`	`19`	`return chatMessage;`
`20`	`20`	`}`
`21`	`21`
`22`	`22`	`@MessageMapping("/chat.addUser")`
`23`		`- @SendTo("/channel/public")`
	`23`	`+ @SendTo("/topic/public")`
`24`	`24`	`public ChatMessage addUser(@Payload ChatMessage chatMessage,`
`25`	`25`	`SimpMessageHeaderAccessor headerAccessor) {`
`26`	`26`	`// Add username in web socket session`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ public void handleWebSocketDisconnectListener(SessionDisconnectEvent event) {`
`39`	`39`	`chatMessage.setType(ChatMessage.MessageType.LEAVE);`
`40`	`40`	`chatMessage.setSender(username);`
`41`	`41`
`42`		`- messagingTemplate.convertAndSend("/channel/public", chatMessage);`
	`42`	`+ messagingTemplate.convertAndSend("/topic/public", chatMessage);`
`43`	`43`	`}`
`44`	`44`	`}`
`45`	`45`	`}`

Lines changed: 2 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -33,8 +33,8 @@ function connect(event) {`
`33`	`33`
`34`	`34`
`35`	`35`	`function onConnected() {`
`36`		`- // Subscribe to the Public Channel`
`37`		`- stompClient.subscribe('/channel/public', onMessageReceived);`
	`36`	`+ // Subscribe to the Public Topic`
	`37`	`+ stompClient.subscribe('/topic/public', onMessageReceived);`
`38`	`38`
`39`	`39`	`// Tell your username to the server`
`40`	`40`	`stompClient.send("/app/chat.addUser",`

Comments

(0)