Class ResponseCorrelator

Namespace

Apache.NMS.ActiveMQ.Transport

Assembly

Apache.NMS.ActiveMQ.dll

public class ResponseCorrelator : TransportFilter, ITransport, IStartable, IDisposable, IStoppable

Inheritance

object

TransportFilter

ResponseCorrelator

Implements

ITransport

IStartable

IDisposable

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.Dispose()

TransportFilter.Dispose(bool)

TransportFilter.Narrow(Type)

TransportFilter.UpdateURIs(bool, Uri[])

TransportFilter.IsStarted

TransportFilter.IsDisposed

TransportFilter.Command

TransportFilter.Exception

TransportFilter.Interrupted

TransportFilter.Resumed

TransportFilter.Timeout

TransportFilter.AsyncTimeout

TransportFilter.IsFaultTolerant

TransportFilter.IsConnected

TransportFilter.RemoteAddress

TransportFilter.IsReconnectSupported

TransportFilter.IsUpdateURIsSupported

TransportFilter.WireFormat

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ResponseCorrelator(ITransport)

public ResponseCorrelator(ITransport next)

Parameters

next ITransport

Methods

AsyncRequest(Command)

public override FutureResponse AsyncRequest(Command command)

Parameters

command Command

Returns

FutureResponse

OnCommand(ITransport, Command)

protected override void OnCommand(ITransport sender, Command command)

Parameters

sender ITransport

command Command

OnException(ITransport, Exception)

protected override void OnException(ITransport sender, Exception command)

Parameters

sender ITransport

command Exception

Oneway(Command)

public override void Oneway(Command command)

Parameters

command Command

Request(Command, TimeSpan)

public override Response Request(Command command, TimeSpan timeout)

Parameters

command Command

timeout TimeSpan

Returns

Response

Stop()

public override void Stop()