Processing messages

function GetMessages(): QueueMsg[];

type QueueMsg = {
  receivedAt: Date; // JavaScript Date object
  queue:      string;
  message:    string;
}

Inside the loop where you call GetMessages() repeatedly, always check for a halt signal to allow the script to terminate cleanly.

Example

ConsoleFeedback = true;
var cli = new AmqpClient091();
cli.URL = 'amqp://localhost:5672';
cli.User = 'guest';
cli.Pass = 'guest';
if (cli.Connect()) {
  cli.MonitorQueue('myqueue');
  while (true) {
    Sleep(1000);
    if (HaltSignalReceived()) {
      break;
    }
    var msgs = cli.GetMessages();
    if (msgs.length > 0) {
      Log(JSON.stringify(msgs));
    }
  }
  cli.Close();
}
cli = null;