Update from trunk r1375509 through r1450773asyncstore

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1451244 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 301 insertions, 0 deletions

diff --git a/cpp/src/qpid/amqp/MessageReader.h b/cpp/src/qpid/amqp/MessageReader.h
new file mode 100644
index 0000000000..5d26b288f5
--- /dev/null
+++ b/cpp/src/qpid/amqp/MessageReader.h
@@ -0,0 +1,301 @@
+#ifndef QPID_AMQP_MESSAGEREADER_H
+#define QPID_AMQP_MESSAGEREADER_H
+
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+#include "qpid/amqp/CharSequence.h"
+#include "qpid/amqp/Reader.h"
+#include "qpid/amqp/ListReader.h"
+#include "qpid/types/Variant.h"
+#include "qpid/CommonImportExport.h"
+
+namespace qpid {
+namespace amqp {
+
+/**
+ * Reader for an AMQP 1.0 message
+ */
+class MessageReader : public Reader
+{
+  public:
+    QPID_COMMON_EXTERN MessageReader();
+
+    //header, properties, amqp-sequence, amqp-value
+    QPID_COMMON_EXTERN bool onStartList(uint32_t, const CharSequence&, const Descriptor*);
+    QPID_COMMON_EXTERN void onEndList(uint32_t, const Descriptor*);
+
+    //delivery-annotations, message-annotations, application-headers, amqp-value
+    QPID_COMMON_EXTERN bool onStartMap(uint32_t, const CharSequence&, const Descriptor*);
+    QPID_COMMON_EXTERN void onEndMap(uint32_t, const Descriptor*);
+
+    //data, amqp-value
+    QPID_COMMON_EXTERN void onBinary(const CharSequence&, const Descriptor*);
+
+    //amqp-value
+    QPID_COMMON_EXTERN void onNull(const Descriptor*);
+    QPID_COMMON_EXTERN void onString(const CharSequence&, const Descriptor*);
+    QPID_COMMON_EXTERN void onSymbol(const CharSequence&, const Descriptor*);
+    QPID_COMMON_EXTERN void onBoolean(bool, const Descriptor*);
+    QPID_COMMON_EXTERN void onUByte(uint8_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onUShort(uint16_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onUInt(uint32_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onULong(uint64_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onByte(int8_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onShort(int16_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onInt(int32_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onLong(int64_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onFloat(float, const Descriptor*);
+    QPID_COMMON_EXTERN void onDouble(double, const Descriptor*);
+    QPID_COMMON_EXTERN void onUuid(const CharSequence&, const Descriptor*);
+    QPID_COMMON_EXTERN void onTimestamp(int64_t, const Descriptor*);
+    QPID_COMMON_EXTERN bool onStartArray(uint32_t, const CharSequence&, const Constructor&, const Descriptor*);
+    QPID_COMMON_EXTERN void onEndArray(uint32_t, const Descriptor*);
+    QPID_COMMON_EXTERN void onDescriptor(const Descriptor&, const char*);
+
+    //header:
+    virtual void onDurable(bool) = 0;
+    virtual void onPriority(uint8_t) = 0;
+    virtual void onTtl(uint32_t) = 0;
+    virtual void onFirstAcquirer(bool) = 0;
+    virtual void onDeliveryCount(uint32_t) = 0;
+
+    //properties:
+    virtual void onMessageId(uint64_t) = 0;
+    virtual void onMessageId(const CharSequence&, qpid::types::VariantType) = 0;
+    virtual void onUserId(const CharSequence&) = 0;
+    virtual void onTo(const CharSequence&) = 0;
+    virtual void onSubject(const CharSequence&) = 0;
+    virtual void onReplyTo(const CharSequence&) = 0;
+    virtual void onCorrelationId(uint64_t) = 0;
+    virtual void onCorrelationId(const CharSequence&, qpid::types::VariantType) = 0;
+    virtual void onContentType(const CharSequence&) = 0;
+    virtual void onContentEncoding(const CharSequence&) = 0;
+    virtual void onAbsoluteExpiryTime(int64_t) = 0;
+    virtual void onCreationTime(int64_t) = 0;
+    virtual void onGroupId(const CharSequence&) = 0;
+    virtual void onGroupSequence(uint32_t) = 0;
+    virtual void onReplyToGroupId(const CharSequence&) = 0;
+
+    virtual void onApplicationProperties(const CharSequence&) = 0;
+    virtual void onDeliveryAnnotations(const CharSequence&) = 0;
+    virtual void onMessageAnnotations(const CharSequence&) = 0;
+    virtual void onBody(const CharSequence&, const Descriptor&) = 0;
+    virtual void onBody(const qpid::types::Variant&, const Descriptor&) = 0;
+    virtual void onFooter(const CharSequence&) = 0;
+
+    QPID_COMMON_EXTERN CharSequence getBareMessage() const;
+
+  private:
+    /*
+    class DurableReader : public Reader
+    {
+      public:
+        DurableReader(MessageReader&);
+        void onBoolean(bool v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class PriorityReader : public Reader
+    {
+      public:
+        PriorityReader(MessageReader&);
+        void onUByte(uint8_t v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class TtlReader : public Reader
+    {
+      public:
+        TtlReader(MessageReader&);
+        void onUInt(uint32_t v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class FirstAcquirerReader : public Reader
+    {
+      public:
+        FirstAcquirerReader(MessageReader&);
+        void onBoolean(bool v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class DeliveryCountReader : public Reader
+    {
+      public:
+        DeliveryCountReader(MessageReader&);
+        void onUInt(uint32_t v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+
+    class MessageIdReader : public Reader
+    {
+      public:
+        MessageIdReader(MessageReader&);
+        void onUuid(const qpid::types::Uuid& v, const Descriptor*);
+        void onULong(uint64_t v, const Descriptor*);
+        void onString(const CharSequence& v, const Descriptor*);
+        void onBinary(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class UserIdReader : public Reader
+    {
+      public:
+        UserIdReader(MessageReader&);
+        void onBinary(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class ToReader : public Reader
+    {
+      public:
+        ToReader(MessageReader&);
+        void onString(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class SubjectReader : public Reader
+    {
+      public:
+        SubjectReader(MessageReader&);
+        void onString(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class ReplyToReader : public Reader
+    {
+      public:
+        ReplyToReader(MessageReader&);
+        void onString(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class CorrelationIdReader : public Reader
+    {
+      public:
+        CorrelationIdReader(MessageReader&);
+        void onUuid(const qpid::types::Uuid& v, const Descriptor*);
+        void onULong(uint64_t v, const Descriptor*);
+        void onString(const CharSequence& v, const Descriptor*);
+        void onBinary(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class ContentTypeReader : public Reader
+    {
+      public:
+        ContentTypeReader(MessageReader&);
+        void onString(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class ContentEncodingReader : public Reader
+    {
+      public:
+        ContentEncodingReader(MessageReader&);
+        void onString(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class AbsoluteExpiryTimeReader : public Reader
+    {
+      public:
+        AbsoluteExpiryTimeReader(MessageReader&);
+        void onTimestamp(int64_t v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class CreationTimeReader : public Reader
+    {
+      public:
+        CreationTimeReader(MessageReader&);
+        void onTimestamp(int64_t v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class GroupIdReader : public Reader
+    {
+      public:
+        GroupIdReader(MessageReader&);
+        void onString(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class GroupSequenceReader : public Reader
+    {
+      public:
+        GroupSequenceReader(MessageReader&);
+        void onUInt(uint32_t v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    class ReplyToGroupIdReader : public Reader
+    {
+      public:
+        ReplyToGroupIdReader(MessageReader&);
+        void onString(const CharSequence& v, const Descriptor*);
+      private:
+        MessageReader& parent;
+    };
+    */
+
+    class HeaderReader : public Reader //public ListReader
+    {
+      public:
+        //Reader& getReader(size_t index);
+
+        HeaderReader(MessageReader&);
+        void onBoolean(bool v, const Descriptor*);  // durable, first-acquirer
+        void onUByte(uint8_t v, const Descriptor*); // priority
+        void onUInt(uint32_t v, const Descriptor*); // ttl, delivery-count
+        void onNull(const Descriptor*);
+      private:
+        MessageReader& parent;
+        size_t index;
+    };
+    class PropertiesReader : public Reader //public ListReader
+    {
+      public:
+        //Reader& getReader(size_t index);
+
+        PropertiesReader(MessageReader&);
+        void onUuid(const CharSequence& v, const Descriptor*); // message-id, correlation-id
+        void onULong(uint64_t v, const Descriptor*); // message-id, correlation-id
+        void onBinary(const CharSequence& v, const Descriptor*); // message-id, correlation-id, user-id
+        void onString(const CharSequence& v, const Descriptor*); // message-id, correlation-id, group-id, reply-to-group-id, subject, to, reply-to
+        void onSymbol(const CharSequence& v, const Descriptor*); // content-type, content-encoding
+        void onTimestamp(int64_t v, const Descriptor*); // absolute-expiry-time, creation-time
+        void onUInt(uint32_t v, const Descriptor*); // group-sequence
+        void onNull(const Descriptor*);
+      private:
+        MessageReader& parent;
+        size_t index;
+    };
+    HeaderReader headerReader;
+    PropertiesReader propertiesReader;
+    Reader* delegate;
+    CharSequence bare;
+};
+}} // namespace qpid::amqp
+
+#endif  /*!QPID_AMQP_MESSAGEREADER_H*/