Exportar (0) Imprimir
Expandir todo

Clase OnMessageOptions

Proporciona opciones asociadas con el procesamiento del bombeo de mensajes con el uso de OnMessage(Action<(Of <<'(BrokeredMessage>)>>)) y OnMessage(Action<(Of <<'(BrokeredMessage>)>>)).

System..::..Object
  Microsoft.ServiceBus.Messaging..::..OnMessageOptions

Espacio de nombres:  Microsoft.ServiceBus.Messaging
Ensamblado:  Microsoft.ServiceBus (en Microsoft.ServiceBus.dll)

public sealed class OnMessageOptions

El tipo OnMessageOptions expone los siguientes miembros.

  NombreDescripción
Método públicoOnMessageOptionsInicializa una nueva instancia de la clase OnMessageOptions.
Arriba

  NombreDescripción
Propiedad públicaAutoCompleteObtiene o establece un valor que indica si el bombeo de mensajes debería llamar Complete(Guid) o Complete(Guid) en los mensajes una vez completado el procesamiento de la llamada.
Propiedad públicaAutoRenewTimeoutObtiene o establece el tiempo necesario para que la sesión se renueve automáticamente.
Propiedad públicaMaxConcurrentCallsObtiene o establece el número máximo de llamadas simultáneas a la llamada que debería iniciar el bombeo de mensajes.
Arriba

  NombreDescripción
Método públicoEquals (Se hereda de Object.)
Método públicoGetHashCode (Se hereda de Object.)
Método públicoGetType (Se hereda de Object.)
Método públicoToString (Se hereda de Object.)
Arriba

  NombreDescripción
Evento públicoExceptionReceivedSe produce cuando se recibe una excepción. Le permite recibir notificación de los errores que se encuentran en el bombeo de mensajes.
Arriba

When calling OnMessage()()()(), the client starts an internal message pump that constantly polls the queue or subscription. This message pump consists of an infinite loop that issues a Receive() call. If the call times out, it issues the next Receive() call. The timeout is the value of the OperationTimeout property of the MessagingFactory that is used. The default value of this timeout is 60 seconds. You can modify the timeout by changing the OperationTimeout property before creating the MessagingFactory. Note that every receive operation is a billable event.

void ReceiveMessages()
{
    // Initialize message pump options.
    OnMessageOptions options = new OnMessageOptions();
    options.AutoComplete = true; // Indicates if the message-pump should call complete on messages after the callback has completed processing.
    options.MaxConcurrentCalls = 1; // Indicates the maximum number of concurrent calls to the callback the pump should initiate.
    options.ExceptionReceived += LogErrors; // Enables you to get notified of any errors encountered by the message pump.

    // Start receiving messages.
    QueueClient client = QueueClient.Create("myQueue");
    client.OnMessage((receivedMessage) => // Initiates the message pump and callback is invoked for each message that is recieved, calling close on the client will stop the pump.
    {
        // Process the message.
    }, options);

    Console.WriteLine("Press any key to exit.");
    Console.ReadKey();
}

        void LogErrors(object sender, ExceptionReceivedEventArgs e)
        {
            if (e.Exception != null)
            {
                Console.WriteLine("Error: " + e.Exception.Message);
                Client.Close();
            }
        }

Cualquier miembro público static (Shared en Visual Basic) de este tipo es seguro para subprocesos. No se garantiza que los miembros de instancia sean seguros para subprocesos.

Adiciones de comunidad

AGREGAR
Mostrar:
© 2014 Microsoft