18#ifndef _ACTIVEMQ_STATE_CONNECTIONSTATE_H_
19#define _ACTIVEMQ_STATE_CONNECTIONSTATE_H_
45 using decaf::lang::Pointer;
46 using namespace decaf::util;
47 using namespace activemq::commands;
62 bool connectionInterruptProcessingComplete;
87 tempDestinations.add(info);
98 return transactions.get(
id.dynamicCast<LocalTransactionId>());
102 return transactions.values();
106 return transactions.remove(
id.dynamicCast<LocalTransactionId>());
115 return sessions.remove(
id);
119 return sessions.get(
id);
123 return tempDestinations;
127 return sessions.values();
131 return recoveringPullConsumers;
135 this->connectionInterruptProcessingComplete = connectionInterruptProcessingComplete;
139 return this->connectionInterruptProcessingComplete;
#define AMQCPP_API
Definition Config.h:30
decaf::lang::PointerComparator< ConsumerId > COMPARATOR
Definition ConsumerId.h:59
decaf::lang::PointerComparator< LocalTransactionId > COMPARATOR
Definition LocalTransactionId.h:65
decaf::lang::PointerComparator< SessionId > COMPARATOR
Definition SessionId.h:61
const Pointer< commands::ConnectionInfo > getInfo() const
Definition ConnectionState.h:75
const Pointer< SessionState > getSessionState(Pointer< SessionId > id) const
Definition ConnectionState.h:118
void addTransactionState(Pointer< TransactionId > id)
Definition ConnectionState.h:92
bool isConnectionInterruptProcessingComplete()
Definition ConnectionState.h:138
Pointer< TransactionState > removeTransactionState(Pointer< TransactionId > id)
Definition ConnectionState.h:105
ConnectionState(Pointer< ConnectionInfo > info)
std::string toString() const
void addTempDestination(Pointer< DestinationInfo > info)
Definition ConnectionState.h:85
const decaf::util::Collection< Pointer< SessionState > > & getSessionStates() const
Definition ConnectionState.h:126
virtual ~ConnectionState()
void reset(Pointer< ConnectionInfo > info)
const Pointer< TransactionState > & getTransactionState(Pointer< TransactionId > id) const
Definition ConnectionState.h:97
void addSession(Pointer< SessionInfo > info)
Definition ConnectionState.h:109
const LinkedList< Pointer< DestinationInfo > > & getTempDesinations() const
Definition ConnectionState.h:122
void removeTempDestination(Pointer< ActiveMQDestination > destination)
void checkShutdown() const
Pointer< SessionState > removeSession(Pointer< SessionId > id)
Definition ConnectionState.h:114
void setConnectionInterruptProcessingComplete(bool connectionInterruptProcessingComplete)
Definition ConnectionState.h:134
StlMap< Pointer< ConsumerId >, Pointer< ConsumerInfo >, ConsumerId::COMPARATOR > & getRecoveringPullConsumers()
Definition ConnectionState.h:130
const decaf::util::Collection< Pointer< TransactionState > > & getTransactionStates() const
Definition ConnectionState.h:101
Definition SessionState.h:41
Definition TransactionState.h:45
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
The root interface in the collection hierarchy.
Definition Collection.h:69
A complete implementation of the List interface using a doubly linked list data structure.
Definition LinkedList.h:55
Map template that wraps around a std::map to provide a more user-friendly interface and to provide co...
Definition StlMap.h:48
Map template that wraps around a std::map to provide a more user-friendly interface and to provide co...
Definition ConcurrentStlMap.h:51
A boolean value that may be updated atomically.
Definition AtomicBoolean.h:34
Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
Definition CachedConsumer.h:24