Клиент Socket.io не работает должным образом

Я создал приложение чата, используя следующие

1. Рельсы
2. Rabbitmq
3. nodejs (с amqplib/callback_api и socket.io)

У меня есть следующий код на стороне сервера

var amqp = require('amqplib/callback_api');
var amqpConn = null;

var app = require('http').createServer()
var io = require('socket.io')(app);
var fs = require('fs');

io.on('connection', function (socket) {
        socket.emit('news/1', msg.content.toString());
        // socket.disconnect()
});

сторона клиента

<%= javascript_include_tag "http://localhost:53597/socket.io/socket.io.js"  %>
<script>



var socket = io('http://localhost:53597', {reconnect: true});

  socket.on('connect', function () {
    console.log('connected');

    socket.on('news/1', function (msg) {
      console.log('inside coming');
      console.log(msg);
    });
  });

</script>

Когда я отправляю сообщение, сообщение успешно помещается в очередь, а сообщения отправляются в сокет. Проблема в том, что я могу получать сообщения, когда только обновляю страницу, а сообщения не удаляются.

Я не могу понять, что здесь не так?