Class TransportFilter

Namespace

Apache.NMS.ActiveMQ.Transport

Assembly

Apache.NMS.ActiveMQ.dll

public class TransportFilter : ITransport, IStartable, IDisposable, IStoppable

Inheritance

object

TransportFilter

Implements

ITransport

IStartable

IDisposable

IStoppable

Derived

DiscoveryTransport

InactivityMonitor

LoggingTransport

MutexTransport

ResponseCorrelator

WireFormatNegotiator

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

TransportFilter(ITransport)

public TransportFilter(ITransport next)

Parameters

next ITransport

Fields

commandHandler

protected CommandHandler commandHandler

Field Value

CommandHandler

exceptionHandler

protected ExceptionHandler exceptionHandler

Field Value

ExceptionHandler

interruptedHandler

protected InterruptedHandler interruptedHandler

Field Value

InterruptedHandler

next

protected readonly ITransport next

Field Value

ITransport

resumedHandler

protected ResumedHandler resumedHandler

Field Value

ResumedHandler

Properties

AsyncTimeout

public int AsyncTimeout { get; set; }

Property Value

int

Command

public CommandHandler Command { get; set; }

Property Value

CommandHandler

Exception

public ExceptionHandler Exception { get; set; }

Property Value

ExceptionHandler

Interrupted

public InterruptedHandler Interrupted { get; set; }

Property Value

InterruptedHandler

IsConnected

public bool IsConnected { get; }

Property Value

bool

IsDisposed

public bool IsDisposed { get; }

Property Value

bool

IsFaultTolerant

public bool IsFaultTolerant { get; }

Property Value

bool

IsReconnectSupported

public bool IsReconnectSupported { get; }

Property Value

bool

IsStarted

public bool IsStarted { get; }

Property Value

bool

IsUpdateURIsSupported

public bool IsUpdateURIsSupported { get; }

Property Value

bool

RemoteAddress

public Uri RemoteAddress { get; }

Property Value

Uri

Resumed

public ResumedHandler Resumed { get; set; }

Property Value

ResumedHandler

Timeout

public int Timeout { get; set; }

Property Value

int

WireFormat

public IWireFormat WireFormat { get; }

Property Value

IWireFormat

Methods

AsyncRequest(Command)

public virtual FutureResponse AsyncRequest(Command command)

Parameters

command Command

Returns

FutureResponse

Dispose()

public void Dispose()

Dispose(bool)

protected virtual void Dispose(bool disposing)

Parameters

disposing bool

~TransportFilter()

protected ~TransportFilter()

Narrow(Type)

public object Narrow(Type type)

Parameters

type Type

Returns

object

OnCommand(ITransport, Command)

protected virtual void OnCommand(ITransport sender, Command command)

Parameters

sender ITransport

command Command

OnException(ITransport, Exception)

protected virtual void OnException(ITransport sender, Exception command)

Parameters

sender ITransport

command Exception

OnInterrupted(ITransport)

protected virtual void OnInterrupted(ITransport sender)

Parameters

sender ITransport

OnResumed(ITransport)

protected virtual void OnResumed(ITransport sender)

Parameters

sender ITransport

Oneway(Command)

public virtual void Oneway(Command command)

Parameters

command Command

Request(Command)

public virtual Response Request(Command command)

Parameters

command Command

Returns

Response

Request(Command, TimeSpan)

public virtual Response Request(Command command, TimeSpan timeout)

Parameters

command Command

timeout TimeSpan

Returns

Response

Start()

public virtual void Start()

Stop()

public virtual void Stop()

UpdateURIs(bool, Uri[])

public void UpdateURIs(bool rebalance, Uri[] updatedURIs)

Parameters

rebalance bool

updatedURIs Uri[]