18#ifndef _ACTIVEMQ_STATE_CONNECTIONSTATETRACKER_H_
19#define _ACTIVEMQ_STATE_CONNECTIONSTATETRACKER_H_
38 class RemoveTransactionAction;
39 class StateTrackerImpl;
44 StateTrackerImpl* impl;
46 bool trackTransactions;
48 bool restoreConsumers;
49 bool restoreProducers;
50 bool restoreTransaction;
52 bool trackTransactionProducers;
53 int maxMessageCacheSize;
54 int maxMessagePullCacheSize;
112 return this->restoreConsumers;
116 this->restoreConsumers = restoreConsumers;
120 return this->restoreProducers;
124 this->restoreProducers = restoreProducers;
128 return this->restoreSessions;
132 this->restoreSessions = restoreSessions;
136 return this->trackTransactions;
140 this->trackTransactions = trackTransactions;
144 return this->restoreTransaction;
148 this->restoreTransaction = restoreTransaction;
152 return this->trackMessages;
156 this->trackMessages = trackMessages;
160 return this->maxMessageCacheSize;
164 this->maxMessageCacheSize = maxMessageCacheSize;
168 return this->maxMessagePullCacheSize;
172 this->maxMessagePullCacheSize = maxMessagePullCacheSize;
176 return this->trackTransactionProducers;
180 this->trackTransactionProducers = trackTransactionProducers;
#define AMQCPP_API
Definition Config.h:30
Definition ConnectionId.h:51
Definition ConnectionInfo.h:49
Definition ConsumerId.h:48
Definition ConsumerInfo.h:51
Definition DestinationInfo.h:49
Definition MessagePull.h:49
Definition ProducerId.h:48
Definition ProducerInfo.h:50
Definition SessionId.h:51
Definition SessionInfo.h:48
Definition TransactionInfo.h:48
Default Implementation of a CommandVisitor that returns NULL for all calls.
Definition CommandVisitorAdapter.h:66
int getMaxMessageCacheSize() const
Definition ConnectionStateTracker.h:159
virtual decaf::lang::Pointer< Command > processEndTransaction(TransactionInfo *info)
virtual decaf::lang::Pointer< Command > processDestinationInfo(DestinationInfo *info)
friend class RemoveTransactionAction
Definition ConnectionStateTracker.h:56
void setTrackMessages(bool trackMessages)
Definition ConnectionStateTracker.h:155
virtual decaf::lang::Pointer< Command > processRemoveSession(SessionId *id)
virtual decaf::lang::Pointer< Command > processRollbackTransaction(TransactionInfo *info)
void setMaxMessagePullCacheSize(int maxMessagePullCacheSize)
Definition ConnectionStateTracker.h:171
bool isRestoreSessions() const
Definition ConnectionStateTracker.h:127
void setTrackTransactions(bool trackTransactions)
Definition ConnectionStateTracker.h:139
bool isTrackTransactionProducers() const
Definition ConnectionStateTracker.h:175
virtual decaf::lang::Pointer< Command > processRemoveProducer(ProducerId *id)
virtual decaf::lang::Pointer< Command > processPrepareTransaction(TransactionInfo *info)
virtual decaf::lang::Pointer< Command > processConsumerInfo(ConsumerInfo *info)
void restore(decaf::lang::Pointer< transport::Transport > transport)
void setRestoreSessions(bool restoreSessions)
Definition ConnectionStateTracker.h:131
virtual decaf::lang::Pointer< Command > processSessionInfo(SessionInfo *info)
virtual decaf::lang::Pointer< Command > processRemoveDestination(DestinationInfo *info)
virtual decaf::lang::Pointer< Command > processBeginTransaction(TransactionInfo *info)
void setMaxMessageCacheSize(int maxMessageCacheSize)
Definition ConnectionStateTracker.h:163
bool isTrackTransactions() const
Definition ConnectionStateTracker.h:135
virtual decaf::lang::Pointer< Command > processProducerInfo(ProducerInfo *info)
void trackBack(decaf::lang::Pointer< Command > command)
void setRestoreTransaction(bool restoreTransaction)
Definition ConnectionStateTracker.h:147
bool isRestoreTransaction() const
Definition ConnectionStateTracker.h:143
void setRestoreProducers(bool restoreProducers)
Definition ConnectionStateTracker.h:123
virtual decaf::lang::Pointer< Command > processCommitTransactionTwoPhase(TransactionInfo *info)
void transportInterrupted()
virtual ~ConnectionStateTracker()
virtual decaf::lang::Pointer< Command > processRemoveConsumer(ConsumerId *id)
virtual decaf::lang::Pointer< Command > processMessage(Message *message)
int getMaxMessagePullCacheSize() const
Definition ConnectionStateTracker.h:167
bool isTrackMessages() const
Definition ConnectionStateTracker.h:151
void setRestoreConsumers(bool restoreConsumers)
Definition ConnectionStateTracker.h:115
virtual decaf::lang::Pointer< Command > processRemoveConnection(ConnectionId *id)
Pointer< Tracked > track(Pointer< Command > command)
bool isRestoreConsumers() const
Definition ConnectionStateTracker.h:111
virtual decaf::lang::Pointer< Command > processCommitTransactionOnePhase(TransactionInfo *info)
void connectionInterruptProcessingComplete(transport::Transport *transport, decaf::lang::Pointer< ConnectionId > connectionId)
virtual decaf::lang::Pointer< Command > processMessagePull(MessagePull *pull)
bool isRestoreProducers() const
Definition ConnectionStateTracker.h:119
void setTrackTransactionProducers(bool trackTransactionProducers)
Definition ConnectionStateTracker.h:179
virtual decaf::lang::Pointer< Command > processConnectionInfo(ConnectionInfo *info)
Interface for a transport layer for command objects.
Definition Transport.h:60
Decaf's implementation of a Smart Pointer that is a template on a Type and is Thread Safe if the defa...
Definition Pointer.h:53
Definition AbstractTransportFactory.h:30
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24