Spring 4 WebSocket Remote Broker configuration

java spring spring-mvc websocket spring-4
Evgeni Dimitrov picture Evgeni Dimitrov · Dec 23, 2013 · Viewed 9.3k times · Source

I managed to create simple Websocket application with Spring 4 and Stomp. See my last question here Then I tried to use remote message broker(ActiveMQ). I just started the broker and changed 

registry.enableSimpleBroker("/topic");

to

registry.enableStompBrokerRelay("/topic");

and it worked.

The question is how the broker is configured? I understand that in this case the application automagicaly finds the broker on localhost:defaultport, bu what if I need to point the app to some other broker on other machine?

Answer

Brian Clozel picture Brian Clozel · Dec 27, 2013

The enableStompBrokerRelay method returns a convenient Registration instance that exposes a fluent API.

You can use this fluent API to configure your Broker relay:

registry.enableStompBrokerRelay("/topic").setRelayHost("host").setRelayPort("1234");

You can also configure various properties, like login/pass credentials for your broker, etc.

Same with XML Configuration:

<websocket:message-broker>
  <websocket:stomp-endpoint path="/foo">
    <websocket:handshake-handler ref="myHandler"/>
    <websocket:sockjs/>
  </websocket:stomp-endpoint>
  <websocket:stomp-broker-relay prefix="/topic,/queue" 
      relay-host="relayhost" relay-port="1234"
      client-login="clientlogin" client-passcode="clientpass"
      system-login="syslogin" system-passcode="syspass"
      heartbeat-send-interval="5000" heartbeat-receive-interval="5000"
      virtual-host="example.org"/>
</websocket:message-broker>

See the StompBrokerRelayRegistration javadoc for more details on properties and default values.

Related questions

Send Message to all clients via SimpMessagingTemplate in ServletContextListener

I'm using the Spring framework and I have a working websocket controller that looks like this: @Controller public class GreetingController { @MessageMapping("/hello") @SendTo("/topic/greetings") public Greeting greeting(HelloMessage message) throws InterruptedException { return new Greeting("Hello, " + message.getName() + "!"); } } I also …

Read More
how to capture subscribe event in my webSocket server with Spring 4

I did a simple web socket communication with spring 4, STOMP and sock.js, following this https://spring.io/guides/gs/messaging-stomp-websocket/ Now I want to upgrade it to simple chat. My problem is that when user subscribes to new chat …

Read More
What's the difference between @Component, @Repository & @Service annotations in Spring?

Can @Component, @Repository and @Service annotations be used interchangeably in Spring or do they provide any particular functionality besides acting as a notation device? In other words, if I have a Service class and I change the annotation from @Service …

Read More