ServiceBusSessionProcessor Classe

Inicializa uma nova instância da ServiceBusSessionProcessor classe para simulação.

Inicializa uma nova instância da ServiceBusSessionProcessor classe para uso com tipos derivados.

Inicializa uma nova instância da ServiceBusSessionProcessor classe para uso com tipos derivados.

Obtém um valor que indica se o processador deve concluir automaticamente as mensagens depois que o manipulador de mensagens concluir o processamento. Se o manipulador de mensagens disparar uma exceção, a mensagem não será concluída automaticamente.

Obtém o caminho da entidade do Barramento de Serviço à qual o processador está conectado, específico ao namespace do Barramento de Serviço que o contém.

Obtém o namespace do Barramento de Serviço totalmente qualificado ao qual o receptor está associado. É provável que isso seja semelhante a {yournamespace}.servicebus.windows.net.

Obtém o Identificador usado para identificar esse cliente processador. Se null ou estiver vazio, um valor exclusivo aleatório será usado.

O ServiceBusProcessor para o qual o processador de sessão delega. Isso pode ser substituído para fins de teste.

Indica se isso ServiceBusSessionProcessor foi ou não fechado.

Obtém se esse processador está processando ou não mensagens no momento.

Obtém a duração máxima dentro da qual o bloqueio de sessão será renovado automaticamente.

Obtém o número máximo de chamadas para o retorno de chamada que o processador iniciará por sessão. Portanto, o número total de retornos de chamada será igual a MaxConcurrentSessions * MaxConcurrentCallsPerSession. O valor padrão é 1.

Obtém o número máximo de sessões que serão processadas simultaneamente pelo processador. O valor padrão é 8.

Obtém o número de mensagens que serão solicitadas ansiosamente de Filas ou Assinaturas durante o processamento. Isso se destina a ajudar a maximizar a taxa de transferência, permitindo que o processador receba de um cache local em vez de aguardar uma solicitação de serviço.

Obtém o ReceiveMode usado para especificar como as mensagens são recebidas. O padrão é o modo PeekLock.

Obtém o tempo máximo de espera para que uma mensagem seja recebida para a sessão ativa no momento. Decorrido esse tempo, o processador fechará a sessão e tentará processar outra sessão. Se não for especificado, o TryTimeout será usado.

Executa a tarefa necessária para limpo recursos usados pelo ServiceBusSessionProcessor.

Executa a tarefa necessária para limpo recursos usados pelo ServiceBusSessionProcessor. Isso é equivalente a chamar CloseAsync(CancellationToken).

Invoca o manipulador de eventos de erro quando ocorreu um erro durante o processamento. Esse método pode ser substituído para gerar um evento manualmente para fins de teste.

Invoca o manipulador de eventos de mensagem de processo depois que uma mensagem é recebida. Esse método pode ser substituído para gerar um evento manualmente para fins de teste.

Invoca o manipulador de eventos de fechamento de sessão quando uma sessão está prestes a ser fechada para processamento. Esse método pode ser substituído para gerar um evento manualmente para fins de teste.

Invoca o manipulador de eventos abertos da sessão quando uma nova sessão está prestes a ser processada. Esse método pode ser substituído para gerar um evento manualmente para fins de teste.

Sinaliza o processador para começar a processar mensagens. Se esse método for chamado enquanto o processador já estiver em execução, um InvalidOperationException será lançado.

Sinaliza ao processador para interromper o processamento de mensagens. Se esse método for chamado enquanto o processador não estiver em execução, nenhuma ação será executada. Esse método não fechará os receptores subjacentes, mas fará com que os receptores parem de receber. Todos os manipuladores de mensagens em andamento serão aguardados e esse método não retornará até que todos os manipuladores de mensagens em andamento tenham retornado. Para fechar os receptores subjacentes, CloseAsync(CancellationToken) deve ser chamado. Se CloseAsync(CancellationToken) for chamado, o processador não poderá ser reiniciado. Se você quiser retomar o processamento em algum momento depois de chamar esse método, poderá chamar StartProcessingAsync(CancellationToken).

Atualizações a simultaneidade do processador. Esse método pode ser usado para alterar dinamicamente a simultaneidade de um processador em execução.

Atualizações a contagem de pré-busca para o processador. Esse método pode ser usado para alterar dinamicamente a contagem de pré-busca de um processador em execução.

O manipulador responsável por processar exceções sem tratamento geradas enquanto esse processador está em execução. A implementação é obrigatória.

O manipulador responsável pelo processamento de mensagens recebidas da Fila ou assinatura. A implementação é obrigatória.

Manipulador opcional que pode ser definido para ser notificado quando uma sessão está prestes a ser fechada para processamento. Isso significa que a chamada mais recente ReceiveMessageAsync(Nullable<TimeSpan>, CancellationToken) atingiu o tempo limite ou que ReleaseSession() foi chamada no ProcessMessageAsync manipulador.

Manipulador opcional que pode ser definido para ser notificado quando uma nova sessão está prestes a ser processada.