Show / Hide Table of Contents

    Class ResponseCorrelator

    A Transport that correlates asynchronous send/receive messages into single request/response.

    Inheritance
    System.Object
    TransportFilter
    ResponseCorrelator
    Implements
    ITransport
    Apache.NMS.IStartable
    System.IDisposable
    Apache.NMS.IStoppable
    Inherited Members
    TransportFilter.next
    TransportFilter.commandHandler
    TransportFilter.exceptionHandler
    TransportFilter.interruptedHandler
    TransportFilter.resumedHandler
    TransportFilter.OnInterrupted(ITransport)
    TransportFilter.OnResumed(ITransport)
    TransportFilter.Request(Command)
    TransportFilter.Start()
    TransportFilter.IsStarted
    TransportFilter.Dispose()
    TransportFilter.Dispose(Boolean)
    TransportFilter.IsDisposed
    TransportFilter.Command
    TransportFilter.Exception
    TransportFilter.Interrupted
    TransportFilter.Resumed
    TransportFilter.Narrow(Type)
    TransportFilter.Timeout
    TransportFilter.AsyncTimeout
    TransportFilter.IsFaultTolerant
    TransportFilter.IsConnected
    TransportFilter.RemoteAddress
    TransportFilter.IsReconnectSupported
    TransportFilter.IsUpdateURIsSupported
    TransportFilter.UpdateURIs(Boolean, Uri[])
    TransportFilter.WireFormat
    System.Object.Equals(System.Object)
    System.Object.Equals(System.Object, System.Object)
    System.Object.GetHashCode()
    System.Object.GetType()
    System.Object.MemberwiseClone()
    System.Object.ReferenceEquals(System.Object, System.Object)
    System.Object.ToString()
    Namespace: Apache.NMS.ActiveMQ.Transport
    Assembly: Apache.NMS.ActiveMQ.dll
    Syntax
    public class ResponseCorrelator : TransportFilter, ITransport, IStartable, IDisposable, IStoppable

    Constructors

    | Improve this Doc View Source

    ResponseCorrelator(ITransport)

    Declaration
    public ResponseCorrelator(ITransport next)
    Parameters
    Type Name Description
    ITransport next

    Methods

    | Improve this Doc View Source

    AsyncRequest(Command)

    Declaration
    public override FutureResponse AsyncRequest(Command command)
    Parameters
    Type Name Description
    Command command
    Returns
    Type Description
    FutureResponse
    Overrides
    TransportFilter.AsyncRequest(Command)
    | Improve this Doc View Source

    OnCommand(ITransport, Command)

    Declaration
    protected override void OnCommand(ITransport sender, Command command)
    Parameters
    Type Name Description
    ITransport sender
    Command command
    Overrides
    TransportFilter.OnCommand(ITransport, Command)
    | Improve this Doc View Source

    Oneway(Command)

    Declaration
    public override void Oneway(Command command)
    Parameters
    Type Name Description
    Command command
    Overrides
    TransportFilter.Oneway(Command)
    | Improve this Doc View Source

    OnException(ITransport, Exception)

    Declaration
    protected override void OnException(ITransport sender, Exception command)
    Parameters
    Type Name Description
    ITransport sender
    System.Exception command
    Overrides
    TransportFilter.OnException(ITransport, Exception)
    | Improve this Doc View Source

    Request(Command, TimeSpan)

    Declaration
    public override Response Request(Command command, TimeSpan timeout)
    Parameters
    Type Name Description
    Command command
    System.TimeSpan timeout
    Returns
    Type Description
    Response
    Overrides
    TransportFilter.Request(Command, TimeSpan)
    | Improve this Doc View Source

    Stop()

    Declaration
    public override void Stop()
    Overrides
    TransportFilter.Stop()

    Implements

    ITransport
    Apache.NMS.IStartable
    System.IDisposable
    Apache.NMS.IStoppable
    • Improve this Doc
    • View Source
    Back to top Copyright � 2005-2019 Apache Software Foundation project
    Generated by DocFX