DerbyJS model manipulation

gistfile1.js

var model = store.createModel();

// Creation of AMQP connection, exchange and queue

model.subscribe('messages', function(err, messages) {
  model.on('set', 'messages.*', function(id, message) {
    exchange.publish('collector', message);
  });

  queue.subscribe(function (message, headers, deliveryInfo) {
    model.set('messages.' + message.id, message);
  });
});