| 31 | main(); |
| 32 | |
| 33 | function sendMessageLoop(queuename) { |
| 34 | // push a message every 2 seconds into the queue |
| 35 | setInterval(() => { |
| 36 | // send the messages with a random delay between 0-5 seconds |
| 37 | rsmq.sendMessage({ qname: queuename, message: `Hello World at ${new Date().toISOString()}`, delay: Math.floor(Math.random() * 6) }, (err) => { |
| 38 | if (err) { |
| 39 | console.error(err); |
| 40 | return; |
| 41 | } |
| 42 | |
| 43 | console.log("pushed new message into queue.."); |
| 44 | }); |
| 45 | }, 2000); |
| 46 | } |
| 47 | |
| 48 | function receiveMessageLoop(queuename) { |
| 49 | // check for new messages every 2.5 seconds |