Sending messages with Spring Messaging (Websockets) from a RabbitMQ Listener class

Question

Is it possible to send messages with SimpMessageSendingOperations from a RabbitMQ listener bean?

I have the following listener class:

 public class MyJobListener {
     @Autowired
     public SimpMessageSendingOperations messagingTemplate;

     public void handleJob(JobMessage jobMessage) {
         doWork(jobMessage);

         messagingTemplate.convertAndSend("/topic/greetings", "TEST");
     }
 }

My Rabbit config file is:

<!-- RabbitMQ configuration -->
<rabbit:connection-factory id="connectionFactory" host="${rabbitmq.connection.host}" port="${rabbitmq.connection.port}"  />
<rabbit:admin connection-factory="connectionFactory" /> 
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" />

<!-- Queues -->    
<rabbit:queue id="myQueue" name="myQueue" />

<!-- Listeners -->
<bean id="myListener01" class="com.xxx.MyJobListener" />
<bean id="myListener02" class="com.xxx.MyJobListener" />
<bean id="myListener03" class="com.xxx.MyJobListener" />
<bean id="myListener04" class="com.xxx.MyJobListener" />    

<rabbit:listener-container connection-factory="connectionFactory" >
    <rabbit:listener ref="myListener01" method="handleJob" queue-names="myQueue" />
    <rabbit:listener ref="myListener02" method="handleJob" queue-names="myQueue" />
    <rabbit:listener ref="myListener03" method="handleJob" queue-names="myQueue" />
    <rabbit:listener ref="myListener04" method="handleJob" queue-names="myQueue" />
</rabbit:listener-container>  

<!-- Bindings -->
<rabbit:direct-exchange name="directexchange" >
    <rabbit:bindings>        
        <rabbit:binding queue="myQueue"/>
    </rabbit:bindings>
</rabbit:direct-exchange> 

When message is expected to be sent (messagingTemplate.convertAndSend("/topic/greetings", "TEST")) nothing happens, but if I do the same thing but in a @Controller everything works fine (message is sent through websocket to the browser)

I need to do this to send a notification to the user when the job is finished.

Answer 1

After many tests I changed my rabbit configuration file, leaving only one listener:

<!-- Listeners -->
<bean id="myListener01" class="com.xxx.MyJobListener" />

<rabbit:listener-container connection-factory="connectionFactory" error-handler="queueErrorHandler" >
    <rabbit:listener ref="myListener01" method="handleJob" queue-names="myQueue" />
</rabbit:listener-container>

and now it works almost randomly. It's strange, but each 2 calls it works. I mean, two times yes, two times not, two times yes, two times not... and so... It's very strange. I think there is something with the rabbit config...

Answer 2

Definitely is Spring Security configuration. If I disable Spring Security everything works fine. I will find out what it is, and then I'll post the answer here.

Answer 3

I was able to solve it.

The problem was not Spring Security, the problem was I was declarating twice the websocket message broker:

<websocket:message-broker application-destination-prefix="/app" >
    <websocket:stomp-endpoint path="/websocket" >
        <websocket:sockjs />
    </websocket:stomp-endpoint>

     <websocket:simple-broker prefix="/topic,/user" />      
</websocket:message-broker> 

These lines resides in my websocket.xml, and this file was imported more than one time because of an "ugly" import sentences distributions along my .xml spring files.

After ordering these imports and ensuring the bean is only created once everything works fine.

May this helps!