Class ConnectionStateTracker

Namespace

Apache.NMS.ActiveMQ.State

Assembly

Apache.NMS.ActiveMQ.dll

public class ConnectionStateTracker : CommandVisitorAdapter, ICommandVisitor

Inheritance

object

CommandVisitorAdapter

ConnectionStateTracker

Implements

ICommandVisitor

Inherited Members

CommandVisitorAdapter.ProcessBrokerInfo(BrokerInfo)

CommandVisitorAdapter.ProcessFlushCommand(FlushCommand)

CommandVisitorAdapter.ProcessForgetTransaction(TransactionInfo)

CommandVisitorAdapter.ProcessKeepAliveInfo(KeepAliveInfo)

CommandVisitorAdapter.ProcessMessageDispatchNotification(MessageDispatchNotification)

CommandVisitorAdapter.ProcessProducerAck(ProducerAck)

CommandVisitorAdapter.ProcessRecoverTransactions(TransactionInfo)

CommandVisitorAdapter.ProcessRemoveSubscriptionInfo(RemoveSubscriptionInfo)

CommandVisitorAdapter.ProcessShutdownInfo(ShutdownInfo)

CommandVisitorAdapter.ProcessWireFormat(WireFormatInfo)

CommandVisitorAdapter.ProcessMessageDispatch(MessageDispatch)

CommandVisitorAdapter.ProcessControlCommand(ControlCommand)

CommandVisitorAdapter.ProcessConnectionControl(ConnectionControl)

CommandVisitorAdapter.ProcessConnectionError(ConnectionError)

CommandVisitorAdapter.ProcessConsumerControl(ConsumerControl)

CommandVisitorAdapter.ProcessResponse(Response)

CommandVisitorAdapter.ProcessReplayCommand(ReplayCommand)

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

ConnectionStateTracker()

public ConnectionStateTracker()

Fields

connectionStates

protected readonly Dictionary<ConnectionId, ConnectionState> connectionStates

Field Value

Dictionary<ConnectionId, ConnectionState>

Properties

MaxCacheSize

public int MaxCacheSize { get; set; }

Property Value

int

RestoreConsumers

public bool RestoreConsumers { get; set; }

Property Value

bool

RestoreProducers

public bool RestoreProducers { get; set; }

Property Value

bool

RestoreSessions

public bool RestoreSessions { get; set; }

Property Value

bool

RestoreTransaction

public bool RestoreTransaction { get; set; }

Property Value

bool

TrackMessages

public bool TrackMessages { get; set; }

Property Value

bool

TrackTransactionProducers

public bool TrackTransactionProducers { get; set; }

Property Value

bool

TrackTransactions

public bool TrackTransactions { get; set; }

Property Value

bool

Methods

ConnectionInterruptProcessingComplete(ITransport, ConnectionId)

public void ConnectionInterruptProcessingComplete(ITransport transport, ConnectionId connectionId)

Parameters

transport ITransport

connectionId ConnectionId

DoRestore(ITransport)

public void DoRestore(ITransport transport)

Parameters

transport ITransport

DoRestoreConsumers(ITransport, SessionState)

protected void DoRestoreConsumers(ITransport transport, SessionState sessionState)

Parameters

transport ITransport

sessionState SessionState

DoRestoreProducers(ITransport, SessionState)

protected void DoRestoreProducers(ITransport transport, SessionState sessionState)

Parameters

transport ITransport

sessionState SessionState

DoRestoreSessions(ITransport, ConnectionState)

protected void DoRestoreSessions(ITransport transport, ConnectionState connectionState)

Parameters

transport ITransport

connectionState ConnectionState

DoRestoreTempDestinations(ITransport, ConnectionState)

protected void DoRestoreTempDestinations(ITransport transport, ConnectionState connectionState)

Parameters

transport ITransport

connectionState ConnectionState

ProcessAddConnection(ConnectionInfo)

public override Response ProcessAddConnection(ConnectionInfo info)

Parameters

info ConnectionInfo

Returns

Response

ProcessAddConsumer(ConsumerInfo)

public override Response ProcessAddConsumer(ConsumerInfo info)

Parameters

info ConsumerInfo

Returns

Response

ProcessAddDestination(DestinationInfo)

public override Response ProcessAddDestination(DestinationInfo info)

Parameters

info DestinationInfo

Returns

Response

ProcessAddProducer(ProducerInfo)

public override Response ProcessAddProducer(ProducerInfo info)

Parameters

info ProducerInfo

Returns

Response

ProcessAddSession(SessionInfo)

public override Response ProcessAddSession(SessionInfo info)

Parameters

info SessionInfo

Returns

Response

ProcessBeginTransaction(TransactionInfo)

public override Response ProcessBeginTransaction(TransactionInfo info)

Parameters

info TransactionInfo

Returns

Response

ProcessCommitTransactionOnePhase(TransactionInfo)

public override Response ProcessCommitTransactionOnePhase(TransactionInfo info)

Parameters

info TransactionInfo

Returns

Response

ProcessCommitTransactionTwoPhase(TransactionInfo)

public override Response ProcessCommitTransactionTwoPhase(TransactionInfo info)

Parameters

info TransactionInfo

Returns

Response

ProcessEndTransaction(TransactionInfo)

public override Response ProcessEndTransaction(TransactionInfo info)

Parameters

info TransactionInfo

Returns

Response

ProcessMessage(Message)

public override Response ProcessMessage(Message send)

Parameters

send Message

Returns

Response

ProcessMessageAck(MessageAck)

public override Response ProcessMessageAck(MessageAck ack)

Parameters

ack MessageAck

Returns

Response

ProcessMessagePull(MessagePull)

public override Response ProcessMessagePull(MessagePull pull)

Parameters

pull MessagePull

Returns

Response

ProcessPrepareTransaction(TransactionInfo)

public override Response ProcessPrepareTransaction(TransactionInfo info)

Parameters

info TransactionInfo

Returns

Response

ProcessRemoveConnection(ConnectionId)

public override Response ProcessRemoveConnection(ConnectionId id)

Parameters

id ConnectionId

Returns

Response

ProcessRemoveConsumer(ConsumerId)

public override Response ProcessRemoveConsumer(ConsumerId id)

Parameters

id ConsumerId

Returns

Response

ProcessRemoveDestination(DestinationInfo)

public override Response ProcessRemoveDestination(DestinationInfo info)

Parameters

info DestinationInfo

Returns

Response

ProcessRemoveProducer(ProducerId)

public override Response ProcessRemoveProducer(ProducerId id)

Parameters

id ProducerId

Returns

Response

ProcessRemoveSession(SessionId)

public override Response ProcessRemoveSession(SessionId id)

Parameters

id SessionId

Returns

Response

ProcessRollbackTransaction(TransactionInfo)

public override Response ProcessRollbackTransaction(TransactionInfo info)

Parameters

info TransactionInfo

Returns

Response

Track(Command)

public Tracked Track(Command command)

Parameters

command Command

Returns

Tracked

TrackBack(Command)

public void TrackBack(Command command)

Parameters

command Command

TransportInterrupted(ConnectionId)

public void TransportInterrupted(ConnectionId id)

Parameters

id ConnectionId