ES6 version: queue.js

queue.js

import Stomp from 'stomp-client';

const destination = 'pdp.integration';

const client1 = new Stomp('54.215.168.194', 62613);
const client2 = new Stomp('54.215.168.194', 62616);


export function updateTickets() {
  console.log('about to send message 1');
  client1.connect(function(sessionId) {
      console.log('sending a message!');

      client1.publish(destination, {
        eventName: 'PDP_Ticket_Balance_Change',
        accountNumber: '12341234',
        balance: 150,
        timestamp: Math.floor(new Date() / 1000),
      });
      return 'Published';
  },
  function(error) {
    console.log(error);
    return error;
  });

  if (client2) {
    console.log('about to send message 2');
    client2.connect(function(sessionId) {
        console.log('sending a message!');

        client2.publish(destination, {
          eventName: 'PDP_Ticket_Balance_Change',
          accountNumber: '12341234',
          balance: 150,
          timestamp: Math.floor(new Date() / 1000),
        });
        return 'Published';
    },
    function(error) {
      console.log(error);
      return error;
    });
  }
}