read.js

var stompit = require('stompit');

let myClient;
 
const connectOptions = {
    host: 'localhost',
    port: 61613,
    connectHeaders: {
      host: '/',
      login: 'username',
      passcode: 'password',
      'heart-beat': '5000,5000',
    },
  };
 
stompit.connect(connectOptions, function(error, client) {

    myClient = client;
  
  if (error) {
    console.log('connect error ' + error.message);
    return;
  }
  
  var subscribeHeaders = {
    'destination': '/queue/test321',
    'ack': 'client-individual'
  };
  
  client.subscribe(subscribeHeaders, function(error, message) {
    
    if (error) {
      console.log('subscribe error ' + error.message);
      return;
    }

    setTimeout( () => myClient.disconnect(), 1000);
    
    message.readString('utf-8', function(error, body) {
      
      if (error) {
        console.log('read message error ' + error.message);
        return;
      }
      
      console.log('received message: ' + body);
      
      //client.ack(message);
      
      //client.disconnect();
    });
  });
});