Class FailoverTransport

Namespace

Apache.NMS.ActiveMQ.Transport.Failover

Assembly

Apache.NMS.ActiveMQ.dll

public class FailoverTransport : ICompositeTransport, ITransport, IStartable, IDisposable, IStoppable, IComparable

Inheritance

object

FailoverTransport

Implements

ICompositeTransport

ITransport

IStartable

IDisposable

IStoppable

IComparable

Inherited Members

object.GetType()

object.MemberwiseClone()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

FailoverTransport()

public FailoverTransport()

Properties

AsyncConnect

public bool AsyncConnect { set; }

Property Value

bool

AsyncTimeout

public int AsyncTimeout { get; set; }

Property Value

int

Backup

public bool Backup { get; set; }

Property Value

bool

BackupPoolSize

public int BackupPoolSize { get; set; }

Property Value

int

Command

public CommandHandler Command { get; set; }

Property Value

CommandHandler

ConnectedTransport

public ITransport ConnectedTransport { get; set; }

Property Value

ITransport

ConnectedTransportURI

public Uri ConnectedTransportURI { get; set; }

Property Value

Uri

Exception

public ExceptionHandler Exception { get; set; }

Property Value

ExceptionHandler

InitialReconnectDelay

public int InitialReconnectDelay { get; set; }

Property Value

int

Interrupted

public InterruptedHandler Interrupted { get; set; }

Property Value

InterruptedHandler

IsConnected

public bool IsConnected { get; }

Property Value

bool

IsConnectedToPriority

public bool IsConnectedToPriority { 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

MaxCacheSize

public int MaxCacheSize { get; set; }

Property Value

int

MaxReconnectAttempts

public int MaxReconnectAttempts { get; set; }

Property Value

int

MaxReconnectDelay

public int MaxReconnectDelay { get; set; }

Property Value

int

PriorityBackup

public bool PriorityBackup { get; set; }

Property Value

bool

PriorityURIs

public string PriorityURIs { get; set; }

Property Value

string

Randomize

public bool Randomize { get; set; }

Property Value

bool

ReconnectDelay

public int ReconnectDelay { get; set; }

Property Value

int

ReconnectDelayExponent

public int ReconnectDelayExponent { get; set; }

Property Value

int

RemoteAddress

public Uri RemoteAddress { get; }

Property Value

Uri

Resumed

public ResumedHandler Resumed { get; set; }

Property Value

ResumedHandler

StartupMaxReconnectAttempts

public int StartupMaxReconnectAttempts { get; set; }

Property Value

int

StateTracker

public ConnectionStateTracker StateTracker { get; }

Property Value

ConnectionStateTracker

Timeout

public int Timeout { get; set; }

Property Value

int

TrackMessages

public bool TrackMessages { get; set; }

Property Value

bool

TrackTransactionProducers

public bool TrackTransactionProducers { get; set; }

Property Value

bool

UseExponentialBackOff

public bool UseExponentialBackOff { get; set; }

Property Value

bool

WireFormat

public IWireFormat WireFormat { get; }

Property Value

IWireFormat

Methods

Add(bool, string)

public void Add(bool rebalance, string u)

Parameters

rebalance bool

u string

Add(bool, Uri[])

public void Add(bool rebalance, Uri[] urisToAdd)

Parameters

rebalance bool

urisToAdd Uri[]

AsyncRequest(Command)

public FutureResponse AsyncRequest(Command command)

Parameters

command Command

Returns

FutureResponse

CompareTo(object)

public int CompareTo(object o)

Parameters

o object

Returns

int

ConnectionInterruptProcessingComplete(ConnectionId)

public void ConnectionInterruptProcessingComplete(ConnectionId connectionId)

Parameters

connectionId ConnectionId

Dispose()

public void Dispose()

Dispose(bool)

public void Dispose(bool disposing)

Parameters

disposing bool

DisposeTransport(ITransport)

public void DisposeTransport(ITransport transport)

Parameters

transport ITransport

DisposedOnCommand(ITransport, Command)

public void DisposedOnCommand(ITransport sender, Command c)

Parameters

sender ITransport

c Command

DisposedOnException(ITransport, Exception)

public void DisposedOnException(ITransport sender, Exception e)

Parameters

sender ITransport

e Exception

~FailoverTransport()

protected ~FailoverTransport()

HandleConnectionControl(ConnectionControl)

public void HandleConnectionControl(ConnectionControl control)

Parameters

control ConnectionControl

HandleTransportFailure(Exception)

public void HandleTransportFailure(Exception e)

Parameters

e Exception

Narrow(Type)

public object Narrow(Type type)

Parameters

type Type

Returns

object

OnCommand(ITransport, Command)

public void OnCommand(ITransport sender, Command command)

Parameters

sender ITransport

command Command

OnException(ITransport, Exception)

public void OnException(ITransport sender, Exception error)

Parameters

sender ITransport

error Exception

Oneway(Command)

public void Oneway(Command command)

Parameters

command Command

Reconnect(bool)

public void Reconnect(bool rebalance)

Parameters

rebalance bool

Reconnect(Uri)

public void Reconnect(Uri uri)

Parameters

uri Uri

Remove(bool, string)

public void Remove(bool rebalance, string u)

Parameters

rebalance bool

u string

Remove(bool, Uri[])

public void Remove(bool rebalance, Uri[] u)

Parameters

rebalance bool

u Uri[]

Request(Command)

public Response Request(Command command)

Parameters

command Command

Returns

Response

Request(Command, TimeSpan)

public Response Request(Command command, TimeSpan ts)

Parameters

command Command

ts TimeSpan

Returns

Response

RestoreTransport(ITransport)

protected void RestoreTransport(ITransport t)

Parameters

t ITransport

Shuffle<T>(List<T>)

public void Shuffle<T>(List<T> list)

Parameters

list List<T>

Type Parameters

T

Start()

public void Start()

Stop()

public virtual void Stop()

ToString()

public override string ToString()

Returns

string

UpdateURIs(bool, Uri[])

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

Parameters

rebalance bool

updatedURIs Uri[]