summaryrefslogtreecommitdiff
path: root/cpp/src
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-03-29 16:00:24 +0000
committerGordon Sim <gsim@apache.org>2010-03-29 16:00:24 +0000
commitc2b13417889ca05c880736e49bba91fb1ba4bd5d (patch)
treeea72ec14078104b05fba67b36eeabaa7654bc046 /cpp/src
parent5913593d7605f97535a4dc66ea9b39d46c64a142 (diff)
downloadqpid-python-c2b13417889ca05c880736e49bba91fb1ba4bd5d.tar.gz
QPID-664: move Variant and Uuid from messaging to types namespace
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@928814 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
-rw-r--r--cpp/src/CMakeLists.txt4
-rw-r--r--cpp/src/Makefile.am8
-rw-r--r--cpp/src/qpid/client/amqp0_10/AddressResolution.cpp8
-rw-r--r--cpp/src/qpid/client/amqp0_10/AddressResolution.h1
-rw-r--r--cpp/src/qpid/client/amqp0_10/Codecs.cpp7
-rw-r--r--cpp/src/qpid/client/amqp0_10/CodecsInternal.h6
-rw-r--r--cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp5
-rw-r--r--cpp/src/qpid/client/amqp0_10/ConnectionImpl.h8
-rw-r--r--cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp4
-rw-r--r--cpp/src/qpid/client/amqp0_10/ReceiverImpl.h1
-rw-r--r--cpp/src/qpid/client/amqp0_10/SenderImpl.h1
-rw-r--r--cpp/src/qpid/client/amqp0_10/SessionImpl.cpp1
-rw-r--r--cpp/src/qpid/client/amqp0_10/SessionImpl.h1
-rw-r--r--cpp/src/qpid/messaging/Address.cpp2
-rw-r--r--cpp/src/qpid/messaging/AddressParser.cpp2
-rw-r--r--cpp/src/qpid/messaging/AddressParser.h20
-rw-r--r--cpp/src/qpid/messaging/Connection.cpp2
-rw-r--r--cpp/src/qpid/messaging/ConnectionImpl.h8
-rw-r--r--cpp/src/qpid/messaging/ListContent.cpp2
-rw-r--r--cpp/src/qpid/messaging/ListView.cpp2
-rw-r--r--cpp/src/qpid/messaging/MapContent.cpp2
-rw-r--r--cpp/src/qpid/messaging/MapView.cpp2
-rw-r--r--cpp/src/qpid/messaging/Message.cpp2
-rw-r--r--cpp/src/qpid/messaging/MessageImpl.cpp2
-rw-r--r--cpp/src/qpid/messaging/MessageImpl.h8
-rw-r--r--cpp/src/qpid/types/Uuid.cpp (renamed from cpp/src/qpid/messaging/Uuid.cpp)6
-rw-r--r--cpp/src/qpid/types/Variant.cpp (renamed from cpp/src/qpid/messaging/Variant.cpp)6
-rw-r--r--cpp/src/tests/Address.cpp3
-rw-r--r--cpp/src/tests/MessagingSessionTests.cpp1
-rw-r--r--cpp/src/tests/Uuid.cpp16
-rw-r--r--cpp/src/tests/Variant.cpp4
-rw-r--r--cpp/src/tests/qpid_recv.cpp1
-rw-r--r--cpp/src/tests/qpid_send.cpp1
-rw-r--r--cpp/src/tests/qpid_stream.cpp1
34 files changed, 86 insertions, 62 deletions
diff --git a/cpp/src/CMakeLists.txt b/cpp/src/CMakeLists.txt
index 733b4848f9..40590993eb 100644
--- a/cpp/src/CMakeLists.txt
+++ b/cpp/src/CMakeLists.txt
@@ -567,6 +567,8 @@ set (qpidcommon_SOURCES
qpid/SessionId.cpp
qpid/StringUtils.cpp
qpid/Url.cpp
+ qpid/types/Uuid.cpp
+ qpid/types/Variant.cpp
qpid/amqp_0_10/SessionHandler.cpp
qpid/framing/AccumulatedAck.cpp
qpid/framing/AMQBody.cpp
@@ -690,8 +692,6 @@ set (qpidclient_SOURCES
qpid/messaging/SessionImpl.h
qpid/messaging/Sender.cpp
qpid/messaging/SenderImpl.h
- qpid/messaging/Uuid.cpp
- qpid/messaging/Variant.cpp
qpid/client/amqp0_10/AcceptTracker.h
qpid/client/amqp0_10/AcceptTracker.cpp
qpid/client/amqp0_10/AddressResolution.h
diff --git a/cpp/src/Makefile.am b/cpp/src/Makefile.am
index 2256ca7df0..7da7f42dcb 100644
--- a/cpp/src/Makefile.am
+++ b/cpp/src/Makefile.am
@@ -425,6 +425,8 @@ libqpidcommon_la_SOURCES += \
qpid/memory.h \
qpid/pointer_to_other.h \
qpid/ptr_map.h \
+ qpid/types/Uuid.cpp \
+ qpid/types/Variant.cpp \
qpid/sys/AggregateOutput.cpp \
qpid/sys/AggregateOutput.h \
qpid/sys/AsynchIO.h \
@@ -716,8 +718,6 @@ libqpidclient_la_SOURCES = \
qpid/messaging/Sender.cpp \
qpid/messaging/Receiver.cpp \
qpid/messaging/Session.cpp \
- qpid/messaging/Uuid.cpp \
- qpid/messaging/Variant.cpp \
qpid/messaging/ConnectionImpl.h \
qpid/messaging/SenderImpl.h \
qpid/messaging/ReceiverImpl.h \
@@ -830,8 +830,8 @@ nobase_include_HEADERS += \
../include/qpid/messaging/Receiver.h \
../include/qpid/messaging/Sender.h \
../include/qpid/messaging/Session.h \
- ../include/qpid/messaging/Uuid.h \
- ../include/qpid/messaging/Variant.h \
+ ../include/qpid/types/Uuid.h \
+ ../include/qpid/types/Variant.h \
../include/qpid/client/amqp0_10/Codecs.h \
../include/qpid/client/amqp0_10/FailoverUpdates.h
diff --git a/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp b/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp
index 9f2d4eef78..990b2a19d8 100644
--- a/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp
+++ b/cpp/src/qpid/client/amqp0_10/AddressResolution.cpp
@@ -26,7 +26,7 @@
#include "qpid/client/amqp0_10/OutgoingMessage.h"
#include "qpid/messaging/Address.h"
#include "qpid/messaging/Message.h"
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "qpid/Exception.h"
#include "qpid/log/Statement.h"
#include "qpid/framing/enum.h"
@@ -47,13 +47,13 @@ namespace amqp0_10 {
using qpid::Exception;
using qpid::messaging::Address;
using qpid::messaging::InvalidAddress;
-using qpid::messaging::Variant;
using qpid::framing::ExchangeBoundResult;
using qpid::framing::ExchangeQueryResult;
using qpid::framing::FieldTable;
using qpid::framing::QueueQueryResult;
using qpid::framing::ReplyTo;
using qpid::framing::Uuid;
+using namespace qpid::types;
using namespace qpid::framing::message;
using namespace boost::assign;
@@ -278,7 +278,7 @@ const Variant& getOption(const Variant::Map& options, const std::vector<std::str
if (j == options.end()) {
return EMPTY_VARIANT;
} else if (++index < path.size()) {
- if (j->second.getType() != qpid::messaging::VAR_MAP)
+ if (j->second.getType() != VAR_MAP)
throw InvalidAddress((boost::format("Expected %1% to be a map") % j->first).str());
return getOption(j->second.asMap(), path, index);
} else {
@@ -326,7 +326,7 @@ Opt& Opt::operator/(const std::string& name)
options = 0;
} else {
value = &(j->second);
- if (value->getType() == qpid::messaging::VAR_MAP) options = &(value->asMap());
+ if (value->getType() == VAR_MAP) options = &(value->asMap());
else options = 0;
}
}
diff --git a/cpp/src/qpid/client/amqp0_10/AddressResolution.h b/cpp/src/qpid/client/amqp0_10/AddressResolution.h
index 5b81b06131..fc8f1a1d18 100644
--- a/cpp/src/qpid/client/amqp0_10/AddressResolution.h
+++ b/cpp/src/qpid/client/amqp0_10/AddressResolution.h
@@ -21,7 +21,6 @@
* under the License.
*
*/
-#include "qpid/messaging/Variant.h"
#include "qpid/client/Session.h"
namespace qpid {
diff --git a/cpp/src/qpid/client/amqp0_10/Codecs.cpp b/cpp/src/qpid/client/amqp0_10/Codecs.cpp
index 3e17fc968b..ce806572e5 100644
--- a/cpp/src/qpid/client/amqp0_10/Codecs.cpp
+++ b/cpp/src/qpid/client/amqp0_10/Codecs.cpp
@@ -19,7 +19,7 @@
*
*/
#include "qpid/client/amqp0_10/Codecs.h"
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "qpid/framing/Array.h"
#include "qpid/framing/Buffer.h"
#include "qpid/framing/FieldTable.h"
@@ -32,6 +32,7 @@
using namespace qpid::framing;
using namespace qpid::messaging;
+using namespace qpid::types;
namespace qpid {
namespace client {
@@ -115,11 +116,11 @@ void setEncodingFor(Variant& out, uint8_t code)
}
}
-qpid::messaging::Uuid getUuid(FieldValue& value)
+qpid::types::Uuid getUuid(FieldValue& value)
{
unsigned char data[16];
value.getFixedWidthValue<16>(data);
- return qpid::messaging::Uuid(data);
+ return qpid::types::Uuid(data);
}
Variant toVariant(boost::shared_ptr<FieldValue> in)
diff --git a/cpp/src/qpid/client/amqp0_10/CodecsInternal.h b/cpp/src/qpid/client/amqp0_10/CodecsInternal.h
index b5a561a9c3..a110d80b8a 100644
--- a/cpp/src/qpid/client/amqp0_10/CodecsInternal.h
+++ b/cpp/src/qpid/client/amqp0_10/CodecsInternal.h
@@ -21,7 +21,7 @@
* under the License.
*
*/
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "qpid/framing/FieldTable.h"
namespace qpid {
@@ -33,8 +33,8 @@ namespace amqp0_10 {
* Codecs.cpp but not exposed through API
*/
-void translate(const qpid::messaging::Variant::Map& from, qpid::framing::FieldTable& to);
-void translate(const qpid::framing::FieldTable& from, qpid::messaging::Variant::Map& to);
+void translate(const qpid::types::Variant::Map& from, qpid::framing::FieldTable& to);
+void translate(const qpid::framing::FieldTable& from, qpid::types::Variant::Map& to);
}}} // namespace qpid::client::amqp0_10
diff --git a/cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp b/cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp
index ce4e1ecc2a..ee044aaf2b 100644
--- a/cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp
+++ b/cpp/src/qpid/client/amqp0_10/ConnectionImpl.cpp
@@ -32,7 +32,8 @@ namespace qpid {
namespace client {
namespace amqp0_10 {
-using qpid::messaging::Variant;
+using qpid::types::Variant;
+using qpid::types::VAR_LIST;
using qpid::framing::Uuid;
void convert(const Variant::List& from, std::vector<std::string>& to)
@@ -62,7 +63,7 @@ bool setIfFound< std::vector<std::string> >(const Variant::Map& map,
{
Variant::Map::const_iterator i = map.find(key);
if (i != map.end()) {
- if (i->second.getType() == qpid::messaging::VAR_LIST) {
+ if (i->second.getType() == VAR_LIST) {
convert(i->second.asList(), value);
} else {
value.push_back(i->second.asString());
diff --git a/cpp/src/qpid/client/amqp0_10/ConnectionImpl.h b/cpp/src/qpid/client/amqp0_10/ConnectionImpl.h
index 37a78b2373..2c59d8add8 100644
--- a/cpp/src/qpid/client/amqp0_10/ConnectionImpl.h
+++ b/cpp/src/qpid/client/amqp0_10/ConnectionImpl.h
@@ -22,7 +22,7 @@
*
*/
#include "qpid/messaging/ConnectionImpl.h"
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "qpid/Url.h"
#include "qpid/client/Connection.h"
#include "qpid/client/ConnectionSettings.h"
@@ -39,14 +39,14 @@ class SessionImpl;
class ConnectionImpl : public qpid::messaging::ConnectionImpl
{
public:
- ConnectionImpl(const qpid::messaging::Variant::Map& options);
+ ConnectionImpl(const qpid::types::Variant::Map& options);
void open(const std::string& url);
void close();
qpid::messaging::Session newSession(bool transactional, const std::string& name);
qpid::messaging::Session getSession(const std::string& name) const;
void closed(SessionImpl&);
void connect();
- void setOption(const std::string& name, const qpid::messaging::Variant& value);
+ void setOption(const std::string& name, const qpid::types::Variant& value);
private:
typedef std::map<std::string, qpid::messaging::Session> Sessions;
@@ -63,7 +63,7 @@ class ConnectionImpl : public qpid::messaging::ConnectionImpl
int64_t maxReconnectInterval;
int32_t retries;
- void setOptions(const qpid::messaging::Variant::Map& options);
+ void setOptions(const qpid::types::Variant::Map& options);
void connect(const qpid::sys::AbsTime& started);
bool tryConnect();
bool tryConnect(const std::vector<std::string>& urls);
diff --git a/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp b/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp
index 669ffd7e9a..8e501511e4 100644
--- a/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp
+++ b/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp
@@ -28,7 +28,7 @@
#include "qpid/messaging/Address.h"
#include "qpid/messaging/Message.h"
#include "qpid/messaging/MessageImpl.h"
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "qpid/framing/DeliveryProperties.h"
#include "qpid/framing/FrameSet.h"
#include "qpid/framing/MessageProperties.h"
@@ -44,7 +44,7 @@ using namespace qpid::framing::message;
using qpid::sys::AbsTime;
using qpid::sys::Duration;
using qpid::messaging::MessageImplAccess;
-using qpid::messaging::Variant;
+using qpid::types::Variant;
namespace {
const std::string EMPTY_STRING;
diff --git a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h
index 689a7f6f25..d509490688 100644
--- a/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h
+++ b/cpp/src/qpid/client/amqp0_10/ReceiverImpl.h
@@ -24,7 +24,6 @@
#include "qpid/messaging/Address.h"
#include "qpid/messaging/Message.h"
#include "qpid/messaging/ReceiverImpl.h"
-#include "qpid/messaging/Variant.h"
#include "qpid/client/AsyncSession.h"
#include "qpid/client/amqp0_10/SessionImpl.h"
#include "qpid/messaging/Duration.h"
diff --git a/cpp/src/qpid/client/amqp0_10/SenderImpl.h b/cpp/src/qpid/client/amqp0_10/SenderImpl.h
index 9e4181f42f..a99d4bd294 100644
--- a/cpp/src/qpid/client/amqp0_10/SenderImpl.h
+++ b/cpp/src/qpid/client/amqp0_10/SenderImpl.h
@@ -24,7 +24,6 @@
#include "qpid/messaging/Address.h"
#include "qpid/messaging/Message.h"
#include "qpid/messaging/SenderImpl.h"
-#include "qpid/messaging/Variant.h"
#include "qpid/client/AsyncSession.h"
#include "qpid/client/amqp0_10/SessionImpl.h"
#include <memory>
diff --git a/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp b/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
index 65308dd0be..245ec878be 100644
--- a/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
+++ b/cpp/src/qpid/client/amqp0_10/SessionImpl.cpp
@@ -43,7 +43,6 @@ using qpid::messaging::KeyError;
using qpid::messaging::MessageImplAccess;
using qpid::messaging::Sender;
using qpid::messaging::Receiver;
-using qpid::messaging::VariantMap;
namespace qpid {
namespace client {
diff --git a/cpp/src/qpid/client/amqp0_10/SessionImpl.h b/cpp/src/qpid/client/amqp0_10/SessionImpl.h
index a7eaae3cdd..a616db6239 100644
--- a/cpp/src/qpid/client/amqp0_10/SessionImpl.h
+++ b/cpp/src/qpid/client/amqp0_10/SessionImpl.h
@@ -23,7 +23,6 @@
*/
#include "qpid/messaging/SessionImpl.h"
#include "qpid/messaging/Duration.h"
-#include "qpid/messaging/Variant.h"
#include "qpid/client/Session.h"
#include "qpid/client/SubscriptionManager.h"
#include "qpid/client/amqp0_10/AddressResolution.h"
diff --git a/cpp/src/qpid/messaging/Address.cpp b/cpp/src/qpid/messaging/Address.cpp
index a5d0671360..2902b8fc4b 100644
--- a/cpp/src/qpid/messaging/Address.cpp
+++ b/cpp/src/qpid/messaging/Address.cpp
@@ -26,6 +26,8 @@
namespace qpid {
namespace messaging {
+using namespace qpid::types;
+
namespace {
const std::string SUBJECT_DIVIDER = "/";
const std::string OPTIONS_DIVIDER = ";";
diff --git a/cpp/src/qpid/messaging/AddressParser.cpp b/cpp/src/qpid/messaging/AddressParser.cpp
index 4b29f126f2..4f22410843 100644
--- a/cpp/src/qpid/messaging/AddressParser.cpp
+++ b/cpp/src/qpid/messaging/AddressParser.cpp
@@ -25,6 +25,8 @@
namespace qpid {
namespace messaging {
+using namespace qpid::types;
+
AddressParser::AddressParser(const std::string& s) : input(s), current(0) {}
bool AddressParser::error(const std::string& message)
diff --git a/cpp/src/qpid/messaging/AddressParser.h b/cpp/src/qpid/messaging/AddressParser.h
index 801b5cead1..a3f41eb04d 100644
--- a/cpp/src/qpid/messaging/AddressParser.h
+++ b/cpp/src/qpid/messaging/AddressParser.h
@@ -31,8 +31,8 @@ class AddressParser
public:
AddressParser(const std::string&);
bool parse(Address& address);
- bool parseMap(Variant::Map& map);
- bool parseList(Variant::List& list);
+ bool parseMap(qpid::types::Variant::Map& map);
+ bool parseList(qpid::types::Variant::List& list);
private:
const std::string& input;
std::string::size_type current;
@@ -40,15 +40,15 @@ class AddressParser
bool readChar(char c);
bool readQuotedString(std::string& s);
- bool readQuotedValue(Variant& value);
+ bool readQuotedValue(qpid::types::Variant& value);
bool readString(std::string& value, char delimiter);
bool readWord(std::string& word, const std::string& delims = RESERVED);
- bool readSimpleValue(Variant& word);
+ bool readSimpleValue(qpid::types::Variant& word);
bool readKey(std::string& key);
- bool readValue(Variant& value);
- bool readKeyValuePair(Variant::Map& map);
- bool readMap(Variant& value);
- bool readList(Variant& value);
+ bool readValue(qpid::types::Variant& value);
+ bool readKeyValuePair(qpid::types::Variant::Map& map);
+ bool readMap(qpid::types::Variant& value);
+ bool readList(qpid::types::Variant& value);
bool readName(std::string& name);
bool readSubject(std::string& subject);
bool error(const std::string& message);
@@ -56,8 +56,8 @@ class AddressParser
bool iswhitespace();
bool in(const std::string& delims);
bool isreserved();
- void readListItems(Variant::List& list);
- void readMapEntries(Variant::Map& map);
+ void readListItems(qpid::types::Variant::List& list);
+ void readMapEntries(qpid::types::Variant::Map& map);
};
}} // namespace qpid::messaging
diff --git a/cpp/src/qpid/messaging/Connection.cpp b/cpp/src/qpid/messaging/Connection.cpp
index cb06af7693..853ba1d100 100644
--- a/cpp/src/qpid/messaging/Connection.cpp
+++ b/cpp/src/qpid/messaging/Connection.cpp
@@ -30,6 +30,8 @@
namespace qpid {
namespace messaging {
+using namespace qpid::types;
+
typedef PrivateImplRef<qpid::messaging::Connection> PI;
Connection::Connection(ConnectionImpl* impl) { PI::ctor(*this, impl); }
diff --git a/cpp/src/qpid/messaging/ConnectionImpl.h b/cpp/src/qpid/messaging/ConnectionImpl.h
index 2f03c9610b..474f486736 100644
--- a/cpp/src/qpid/messaging/ConnectionImpl.h
+++ b/cpp/src/qpid/messaging/ConnectionImpl.h
@@ -25,10 +25,14 @@
#include "qpid/RefCounted.h"
namespace qpid {
+
+namespace types {
+class Variant;
+}
+
namespace messaging {
class Session;
-class Variant;
class ConnectionImpl : public virtual qpid::RefCounted
{
@@ -38,7 +42,7 @@ class ConnectionImpl : public virtual qpid::RefCounted
virtual void close() = 0;
virtual Session newSession(bool transactional, const std::string& name) = 0;
virtual Session getSession(const std::string& name) const = 0;
- virtual void setOption(const std::string& name, const Variant& value) = 0;
+ virtual void setOption(const std::string& name, const qpid::types::Variant& value) = 0;
private:
};
}} // namespace qpid::messaging
diff --git a/cpp/src/qpid/messaging/ListContent.cpp b/cpp/src/qpid/messaging/ListContent.cpp
index 038c1fad0b..4bd990e062 100644
--- a/cpp/src/qpid/messaging/ListContent.cpp
+++ b/cpp/src/qpid/messaging/ListContent.cpp
@@ -25,6 +25,8 @@
namespace qpid {
namespace messaging {
+using namespace qpid::types;
+
class ListContentImpl : public Variant
{
Message* msg;
diff --git a/cpp/src/qpid/messaging/ListView.cpp b/cpp/src/qpid/messaging/ListView.cpp
index b717d157fa..5cf453254f 100644
--- a/cpp/src/qpid/messaging/ListView.cpp
+++ b/cpp/src/qpid/messaging/ListView.cpp
@@ -25,6 +25,8 @@
namespace qpid {
namespace messaging {
+using namespace qpid::types;
+
class ListViewImpl : public Variant
{
public:
diff --git a/cpp/src/qpid/messaging/MapContent.cpp b/cpp/src/qpid/messaging/MapContent.cpp
index 1f190b85aa..11dcfbaf70 100644
--- a/cpp/src/qpid/messaging/MapContent.cpp
+++ b/cpp/src/qpid/messaging/MapContent.cpp
@@ -25,6 +25,8 @@
namespace qpid {
namespace messaging {
+using namespace qpid::types;
+
class MapContentImpl : public Variant
{
Message* msg;
diff --git a/cpp/src/qpid/messaging/MapView.cpp b/cpp/src/qpid/messaging/MapView.cpp
index ffa6e91a16..8bb0a724d2 100644
--- a/cpp/src/qpid/messaging/MapView.cpp
+++ b/cpp/src/qpid/messaging/MapView.cpp
@@ -25,6 +25,8 @@
namespace qpid {
namespace messaging {
+using namespace qpid::types;
+
class MapViewImpl : public Variant
{
public:
diff --git a/cpp/src/qpid/messaging/Message.cpp b/cpp/src/qpid/messaging/Message.cpp
index 4f8a358764..d953b3ff75 100644
--- a/cpp/src/qpid/messaging/Message.cpp
+++ b/cpp/src/qpid/messaging/Message.cpp
@@ -24,6 +24,8 @@
namespace qpid {
namespace messaging {
+using namespace qpid::types;
+
Message::Message(const std::string& bytes) : impl(new MessageImpl(bytes)) {}
Message::Message(const char* bytes, size_t count) : impl(new MessageImpl(bytes, count)) {}
diff --git a/cpp/src/qpid/messaging/MessageImpl.cpp b/cpp/src/qpid/messaging/MessageImpl.cpp
index 5d754ac487..5f8ac20551 100644
--- a/cpp/src/qpid/messaging/MessageImpl.cpp
+++ b/cpp/src/qpid/messaging/MessageImpl.cpp
@@ -28,6 +28,8 @@ namespace {
const std::string EMPTY_STRING = "";
}
+using namespace qpid::types;
+
MessageImpl::MessageImpl(const std::string& c) :
ttl(0),
durable(false),
diff --git a/cpp/src/qpid/messaging/MessageImpl.h b/cpp/src/qpid/messaging/MessageImpl.h
index bdbc1f6a1e..3898ff9f98 100644
--- a/cpp/src/qpid/messaging/MessageImpl.h
+++ b/cpp/src/qpid/messaging/MessageImpl.h
@@ -22,7 +22,7 @@
*
*/
#include "qpid/messaging/Address.h"
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "qpid/framing/SequenceNumber.h"
namespace qpid {
@@ -39,7 +39,7 @@ struct MessageImpl
uint64_t ttl;
bool durable;
bool redelivered;
- Variant::Map headers;
+ qpid::types::Variant::Map headers;
std::string bytes;
@@ -57,8 +57,8 @@ struct MessageImpl
void setContentType(const std::string& s);
const std::string& getContentType() const;
- const Variant::Map& getHeaders() const;
- Variant::Map& getHeaders();
+ const qpid::types::Variant::Map& getHeaders() const;
+ qpid::types::Variant::Map& getHeaders();
void setBytes(const std::string& bytes);
void setBytes(const char* chars, size_t count);
diff --git a/cpp/src/qpid/messaging/Uuid.cpp b/cpp/src/qpid/types/Uuid.cpp
index 87eb34456f..9face4e5d2 100644
--- a/cpp/src/qpid/messaging/Uuid.cpp
+++ b/cpp/src/qpid/types/Uuid.cpp
@@ -18,14 +18,14 @@
* under the License.
*
*/
-#include "qpid/messaging/Uuid.h"
+#include "qpid/types/Uuid.h"
#include "qpid/sys/uuid.h"
#include <sstream>
#include <iostream>
#include <string.h>
namespace qpid {
-namespace messaging {
+namespace types {
using namespace std;
@@ -137,4 +137,4 @@ std::string Uuid::str() const
return os.str();
}
-}} // namespace qpid::messaging
+}} // namespace qpid::types
diff --git a/cpp/src/qpid/messaging/Variant.cpp b/cpp/src/qpid/types/Variant.cpp
index 2567b7508b..3729b6c947 100644
--- a/cpp/src/qpid/messaging/Variant.cpp
+++ b/cpp/src/qpid/types/Variant.cpp
@@ -18,7 +18,7 @@
* under the License.
*
*/
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "qpid/Msg.h"
#include "qpid/log/Statement.h"
#include <boost/format.hpp>
@@ -27,7 +27,7 @@
#include <sstream>
namespace qpid {
-namespace messaging {
+namespace types {
InvalidConversion::InvalidConversion(const std::string& msg) : Exception(msg) {}
@@ -687,4 +687,4 @@ bool Variant::isEqualTo(const Variant& other) const
return impl->isEqualTo(*other.impl);
}
-}} // namespace qpid::messaging
+}} // namespace qpid::types
diff --git a/cpp/src/tests/Address.cpp b/cpp/src/tests/Address.cpp
index f25a27d231..01d8683efe 100644
--- a/cpp/src/tests/Address.cpp
+++ b/cpp/src/tests/Address.cpp
@@ -20,11 +20,12 @@
*/
#include <iostream>
#include "qpid/messaging/Address.h"
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "unit_test.h"
using namespace qpid::messaging;
+using namespace qpid::types;
namespace qpid {
namespace tests {
diff --git a/cpp/src/tests/MessagingSessionTests.cpp b/cpp/src/tests/MessagingSessionTests.cpp
index ef0685a508..56e86d101f 100644
--- a/cpp/src/tests/MessagingSessionTests.cpp
+++ b/cpp/src/tests/MessagingSessionTests.cpp
@@ -48,6 +48,7 @@ namespace tests {
QPID_AUTO_TEST_SUITE(MessagingSessionTests)
using namespace qpid::messaging;
+using namespace qpid::types;
using namespace qpid;
using qpid::broker::Broker;
using qpid::framing::Uuid;
diff --git a/cpp/src/tests/Uuid.cpp b/cpp/src/tests/Uuid.cpp
index 6d6c07169f..4c6505b139 100644
--- a/cpp/src/tests/Uuid.cpp
+++ b/cpp/src/tests/Uuid.cpp
@@ -18,7 +18,7 @@
#include "qpid/framing/Uuid.h"
#include "qpid/framing/Buffer.h"
-#include "qpid/messaging/Uuid.h"
+#include "qpid/types/Uuid.h"
#include "qpid/sys/alloca.h"
#include "unit_test.h"
@@ -80,15 +80,15 @@ QPID_AUTO_TEST_CASE(testUuidEncodeDecode) {
string(decoded.begin(), decoded.end()));
}
-QPID_AUTO_TEST_CASE(testMessagingUuid)
+QPID_AUTO_TEST_CASE(testTypesUuid)
{
- //tests for the Uuid class in the messaging namespace (introduced
+ //tests for the Uuid class in the types namespace (introduced
//to avoid pulling in dependencies from framing)
- messaging::Uuid a;
- messaging::Uuid b(true);
- messaging::Uuid c(true);
- messaging::Uuid d(b);
- messaging::Uuid e;
+ types::Uuid a;
+ types::Uuid b(true);
+ types::Uuid c(true);
+ types::Uuid d(b);
+ types::Uuid e;
e = c;
BOOST_CHECK(!a);
diff --git a/cpp/src/tests/Variant.cpp b/cpp/src/tests/Variant.cpp
index db9e419eab..0d456bc493 100644
--- a/cpp/src/tests/Variant.cpp
+++ b/cpp/src/tests/Variant.cpp
@@ -19,11 +19,11 @@
*
*/
#include <iostream>
-#include "qpid/messaging/Variant.h"
+#include "qpid/types/Variant.h"
#include "unit_test.h"
-using namespace qpid::messaging;
+using namespace qpid::types;
namespace qpid {
namespace tests {
diff --git a/cpp/src/tests/qpid_recv.cpp b/cpp/src/tests/qpid_recv.cpp
index 10738578ed..3ee8208a0b 100644
--- a/cpp/src/tests/qpid_recv.cpp
+++ b/cpp/src/tests/qpid_recv.cpp
@@ -34,6 +34,7 @@
#include <memory>
using namespace qpid::messaging;
+using namespace qpid::types;
using qpid::client::amqp0_10::FailoverUpdates;
using namespace std;
diff --git a/cpp/src/tests/qpid_send.cpp b/cpp/src/tests/qpid_send.cpp
index a8b0241a1d..eabcbdae21 100644
--- a/cpp/src/tests/qpid_send.cpp
+++ b/cpp/src/tests/qpid_send.cpp
@@ -33,6 +33,7 @@
#include <memory>
using namespace qpid::messaging;
+using namespace qpid::types;
using qpid::client::amqp0_10::FailoverUpdates;
typedef std::vector<std::string> string_vector;
diff --git a/cpp/src/tests/qpid_stream.cpp b/cpp/src/tests/qpid_stream.cpp
index 5ed7f84492..e451198ef4 100644
--- a/cpp/src/tests/qpid_stream.cpp
+++ b/cpp/src/tests/qpid_stream.cpp
@@ -32,6 +32,7 @@
#include <string>
using namespace qpid::messaging;
+using namespace qpid::types;
namespace qpid {
namespace tests {