Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
receiver.on(ReceiverEvents.message, (context: EventContext) => {
console.log("Received message: %O", context.message);
});
receiver.on(ReceiverEvents.receiverError, (context: EventContext) => {
const receiverError = context.receiver && context.receiver.error;
if (receiverError) {
console.log(
">>>>> [%s] An error occurred for receiver '%s': %O.",
connectionContext.connection.id,
receiverName,
receiverError
);
}
});
// sleeping for 2 mins to let the receiver receive messages and then closing it.
await delay(120000);
await receiver.close();
await connectionContext.connection.close();
}
receiver.on(ReceiverEvents.message, (context: EventContext) => {
console.log("Received message: %O", context.message);
});
receiver.on(ReceiverEvents.receiverError, (context: EventContext) => {
const receiverError = context.receiver && context.receiver.error;
if (receiverError) {
console.log(
">>>>> [%s] An error occurred for receiver '%s': %O.",
connectionContext.connection.id,
receiverName,
receiverError
);
}
});
// sleeping for 2 mins to let the receiver receive messages and then closing it.
await delay(120000);
await receiver.close();
await connectionContext.connection.close();
}
receiver.on(ReceiverEvents.message, (context: EventContext) => {
console.log("Received message: %O", context.message);
});
receiver.on(ReceiverEvents.receiverError, (context: EventContext) => {
const receiverError = context.receiver && context.receiver.error;
if (receiverError) {
console.log(
">>>>> [%s] An error occurred for receiver '%s': %O.",
connectionContext.connection.id,
receiverName,
receiverError
);
}
});
// sleeping for 2 mins to let the receiver receive messages and then closing it.
await delay(120000);
await receiver.close();
await connectionContext.connection.close();
}
console.log(`Received message: ${brokeredMessage.body} - ${brokeredMessage.label}`);
await brokeredMessage.complete();
};
const onErrorHandler: OnError = (err) => {
console.log("Error occurred: ", err);
};
console.log(`\nStarting receiver immediately at ${new Date(Date.now())}`);
let receiver = queueClient.createReceiver(ReceiveMode.peekLock);
receiver.registerMessageHandler(onMessageHandler, onErrorHandler);
await delay(5000);
await receiver.close();
console.log(`Received ${numOfMessagesReceived} messages.`);
await delay(5000);
receiver = queueClient.createReceiver(ReceiveMode.peekLock);
console.log(`\nStarting receiver at ${new Date(Date.now())}`);
receiver.registerMessageHandler(onMessageHandler, onErrorHandler);
await delay(5000);
await receiver.close();
console.log(`Received ${numOfMessagesReceived} messages.`);
await queueClient.close();
}
console.log(`\nStarting receiver immediately at ${new Date(Date.now())}`);
let receiver = queueClient.createReceiver(ReceiveMode.peekLock);
receiver.registerMessageHandler(onMessageHandler, onErrorHandler);
await delay(5000);
await receiver.close();
console.log(`Received ${numOfMessagesReceived} messages.`);
await delay(5000);
receiver = queueClient.createReceiver(ReceiveMode.peekLock);
console.log(`\nStarting receiver at ${new Date(Date.now())}`);
receiver.registerMessageHandler(onMessageHandler, onErrorHandler);
await delay(5000);
await receiver.close();
console.log(`Received ${numOfMessagesReceived} messages.`);
await queueClient.close();
}