Examples of use as a stream?

[giacecco]

Hi gdaws,
Can you offer an example of using Stompit as a stream, if it is possible? I would like to understand if it is feasible to do something like in the example below:

var writeStream = fs.createWriteStream('./path/to/file.ext');
stompit.connect(CONNECTION_PARAMETERS, function (err, client) {
    client.subscribe(SUBSCRIPTION_PARAMETERS).pipe(writeStream);
});

Thanks,

G.

[gdaws]

Here's an example of how to write messages to a file:

var writeStream = fs.createWriteStream('./path/to/file.ext');

stompit.connect(CONNECTION_PARAMETERS, function (err, client) {

  client.subscribe(SUBSCRIPTION_PARAMETERS, function onMessage(err, message) {

    message.on('end', function() {
      message.ack();
    });

    message.pipe(writeStream, {end: false});
  });
});

The onMessage function is called for each incoming message. The call for the next message is made after the end event of the current message.

The end: false option on the pipe call keeps the write stream open for the next message.

[giacecco]

Thanks!