LIVE AZURE STORAGE QUEUE

Criar uma nova fila:

1
2odinAzureStorageQueue.createQueue("fila-raw").then(() => {
3    console.debug('fila criada com sucesso.');
4}, (err) => {
5    console.error('Houve um erro ao criar a fila.', err);
6});
7

Criar uma mensagem do tipo raw

O conteúdo da mensagem vai em texto puro.

1
2odinAzureStorageQueue.createRawMessage("fila-raw", "minha mensagem").then(() => {
3   console.debug('Mensagem colocada na fila com sucesso.');
4}, (err) => {
5    console.error('Houve um erro ao colocar a mensagem na fila.', err);
6});
7

Criar uma mensagem do tipo base64

Converte o conteúdo da mensagem para base64.

1
2odinAzureStorageQueue.createBase64Message("fila-base64", "minha mensagem").then(() => {
3    console.debug('Mensagem colocada na fila com sucesso.');
4}, (err) => {
5    console.error('Houve um erro ao colocar a mensagem na fila.', err);
6});
7

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.

1
2odinAzureStorageQueue.getMessage("fila-raw").then((message) => {
3    console.debug('Mensagem recebida: ', message);
4}, (err) => {
5    console.error('Houve um erro ao receber a mensagem na fila.', err);
6});
7

Remover uma mensagem da fila

1
2odinAzureStorageQueue.getMessage("fila-raw").then((message) => {
3    odinAzureStorageQueue.deleteMessage("fila-raw", message).then(() => {
4        console.debug('Mensagem removida da fila com sucesso.');
5    }, (err) => {
6        console.error('Houve um erro ao remover a mensagem da fila.', err);
7    });
8}, (err) => {
9    console.error('Houve um erro ao receber a mensagem na fila.', err);
10});
11

Utilizar um listener sempre ativo

1
2const meuListener = (message) => {
3    return new Promise((resolve) => {
4        console.debug('Mensagem recebida: ', message);
5        return resolve();
6    });
7}
8
9odinAzureStorageQueue.listen('fila-base64', meuListener, 10);
10