Class InactivityMonitor
This class make sure that the connection is still alive, by monitoring the reception of commands from the peer of the transport.
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 InactivityMonitor : TransportFilter, ITransport, IStartable, IDisposable, IStoppable
Constructors
| Improve this Doc View SourceInactivityMonitor(ITransport)
Constructor or the Inactivity Monitor
Declaration
public InactivityMonitor(ITransport next)
Parameters
Type | Name | Description |
---|---|---|
ITransport | next |
Properties
| Improve this Doc View SourceInitialDelayTime
Declaration
public long InitialDelayTime { get; set; }
Property Value
Type | Description |
---|---|
System.Int64 |
KeepAliveResponseRequired
Declaration
public bool KeepAliveResponseRequired { get; set; }
Property Value
Type | Description |
---|---|
System.Boolean |
ReadCheckTime
Declaration
public long ReadCheckTime { get; set; }
Property Value
Type | Description |
---|---|
System.Int64 |
WriteCheckTime
Declaration
public long WriteCheckTime { get; set; }
Property Value
Type | Description |
---|---|
System.Int64 |
Methods
| Improve this Doc View SourceAllowReadCheck(TimeSpan)
Checks if we should allow the read check(if less than 90% of the read check time elapsed then we dont do the readcheck
Declaration
public bool AllowReadCheck(TimeSpan elapsed)
Parameters
Type | Name | Description |
---|---|---|
System.TimeSpan | elapsed |
Returns
Type | Description |
---|---|
System.Boolean |
CheckConnection(Object)
Declaration
public void CheckConnection(object state)
Parameters
Type | Name | Description |
---|---|---|
System.Object | state |
Dispose(Boolean)
Declaration
protected override void Dispose(bool disposing)
Parameters
Type | Name | Description |
---|---|---|
System.Boolean | disposing |
Overrides
| Improve this Doc View SourceFinalize()
Declaration
protected void Finalize()
OnCommand(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 SourceReadCheck()
Declaration
public void ReadCheck()
Stop()
Declaration
public override void Stop()
Overrides
| Improve this Doc View SourceWriteCheck()
Check the write to the broker
Declaration
public void WriteCheck()
Implements
Apache.NMS.IStartable
System.IDisposable
Apache.NMS.IStoppable