odin-azure-storage-queue

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);