Class InactivityMonitor

Namespace

Apache.NMS.ActiveMQ.Transport

Assembly

Apache.NMS.ActiveMQ.dll

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

Inheritance

object

TransportFilter

InactivityMonitor

Implements

ITransport

IStartable

IDisposable

IStoppable

Inherited Members

TransportFilter.next

TransportFilter.commandHandler

TransportFilter.exceptionHandler

TransportFilter.interruptedHandler

TransportFilter.resumedHandler

TransportFilter.OnInterrupted(ITransport)

TransportFilter.OnResumed(ITransport)

TransportFilter.AsyncRequest(Command)

TransportFilter.Request(Command)

TransportFilter.Request(Command, TimeSpan)

TransportFilter.Start()

TransportFilter.Dispose()

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

InactivityMonitor(ITransport)

public InactivityMonitor(ITransport next)

Parameters

next ITransport

Properties

InitialDelayTime

public long InitialDelayTime { get; set; }

Property Value

long

KeepAliveResponseRequired

public bool KeepAliveResponseRequired { get; set; }

Property Value

bool

ReadCheckTime

public long ReadCheckTime { get; set; }

Property Value

long

WriteCheckTime

public long WriteCheckTime { get; set; }

Property Value

long

Methods

AllowReadCheck(TimeSpan)

public bool AllowReadCheck(TimeSpan elapsed)

Parameters

elapsed TimeSpan

Returns

bool

CheckConnection(object)

public void CheckConnection(object state)

Parameters

state object

Dispose(bool)

protected override void Dispose(bool disposing)

Parameters

disposing bool

~InactivityMonitor()

protected ~InactivityMonitor()

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

ReadCheck()

public void ReadCheck()

Stop()

public override void Stop()

WriteCheck()

public void WriteCheck()