Class ResponseCorrelator
A Transport that correlates asynchronous send/receive messages into single request/response.
Inherited Members
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 SourceResponseCorrelator(ITransport)
Declaration
public ResponseCorrelator(ITransport next)
Parameters
| Type | Name | Description |
|---|---|---|
| ITransport | next |
Methods
| Improve this Doc View SourceAsyncRequest(Command)
Declaration
public override FutureResponse AsyncRequest(Command command)
Parameters
| Type | Name | Description |
|---|---|---|
| Command | command |
Returns
| Type | Description |
|---|---|
| FutureResponse |
Overrides
| Improve this Doc View SourceOnCommand(ITransport, Command)
Declaration
protected override void OnCommand(ITransport sender, Command command)
Parameters
| Type | Name | Description |
|---|---|---|
| ITransport | sender | |
| Command | command |
Overrides
| Improve this Doc View SourceOneway(Command)
Declaration
public override void Oneway(Command command)
Parameters
| Type | Name | Description |
|---|---|---|
| Command | command |
Overrides
| Improve this Doc View SourceOnException(ITransport, Exception)
Declaration
protected override void OnException(ITransport sender, Exception command)
Parameters
| Type | Name | Description |
|---|---|---|
| ITransport | sender | |
| System.Exception | command |
Overrides
| Improve this Doc View SourceRequest(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
| Improve this Doc View SourceStop()
Declaration
public override void Stop()
Overrides
Implements
Apache.NMS.IStartable
System.IDisposable
Apache.NMS.IStoppable