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