2.0.0 • Published 5 years ago
odin-azure-storage-queue v2.0.0
LIVE AZURE STORAGE QUEUE
Criar uma nova fila:
odinAzureStorageQueue.createQueue("fila-raw").then(() => {
console.debug('fila criada com sucesso.');
}, (err) => {
console.error('Houve um erro ao criar a fila.', err);
});
Criar uma mensagem do tipo raw
O conteúdo da mensagem vai em texto puro.
odinAzureStorageQueue.createRawMessage("fila-raw", "minha mensagem").then(() => {
console.debug('Mensagem colocada na fila com sucesso.');
}, (err) => {
console.error('Houve um erro ao colocar a mensagem na fila.', err);
});
Criar uma mensagem do tipo base64
Converte o conteúdo da mensagem para base64.
odinAzureStorageQueue.createBase64Message("fila-base64", "minha mensagem").then(() => {
console.debug('Mensagem colocada na fila com sucesso.');
}, (err) => {
console.error('Houve um erro ao colocar a mensagem na fila.', err);
});
O método createMessage tem um parametro opcional 'options', que pode receber
quaisquer dos parametros disponíveis na bibliotecaa oficial da microsoft.
Este parametro não é obrigatório.
Ler uma mensagem de uma fila
Indiferente de ser uma mensagem do tipo raw ou base64, o método getMessage é o mesmo. O conteúdo da mensagem será retornado como texto puro.
odinAzureStorageQueue.getMessage("fila-raw").then((message) => {
console.debug('Mensagem recebida: ', message);
}, (err) => {
console.error('Houve um erro ao receber a mensagem na fila.', err);
});
Remover uma mensagem da fila
odinAzureStorageQueue.getMessage("fila-raw").then((message) => {
odinAzureStorageQueue.deleteMessage("fila-raw", message).then(() => {
console.debug('Mensagem removida da fila com sucesso.');
}, (err) => {
console.error('Houve um erro ao remover a mensagem da fila.', err);
});
}, (err) => {
console.error('Houve um erro ao receber a mensagem na fila.', err);
});
Utilizar um listener sempre ativo
const meuListener = (message) => {
return new Promise((resolve) => {
console.debug('Mensagem recebida: ', message);
return resolve();
});
}
odinAzureStorageQueue.listen('fila-base64', meuListener, 10);