Managing offline messages

[m-frachet]

I didn't know where to ask this, and cant find it in the README or exemple, so I try there.

Is it possible, using RabbitJS, to manage offline messages when a user disconnects ?

The aim is to use it for Android Application and SocketIO even if there are network loss.

Can you tell me how should I do that ?

Here's my code :

var context = require('rabbit.js').createContext();
var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);

app.get('/', function (req, res) {
res.sendfile(__dirname + '/index.html');
});

server.listen(8888);

io.sockets.on('connection', function (socket) {
var pub = context.socket('PUB');
var sub = context.socket('SUB');
sub.setEncoding('utf8');
pub.connect('q');
sub.connect('q');

socket.on('message', function (msg) {
    pub.write(msg, 'utf8');
});

sub.on('data', function (msg) {
    socket.emit('news', msg);
});

/* On ferme les streams lorsqu'on se deco */
socket.on('disconnect', function () {
    pub.close();
    sub.close();
});

});

[squaremo]

This is not really encouraged, by design -- PUB/SUB sockets are meant to only collect messages while your application is running.

You may find it easier to encode what you want in amqplib (squaremo/amqp.node), which has full control over the lifetime of exchanges and queues and so on, at the cost of having to do things at a "lower level".