live-azure-queue v1.1.0

##LIVE-AZURE-QUEUE

Tratamento de filas (servicebus) da azure.

##adicionar uma mensagem na fila:

const liveAzureQueue = require('live-azure-queue');

const mensagemJSON = {};

liveAzureQueue.addMessage('nome-fila', mensagemJSON).then(() => {
    // Sua mensagem foi adicionada na fila com sucesso.
}, (err) => {
    // Houve um erro ao adicionar a mensagem.
});

Configurações avançadas

A função recebe um parametro de configuração com os seguintes valores default:

const configuracao = {
    idCliente: "",
    retryCount: 3,
    serviceBus: null
};

idCliente é enviado em todas as mensagens, e pode ser utilizado no momento da leitura da mensagem, por exemplo para resolver um dataSource, ou saber qual cliente que originou aquela mensagem.

retryCount diz respeito a quantas tentativas a aplicação deve fazer ao enviar a fila. Como se trata de uma operação via rede, é comum acontecer uma falha de conexão, que faz com que a mensagem não seja entregue, porém... ao tentar novamente a mensagem é entregue com sucesso.

Por padrão, são realizadas três tentativas de envio. Só retornará um erro, se a terceira tentativa falhar.

Caso seja informado valor 0, retornará erro logo na primeira tentativa sem sucesso.

´serviceBus´ é a instância do Service Bus para qual serão enviadas as mensagens. Caso não seja enviado um valor (null), será criada uma nova conexão com o ServiceBus, baseado na variável de ambiente AZURE_SERVICEBUS_CONNECTION_STRING.

*Se você tiver um processo que adicionar várias mensagens à fila em um curto espaço de tempo, é recomentado por questões de performance, que seja criada uma conexão com o ServiceBus e enviada como parâmetro, sempre a mesma conexão.

####Exemplo:

const liveAzureQueue = require('live-azure-queue');
const azure = require('azure');

const mensagemJSON = {};

const serviceBus = azure.createServiceBusService();

const configuracao = {
    idCliente: "123",
    retryCount: 0,
    serviceBus: serviceBus
};


liveAzureQueue.addMessage('nome-fila', mensagemJSON, configuracao).then(() => {
    // Sua mensagem foi adicionada na fila com sucesso.
}, (err) => {
    // Houve um erro ao adicionar a mensagem.
});

Leitura de mensagens da fila:

A leitura de mensagens, espera como parametros o nome da fila, e uma Promise, que será executada, recebendo como parâmtro a mensagem lida da fila. Ao resolver ou rejeitar a Promise, a função volta a aguardar uma nova mensagem.

const liveAzureQueue = require('live-azure-quee');

liveAzureQueue.listen('nome-fila', minhaPromise);

###Configurações avançadas

TODO...