Creating a branch for experimenting with some ideas for JMS client.rajith_jms_client

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

13 files changed, 0 insertions, 1526 deletions

diff --git a/cpp/include/qmf/engine/Agent.h b/cpp/include/qmf/engine/Agent.h
deleted file mode 100644
index 71abf82254..0000000000
--- a/cpp/include/qmf/engine/Agent.h
+++ /dev/null
@@ -1,209 +0,0 @@
-#ifndef _QmfEngineAgent_
-#define _QmfEngineAgent_
-
-/*
- * 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 <qmf/engine/Schema.h>
-#include <qmf/engine/ObjectId.h>
-#include <qmf/engine/Object.h>
-#include <qmf/engine/Event.h>
-#include <qmf/engine/Query.h>
-#include <qmf/engine/Value.h>
-#include <qmf/engine/Message.h>
-
-namespace qmf {
-namespace engine {
-
-    /**
-     * AgentEvent
-     *
-     *  This structure represents a QMF event coming from the agent to
-     *  the application.
-     */
-    struct AgentEvent {
-        enum EventKind {
-            GET_QUERY      = 1,
-            START_SYNC     = 2,
-            END_SYNC       = 3,
-            METHOD_CALL    = 4,
-            DECLARE_QUEUE  = 5,
-            DELETE_QUEUE   = 6,
-            BIND           = 7,
-            UNBIND         = 8,
-            SETUP_COMPLETE = 9
-        };
-
-        EventKind    kind;
-        uint32_t     sequence;    // Protocol sequence (for all kinds)
-        char*        authUserId;  // Authenticated user ID (for all kinds)
-        char*        authToken;   // Authentication token if issued (for all kinds)
-        char*        name;        // Name of the method/sync query
-                                  //    (METHOD_CALL, START_SYNC, END_SYNC, DECLARE_QUEUE, BIND, UNBIND)
-        Object*      object;      // Object involved in method call (METHOD_CALL)
-        ObjectId*    objectId;    // ObjectId for method call (METHOD_CALL)
-        Query*       query;       // Query parameters (GET_QUERY, START_SYNC)
-        Value*       arguments;   // Method parameters (METHOD_CALL)
-        char*        exchange;    // Exchange for bind (BIND, UNBIND)
-        char*        bindingKey;  // Key for bind (BIND, UNBIND)
-        const SchemaObjectClass* objectClass; // (METHOD_CALL)
-    };
-
-    class AgentImpl;
-
-    /**
-     * Agent - Protocol engine for the QMF agent
-     */
-    class Agent {
-    public:
-        Agent(char* label, bool internalStore=true);
-        ~Agent();
-
-        /**
-         * Configure the directory path for storing persistent data.
-         *@param path Null-terminated string containing a directory path where files can be
-         *            created, written, and read.  If NULL, no persistent storage will be
-         *            attempted.
-         */
-        void setStoreDir(const char* path);
-
-        /**
-         * Configure the directory path for files transferred over QMF.
-         *@param path Null-terminated string containing a directory path where files can be
-         *            created, deleted, written, and read.  If NULL, file transfers shall not
-         *            be permitted.
-         */
-        void setTransferDir(const char* path);
-
-        /**
-         * Pass messages received from the AMQP session to the Agent engine.
-         *@param message AMQP messages received on the agent session.
-         */
-        void handleRcvMessage(Message& message);
-
-        /**
-         * Get the next message to be sent to the AMQP network.
-         *@param item The Message structure describing the message to be produced.
-         *@return true if the Message is valid, false if there are no messages to send.
-         */
-        bool getXmtMessage(Message& item) const;
-
-        /**
-         * Remove and discard one message from the head of the transmit queue.
-         */
-        void popXmt();
-
-        /**
-         * Get the next application event from the agent engine.
-         *@param event The event iff the return value is true
-         *@return true if event is valid, false if there are no events to process
-         */
-        bool getEvent(AgentEvent& event) const;
-
-        /**
-         * Remove and discard one event from the head of the event queue.
-         */
-        void popEvent();
-
-        /**
-         * A new AMQP session has been established for Agent communication.
-         */
-        void newSession();
-
-        /**
-         * Start the QMF Agent protocol.  This should be invoked after a SETUP_COMPLETE event
-         * is received from the Agent engine.
-         */
-        void startProtocol();
-
-        /**
-         * This method is called periodically so the agent can supply a heartbeat.
-         */
-        void heartbeat();
-
-        /**
-         * Respond to a method request.
-         *@param sequence  The sequence number from the method request event.
-         *@param status    The method's completion status.
-         *@param text      Status text ("OK" or an error message)
-         *@param arguments The list of output arguments from the method call.
-         */
-        void methodResponse(uint32_t sequence, uint32_t status, char* text, const Value& arguments);
-
-        /**
-         * Send a content indication to the QMF bus.  This is only needed for objects that are
-         * managed by the application.  This is *NOT* needed for objects managed by the Agent
-         * (inserted using addObject).
-         *@param sequence The sequence number of the GET request or the SYNC_START request.
-         *@param object   The object (annotated with "changed" flags) for publication.
-         *@param prop     If true, changed object properties are transmitted.
-         *@param stat     If true, changed object statistics are transmitted.
-         */
-        void queryResponse(uint32_t sequence, Object& object, bool prop = true, bool stat = true);
-
-        /**
-         * Indicate the completion of a query.  This is not used for SYNC_START requests.
-         *@param sequence The sequence number of the GET request.
-         */
-        void queryComplete(uint32_t sequence);
-
-        /**
-         * Register a schema class with the Agent.
-         *@param cls A SchemaObejctClass object that defines data managed by the agent.
-         */
-        void registerClass(SchemaObjectClass* cls);
-
-        /**
-         * Register a schema class with the Agent.
-         *@param cls A SchemaEventClass object that defines events sent by the agent.
-         */
-        void registerClass(SchemaEventClass* cls);
-
-        /**
-         * Give an object to the Agent for storage and management.  Once added, the agent takes
-         * responsibility for the life cycle of the object.
-         *@param obj       The object to be managed by the Agent.
-         *@param persistId A unique non-zero value if the object-id is to be persistent.
-         *@return The objectId of the managed object.
-         */
-        const ObjectId* addObject(Object& obj, uint64_t persistId);
-        //        const ObjectId* addObject(Object& obj, uint32_t persistIdLo, uint32_t persistIdHi);
-
-        /**
-         * Allocate an object-id for an object that will be managed by the application.
-         *@param persistId A unique non-zero value if the object-id is to be persistent.
-         *@return The objectId structure for the allocated ID.
-         */
-        const ObjectId* allocObjectId(uint64_t persistId);
-        const ObjectId* allocObjectId(uint32_t persistIdLo, uint32_t persistIdHi);
-
-        /**
-         * Raise an event into the QMF network..
-         *@param event The event object for the event to be raised.
-         */
-        void raiseEvent(Event& event);
-
-    private:
-        AgentImpl* impl;
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/ConnectionSettings.h b/cpp/include/qmf/engine/ConnectionSettings.h
deleted file mode 100644
index 36312400b1..0000000000
--- a/cpp/include/qmf/engine/ConnectionSettings.h
+++ /dev/null
@@ -1,150 +0,0 @@
-#ifndef _QmfEngineConnectionSettings_
-#define _QmfEngineConnectionSettings_
-
-/*
- * 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 "qmf/engine/QmfEngineImportExport.h"
-#include "qpid/sys/IntegerTypes.h"
-
-namespace qmf {
-namespace engine {
-
-    class ConnectionSettingsImpl;
-    class Value;
-
-    /**
-     * Settings for AMQP connections to the broker.
-     *
-     * \ingroup qmfapi
-     */
-    class ConnectionSettings {
-    public:
-
-        /**
-         * Create a set of default connection settings.
-         *
-         * If no further attributes are set, the settings will cause a connection to be made to
-         * the default broker (on localhost or at a host/port supplied by service discovery) and
-         * authentication will be the best-available (GSSAPI/Kerberos, Anonymous, Plain with prompts
-         * for username and password).
-         */
-        QMFE_EXTERN ConnectionSettings();
-
-        /**
-         * Create a set of connection settings by URL.
-         *
-         * @param url Universal resource locator describing the broker address and additional attributes.
-         *
-         * The URL is of the form:
-         *    amqp[s]://host[:port][?key=value[&key=value]*]
-         *
-         * For example:
-         *    amqp://localhost
-         *    amqp://broker?transport=rdma&authmech=GSSAPI&authservice=qpidd
-         *    amqps://broker?authmech=PLAIN&authuser=guest&authpass=guest
-         */
-        QMFE_EXTERN ConnectionSettings(const char* url);
-
-        /**
-         * Copy Constructor.
-         */
-        ConnectionSettings(const ConnectionSettings& from);
-
-        /**
-         * Destroy the connection settings object.
-         */
-        QMFE_EXTERN ~ConnectionSettings();
-
-        /**
-         * Set an attribute to control connection setup.
-         *
-         * @param key A null-terminated string that is an attribute name.
-         *
-         * @param value Reference to a value to be stored as the attribute.  The type of the value
-         *              is specific to the key.
-         *
-         * @return True if success, False if invalid attribute
-         */
-        QMFE_EXTERN bool setAttr(const char* key, const Value& value);
-
-        /**
-         * Get the value of an attribute.
-         *
-         * @param key A null-terminated attribute name.
-         *
-         * @return The value associated with the attribute name.
-         */
-        QMFE_EXTERN Value getAttr(const char* key) const;
-
-        /**
-         * Get the attribute string (the portion of the URL following the '?') for the settings.
-         *
-         * @return A pointer to the attribute string.  If the content of this string needs to be
-         *         available beyond the scope of the calling function, it should be copied.  The
-         *         returned pointer may become invalid if the set of attributes is changed.
-         */
-        QMFE_EXTERN const char* getAttrString() const;
-
-        /**
-         * Shortcuts for setting the transport for the connection.
-         *
-         * @param port The port value for the connection address.
-         */
-        QMFE_EXTERN void transportTcp(uint16_t port = 5672);
-        QMFE_EXTERN void transportSsl(uint16_t port = 5671);
-        QMFE_EXTERN void transportRdma(uint16_t port = 5672);
-
-        /**
-         * Shortcuts for setting authentication mechanisms.
-         *
-         * @param username Null-terminated authentication user name.
-         *
-         * @param password Null-terminated authentication password.
-         *
-         * @param serviceName Null-terminated GSSAPI service name (Kerberos service principal)
-         *
-         * @param minSsf Minimum security factor for connections. 0 = encryption not required.
-         *
-         * @param maxSsf Maximum security factor for connections. 0 = encryption not permitted.
-         */
-        QMFE_EXTERN void authAnonymous(const char* username = 0);
-        QMFE_EXTERN void authPlain(const char* username = 0, const char* password = 0);
-        QMFE_EXTERN void authGssapi(const char* serviceName, uint32_t minSsf = 0, uint32_t maxSsf = 256);
-
-        /**
-         * Shortcut for setting connection retry attributes.
-         *
-         * @param delayMin Minimum delay (in seconds) between connection attempts.
-         *
-         * @param delaxMax Maximum delay (in seconds) between connection attempts.
-         *
-         * @param delayFactor Factor to multiply the delay by between failed connection attempts.
-         */
-        QMFE_EXTERN void setRetry(int delayMin = 1, int delayMax = 128, int delayFactor = 2);
-
-    private:
-        friend class ResilientConnectionImpl;
-        ConnectionSettingsImpl* impl;
-    };
-
-}
-}
-
-#endif
diff --git a/cpp/include/qmf/engine/Console.h b/cpp/include/qmf/engine/Console.h
deleted file mode 100644
index bd40c63c6c..0000000000
--- a/cpp/include/qmf/engine/Console.h
+++ /dev/null
@@ -1,239 +0,0 @@
-#ifndef _QmfEngineConsole_
-#define _QmfEngineConsole_
-
-/*
- * 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 <qmf/engine/ResilientConnection.h>
-#include <qmf/engine/Schema.h>
-#include <qmf/engine/ObjectId.h>
-#include <qmf/engine/Object.h>
-#include <qmf/engine/Event.h>
-#include <qmf/engine/Query.h>
-#include <qmf/engine/Value.h>
-#include <qmf/engine/Message.h>
-
-namespace qmf {
-namespace engine {
-
-    class Console;
-    class ConsoleImpl;
-    class BrokerProxyImpl;
-    class AgentProxy;
-    struct AgentProxyImpl;
-    struct MethodResponseImpl;
-    struct QueryResponseImpl;
-    struct QueryContext;
-
-    /**
-     *
-     */
-    class MethodResponse {
-    public:
-        MethodResponse(const MethodResponse& from);
-        ~MethodResponse();
-        uint32_t getStatus() const;
-        const Value* getException() const;
-        const Value* getArgs() const;
-
-    private:
-        friend struct MethodResponseImpl;
-        friend class ConsoleImpl;
-        MethodResponse(MethodResponseImpl* impl);
-        MethodResponseImpl* impl;
-    };
-
-    /**
-     *
-     */
-    class QueryResponse {
-    public:
-        ~QueryResponse();
-        uint32_t getStatus() const;
-        const Value* getException() const;
-        uint32_t getObjectCount() const;
-        const Object* getObject(uint32_t idx) const;
-
-    private:
-        friend struct QueryResponseImpl;
-        friend struct QueryContext;
-        QueryResponse(QueryResponseImpl* impl);
-        QueryResponseImpl *impl;
-    };
-
-    /**
-     *
-     */
-    struct ConsoleEvent {
-        enum EventKind {
-            AGENT_ADDED     = 1,
-            AGENT_DELETED   = 2,
-            NEW_PACKAGE     = 3,
-            NEW_CLASS       = 4,
-            OBJECT_UPDATE   = 5,
-            EVENT_RECEIVED  = 7,
-            AGENT_HEARTBEAT = 8
-        };
-
-        EventKind       kind;
-        AgentProxy*     agent;          // (AGENT_[ADDED|DELETED|HEARTBEAT])
-        char*           name;           // (NEW_PACKAGE)
-        const SchemaClassKey* classKey; // (NEW_CLASS)
-        Object*         object;         // (OBJECT_UPDATE)
-        void*           context;        // (OBJECT_UPDATE)
-        Event*          event;          // (EVENT_RECEIVED)
-        uint64_t        timestamp;      // (AGENT_HEARTBEAT)
-        QueryResponse*  queryResponse;  // (QUERY_COMPLETE)
-        bool            hasProps;
-        bool            hasStats;
-    };
-
-    /**
-     *
-     */
-    struct BrokerEvent {
-        enum EventKind {
-            BROKER_INFO     = 10,
-            DECLARE_QUEUE   = 11,
-            DELETE_QUEUE    = 12,
-            BIND            = 13,
-            UNBIND          = 14,
-            SETUP_COMPLETE  = 15,
-            STABLE          = 16,
-            QUERY_COMPLETE  = 17,
-            METHOD_RESPONSE = 18
-        };
-
-        EventKind kind;
-        char*           name;           // ([DECLARE|DELETE]_QUEUE, [UN]BIND)
-        char*           exchange;       // ([UN]BIND)
-        char*           bindingKey;     // ([UN]BIND)
-        void*           context;        // (QUERY_COMPLETE, METHOD_RESPONSE)
-        QueryResponse*  queryResponse;  // (QUERY_COMPLETE)
-        MethodResponse* methodResponse; // (METHOD_RESPONSE)
-    };
-
-    /**
-     *
-     */
-    class AgentProxy {
-    public:
-        AgentProxy(const AgentProxy& from);
-        ~AgentProxy();
-        const char* getLabel() const;
-        uint32_t getBrokerBank() const;
-        uint32_t getAgentBank() const;
-
-    private:
-        friend struct StaticContext;
-        friend struct QueryContext;
-        friend struct AgentProxyImpl;
-        friend class BrokerProxyImpl;
-        AgentProxy(AgentProxyImpl* impl);
-        AgentProxyImpl* impl;
-    };
-
-    /**
-     *
-     */
-    class BrokerProxy {
-    public:
-        BrokerProxy(Console& console);
-        ~BrokerProxy();
-
-        void sessionOpened(SessionHandle& sh);
-        void sessionClosed();
-        void startProtocol();
-
-        void handleRcvMessage(Message& message);
-        bool getXmtMessage(Message& item) const;
-        void popXmt();
-
-        bool getEvent(BrokerEvent& event) const;
-        void popEvent();
-
-        uint32_t agentCount() const;
-        const AgentProxy* getAgent(uint32_t idx) const;
-        void sendQuery(const Query& query, void* context, const AgentProxy* agent = 0);
-
-    private:
-        friend class ConsoleImpl;
-        friend struct StaticContext;
-        BrokerProxyImpl* impl;
-    };
-
-    // TODO - move this to a public header
-    struct ConsoleSettings {
-        bool rcvObjects;
-        bool rcvEvents;
-        bool rcvHeartbeats;
-        bool userBindings;
-
-        ConsoleSettings() :
-            rcvObjects(true),
-            rcvEvents(true),
-            rcvHeartbeats(true),
-            userBindings(false) {}
-    };
-
-    class Console {
-    public:
-        Console(const ConsoleSettings& settings = ConsoleSettings());
-        ~Console();
-
-        bool getEvent(ConsoleEvent& event) const;
-        void popEvent();
-
-        void addConnection(BrokerProxy& broker, void* context);
-        void delConnection(BrokerProxy& broker);
-
-        uint32_t packageCount() const;
-        const char* getPackageName(uint32_t idx) const;
-
-        uint32_t classCount(const char* packageName) const;
-        const SchemaClassKey* getClass(const char* packageName, uint32_t idx) const;
-
-        ClassKind getClassKind(const SchemaClassKey* key) const;
-        const SchemaObjectClass* getObjectClass(const SchemaClassKey* key) const;
-        const SchemaEventClass* getEventClass(const SchemaClassKey* key) const;
-
-        void bindPackage(const char* packageName);
-        void bindClass(const SchemaClassKey* key);
-        void bindClass(const char* packageName, const char* className);
-
-        void bindEvent(const SchemaClassKey *key);
-        void bindEvent(const char* packageName, const char* eventName);
-
-        /*
-        void startSync(const Query& query, void* context, SyncQuery& sync);
-        void touchSync(SyncQuery& sync);
-        void endSync(SyncQuery& sync);
-        */
-
-    private:
-        friend class BrokerProxyImpl;
-        friend struct AgentProxyImpl;
-        friend struct StaticContext;
-        ConsoleImpl* impl;
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/Event.h b/cpp/include/qmf/engine/Event.h
deleted file mode 100644
index 647b88dbf8..0000000000
--- a/cpp/include/qmf/engine/Event.h
+++ /dev/null
@@ -1,49 +0,0 @@
-#ifndef _QmfEngineEvent_
-#define _QmfEngineEvent_
-
-/*
- * 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.
- */
-
-namespace qmf {
-namespace engine {
-
-    class SchemaEventClass;
-    class Value;
-    struct EventImpl;
-
-    class Event {
-    public:
-        Event(const SchemaEventClass* type);
-        Event(const Event& from);
-        ~Event();
-
-        const SchemaEventClass* getClass() const;
-        Value* getValue(const char* key) const;
-
-    private:
-        friend struct EventImpl;
-        friend class AgentImpl;
-        Event(EventImpl* impl);
-        EventImpl* impl;
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/Message.h b/cpp/include/qmf/engine/Message.h
deleted file mode 100644
index 1e95cc6afe..0000000000
--- a/cpp/include/qmf/engine/Message.h
+++ /dev/null
@@ -1,41 +0,0 @@
-#ifndef _QmfEngineMessage_
-#define _QmfEngineMessage_
-
-/*
- * 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/sys/IntegerTypes.h"
-
-namespace qmf {
-namespace engine {
-
-    struct Message {
-        char*    body;
-        uint32_t length;
-        char*    destination;
-        char*    routingKey;
-        char*    replyExchange;
-        char*    replyKey;
-        char*    userId;
-    };
-
-}
-}
-
-#endif
diff --git a/cpp/include/qmf/engine/Object.h b/cpp/include/qmf/engine/Object.h
deleted file mode 100644
index ad67cfdb95..0000000000
--- a/cpp/include/qmf/engine/Object.h
+++ /dev/null
@@ -1,56 +0,0 @@
-#ifndef _QmfEngineObject_
-#define _QmfEngineObject_
-
-/*
- * 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 <qmf/engine/Schema.h>
-#include <qmf/engine/ObjectId.h>
-#include <qmf/engine/Value.h>
-
-namespace qmf {
-namespace engine {
-
-    struct ObjectImpl;
-    class Object {
-    public:
-        Object(const SchemaObjectClass* type);
-        Object(const Object& from);
-        virtual ~Object();
-
-        void destroy();
-        const ObjectId* getObjectId() const;
-        void setObjectId(ObjectId* oid);
-        const SchemaObjectClass* getClass() const;
-        Value* getValue(const char* key) const;
-        void invokeMethod(const char* methodName, const Value* inArgs, void* context) const;
-        bool isDeleted() const;
-        void merge(const Object& from);
-
-    private:
-        friend struct ObjectImpl;
-        friend class  AgentImpl;
-        Object(ObjectImpl* impl);
-        ObjectImpl* impl;
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/ObjectId.h b/cpp/include/qmf/engine/ObjectId.h
deleted file mode 100644
index 51eb2bc9e7..0000000000
--- a/cpp/include/qmf/engine/ObjectId.h
+++ /dev/null
@@ -1,68 +0,0 @@
-#ifndef _QmfEngineObjectId_
-#define _QmfEngineObjectId_
-
-/*
- * 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/sys/IntegerTypes.h>
-
-namespace qmf {
-namespace engine {
-
-    // TODO: Add to/from string and << operator
-
-    struct ObjectIdImpl;
-    class ObjectId {
-    public:
-        ObjectId();
-        ObjectId(const ObjectId& from);
-        ~ObjectId();
-
-        uint64_t getObjectNum() const;
-        uint32_t getObjectNumHi() const;
-        uint32_t getObjectNumLo() const;
-        bool isDurable() const;
-        const char* str() const;
-        uint8_t getFlags() const;
-        uint16_t getSequence() const;
-        uint32_t getBrokerBank() const;
-        uint32_t getAgentBank() const;
-
-        bool operator==(const ObjectId& other) const;
-        bool operator<(const ObjectId& other) const;
-        bool operator>(const ObjectId& other) const;
-        bool operator<=(const ObjectId& other) const;
-        bool operator>=(const ObjectId& other) const;
-        ObjectId& operator=(const ObjectId &other);
-
-    private:
-        friend struct ObjectIdImpl;
-        friend struct ObjectImpl;
-        friend class  BrokerProxyImpl;
-        friend struct QueryImpl;
-        friend struct ValueImpl;
-        friend class  AgentImpl;
-        ObjectId(ObjectIdImpl* impl);
-        ObjectIdImpl* impl;
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/QmfEngineImportExport.h b/cpp/include/qmf/engine/QmfEngineImportExport.h
deleted file mode 100644
index cf8fffdb17..0000000000
--- a/cpp/include/qmf/engine/QmfEngineImportExport.h
+++ /dev/null
@@ -1,42 +0,0 @@
-#ifndef QMF_ENGINE_IMPORT_EXPORT_H
-#define QMF_ENGINE_IMPORT_EXPORT_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.
- */
-
-#if defined(WIN32) && !defined(QPID_DECLARE_STATIC)
-#  if defined(QMF_EXPORT) || defined (qmfengine_EXPORTS)
-#    define QMFE_EXTERN __declspec(dllexport)
-#  else
-#    define QMFE_EXTERN __declspec(dllimport)
-#  endif
-#  ifdef _MSC_VER
-#    define QMFE_CLASS_EXTERN
-#    define QMFE_INLINE_EXTERN QMFE_EXTERN
-#  else
-#    define QMFE_CLASS_EXTERN QMFE_EXTERN
-#    define QMFE_INLINE_EXTERN
-#  endif
-#else
-#  define QMFE_EXTERN
-#  define QMFE_CLASS_EXTERN
-#  define QMFE_INLINE_EXTERN
-#endif
-
-#endif
diff --git a/cpp/include/qmf/engine/Query.h b/cpp/include/qmf/engine/Query.h
deleted file mode 100644
index 3ed08c5d8e..0000000000
--- a/cpp/include/qmf/engine/Query.h
+++ /dev/null
@@ -1,112 +0,0 @@
-#ifndef _QmfEngineQuery_
-#define _QmfEngineQuery_
-
-/*
- * 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 <qmf/engine/ObjectId.h>
-#include <qmf/engine/Value.h>
-
-namespace qmf {
-namespace engine {
-
-    class Object;
-    struct QueryElementImpl;
-    struct QueryImpl;
-    struct QueryExpressionImpl;
-    class  SchemaClassKey;
-
-    enum ValueOper {
-        O_EQ = 1,
-        O_NE = 2,
-        O_LT = 3,
-        O_LE = 4,
-        O_GT = 5,
-        O_GE = 6,
-        O_RE_MATCH = 7,
-        O_RE_NOMATCH = 8,
-        O_PRESENT = 9,
-        O_NOT_PRESENT = 10
-    };
-
-    struct QueryOperand {
-        virtual ~QueryOperand() {}
-        virtual bool evaluate(const Object* object) const = 0;
-    };
-
-    struct QueryElement : public QueryOperand {
-        QueryElement(const char* attrName, const Value* value, ValueOper oper);
-        QueryElement(QueryElementImpl* impl);
-        virtual ~QueryElement();
-        bool evaluate(const Object* object) const;
-
-        QueryElementImpl* impl;
-    };
-
-    enum ExprOper {
-        E_NOT = 1,
-        E_AND = 2,
-        E_OR  = 3,
-        E_XOR = 4
-    };
-
-    struct QueryExpression : public QueryOperand {
-        QueryExpression(ExprOper oper, const QueryOperand* operand1, const QueryOperand* operand2);
-        QueryExpression(QueryExpressionImpl* impl);
-        virtual ~QueryExpression();
-        bool evaluate(const Object* object) const;
-        
-        QueryExpressionImpl* impl;
-    };
-
-    class Query {
-    public:
-        Query(const char* className, const char* packageName);
-        Query(const SchemaClassKey* key);
-        Query(const ObjectId* oid);
-        Query(const Query& from);
-        ~Query();
-
-        void setSelect(const QueryOperand* criterion);
-        void setLimit(uint32_t maxResults);
-        void setOrderBy(const char* attrName, bool decreasing);
-
-        const char* getPackage() const;
-        const char* getClass() const;
-        const ObjectId* getObjectId() const;
-
-        bool haveSelect() const;
-        bool haveLimit() const;
-        bool haveOrderBy() const;
-        const QueryOperand* getSelect() const;
-        uint32_t getLimit() const;
-        const char* getOrderBy() const;
-        bool getDecreasing() const;
-
-    private:
-        friend struct QueryImpl;
-        friend class BrokerProxyImpl;
-        Query(QueryImpl* impl);
-        QueryImpl* impl;
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/ResilientConnection.h b/cpp/include/qmf/engine/ResilientConnection.h
deleted file mode 100644
index c03d08cb96..0000000000
--- a/cpp/include/qmf/engine/ResilientConnection.h
+++ /dev/null
@@ -1,173 +0,0 @@
-#ifndef _QmfEngineResilientConnection_
-#define _QmfEngineResilientConnection_
-
-/*
- * 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 <qmf/engine/Message.h>
-#include <qmf/engine/ConnectionSettings.h>
-#include <string>
-
-namespace qmf {
-namespace engine {
-
-    class ResilientConnectionImpl;
-
-    /**
-     * Represents events that occur, unsolicited, from ResilientConnection.
-     */
-    struct ResilientConnectionEvent {
-        enum EventKind {
-            CONNECTED      = 1,
-            DISCONNECTED   = 2,
-            SESSION_CLOSED = 3,
-            RECV           = 4
-        };
-
-        EventKind kind;
-        void*     sessionContext; // SESSION_CLOSED, RECV
-        char*     errorText;      // DISCONNECTED, SESSION_CLOSED
-        Message   message;        // RECV
-    };
-
-    class SessionHandle {
-        friend class ResilientConnectionImpl;
-        void* impl;
-    };
-
-    /**
-     * ResilientConnection represents a Qpid connection that is resilient.
-     *
-     * Upon creation, ResilientConnection attempts to establish a connection to the
-     * messaging broker.  If it fails, it will continue to retry at an interval that
-     * increases over time (to a maximum interval).  If an extablished connection is
-     * dropped, a reconnect will be attempted.
-     */
-    class ResilientConnection {
-    public:
-
-        /**
-         * Create a new resilient connection.
-         *@param settings Settings that define how the connection is to be made.
-         *@param delayMin Minimum delay (in seconds) between retries.
-         *@param delayMax Maximum delay (in seconds) between retries.
-         *@param delayFactor Factor to multiply retry delay by after each failure.
-         */
-        ResilientConnection(const ConnectionSettings& settings);
-        ~ResilientConnection();
-
-        /**
-         * Get the connected status of the resilient connection.
-         *@return true iff the connection is established.
-         */
-        bool isConnected() const;
-
-        /**
-         * Get the next event (if present) from the connection.
-         *@param event Returned event if one is available.
-         *@return true if event is valid, false if there are no more events to handle.
-         */
-        bool getEvent(ResilientConnectionEvent& event);
-
-        /**
-         * Discard the event on the front of the queue.  This should be invoked after processing
-         * the event from getEvent.
-         */
-        void popEvent();
-
-        /**
-         * Create a new AMQP session.
-         *@param name Unique name for the session.
-         *@param sessionContext Optional user-context value that will be provided in events
-         *                      pertaining to this session.
-         *@param handle Output handle to be stored and used in subsequent calls pertaining to
-         *              this session.
-         *@return true iff the session was successfully created.
-         */
-        bool createSession(const char* name, void* sessionContext, SessionHandle& handle);
-
-        /**
-         * Destroy a created session.
-         *@param handle SessionHandle returned by createSession.
-         */
-        void destroySession(SessionHandle handle);
-
-        /**
-         * Send a message into the AMQP broker via a session.
-         *@param handle The session handle of the session to transmit through.
-         *@param message The QMF message to transmit.
-         */
-        void sendMessage(SessionHandle handle, Message& message);
-
-        /**
-         * Declare an exclusive, auto-delete queue for a session.
-         *@param handle The session handle for the owner of the queue.
-         *@param queue The name of the queue.
-         */
-        void declareQueue(SessionHandle handle, char* queue);
-
-        /**
-         * Delete a queue.
-         *@param handle The session handle for the owner of the queue.
-         *@param queue The name of the queue.
-         */
-        void deleteQueue(SessionHandle handle, char* queue);
-
-        /**
-         * Bind a queue to an exchange.
-         *@param handle The session handle of the session to use for binding.
-         *@param exchange The name of the exchange for binding.
-         *@param queue The name of the queue for binding.
-         *@param key The binding key.
-         */
-        void bind(SessionHandle handle, char* exchange, char* queue, char* key);
-
-        /**
-         * Remove a binding.
-         *@param handle The session handle of the session to use for un-binding.
-         *@param exchange The name of the exchange.
-         *@param queue The name of the queue.
-         *@param key The binding key.
-         */
-        void unbind(SessionHandle handle, char* exchange, char* queue, char* key);
-
-        /**
-         * Establish a file descriptor for event notification.
-         *@param fd A file descriptor into which the connection shall write a character each
-         *          time an event is enqueued.  This fd may be in a pair, the other fd of which
-         *          is used in a select loop to control execution.
-         */
-        void setNotifyFd(int fd);
-
-        /**
-         * Send a byte into the notify file descriptor.
-         *
-         * This can be used to wake up the event processing portion of the engine from either the
-         * wrapped implementation or the engine itself.
-         */
-        void notify();
-
-    private:
-        ResilientConnectionImpl* impl;
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/Schema.h b/cpp/include/qmf/engine/Schema.h
deleted file mode 100644
index f53e84324a..0000000000
--- a/cpp/include/qmf/engine/Schema.h
+++ /dev/null
@@ -1,212 +0,0 @@
-#ifndef _QmfEngineSchema_
-#define _QmfEngineSchema_
-
-/*
- * 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 <qmf/engine/Typecode.h>
-#include <qpid/sys/IntegerTypes.h>
-
-namespace qmf {
-namespace engine {
-
-    enum Access { ACCESS_READ_CREATE = 1, ACCESS_READ_WRITE = 2, ACCESS_READ_ONLY = 3 };
-    enum Direction { DIR_IN = 1, DIR_OUT = 2, DIR_IN_OUT = 3 };
-    enum ClassKind { CLASS_OBJECT = 1, CLASS_EVENT = 2 };
-    enum Severity { SEV_EMERG = 0, SEV_ALERT = 1, SEV_CRIT = 2, SEV_ERROR = 3, SEV_WARN = 4, SEV_NOTICE = 5, SEV_INFORM = 6, SEV_DEBUG = 7 };
-
-    struct SchemaArgumentImpl;
-    struct SchemaMethodImpl;
-    struct SchemaPropertyImpl;
-    struct SchemaStatisticImpl;
-    struct SchemaObjectClassImpl;
-    struct SchemaEventClassImpl;
-    struct SchemaClassKeyImpl;
-
-    /**
-     */
-    class SchemaArgument {
-    public:
-        SchemaArgument(const char* name, Typecode typecode);
-        SchemaArgument(const SchemaArgument& from);
-        ~SchemaArgument();
-        void setDirection(Direction dir);
-        void setUnit(const char* val);
-        void setDesc(const char* desc);
-        const char* getName() const;
-        Typecode getType() const;
-        Direction getDirection() const;
-        const char* getUnit() const;
-        const char* getDesc() const;
-
-    private:
-        friend struct SchemaArgumentImpl;
-        friend struct SchemaMethodImpl;
-        friend struct SchemaEventClassImpl;
-        SchemaArgument(SchemaArgumentImpl* impl);
-        SchemaArgumentImpl* impl;
-    };
-
-    /**
-     */
-    class SchemaMethod {
-    public:
-        SchemaMethod(const char* name);
-        SchemaMethod(const SchemaMethod& from);
-        ~SchemaMethod();
-        void addArgument(const SchemaArgument* argument);
-        void setDesc(const char* desc);
-        const char* getName() const;
-        const char* getDesc() const;
-        int getArgumentCount() const;
-        const SchemaArgument* getArgument(int idx) const;
-
-    private:
-        friend struct SchemaMethodImpl;
-        friend struct SchemaObjectClassImpl;
-        friend class  AgentImpl;
-        SchemaMethod(SchemaMethodImpl* impl);
-        SchemaMethodImpl* impl;
-    };
-
-    /**
-     */
-    class SchemaProperty {
-    public:
-        SchemaProperty(const char* name, Typecode typecode);
-        SchemaProperty(const SchemaProperty& from);
-        ~SchemaProperty();
-        void setAccess(Access access);
-        void setIndex(bool val);
-        void setOptional(bool val);
-        void setUnit(const char* val);
-        void setDesc(const char* desc);
-        const char* getName() const;
-        Typecode getType() const;
-        Access getAccess() const;
-        bool isIndex() const;
-        bool isOptional() const;
-        const char* getUnit() const;
-        const char* getDesc() const;
-
-    private:
-        friend struct SchemaPropertyImpl;
-        friend struct SchemaObjectClassImpl;
-        SchemaProperty(SchemaPropertyImpl* impl);
-        SchemaPropertyImpl* impl;
-    };
-
-    /**
-     */
-    class SchemaStatistic {
-    public:
-        SchemaStatistic(const char* name, Typecode typecode);
-        SchemaStatistic(const SchemaStatistic& from);
-        ~SchemaStatistic();
-        void setUnit(const char* val);
-        void setDesc(const char* desc);
-        const char* getName() const;
-        Typecode getType() const;
-        const char* getUnit() const;
-        const char* getDesc() const;
-
-    private:
-        friend struct SchemaStatisticImpl;
-        friend struct SchemaObjectClassImpl;
-        SchemaStatistic(SchemaStatisticImpl* impl);
-        SchemaStatisticImpl* impl;
-    };
-
-    /**
-     */
-    class SchemaClassKey {
-    public:
-        SchemaClassKey(const SchemaClassKey& from);
-        ~SchemaClassKey();
-
-        const char* getPackageName() const;
-        const char* getClassName() const;
-        const uint8_t* getHash() const;
-        const char* asString() const;
-
-        bool operator==(const SchemaClassKey& other) const;
-        bool operator<(const SchemaClassKey& other) const;
-
-    private:
-        friend struct SchemaClassKeyImpl;
-        friend class BrokerProxyImpl;
-        friend class ConsoleImpl;
-        SchemaClassKey(SchemaClassKeyImpl* impl);
-        SchemaClassKeyImpl* impl;
-    };
-
-    /**
-     */
-    class SchemaObjectClass {
-    public:
-        SchemaObjectClass(const char* package, const char* name);
-        SchemaObjectClass(const SchemaObjectClass& from);
-        ~SchemaObjectClass();
-        void addProperty(const SchemaProperty* property);
-        void addStatistic(const SchemaStatistic* statistic);
-        void addMethod(const SchemaMethod* method);
-
-        const SchemaClassKey* getClassKey() const;
-        int getPropertyCount() const;
-        int getStatisticCount() const;
-        int getMethodCount() const;
-        const SchemaProperty* getProperty(int idx) const;
-        const SchemaStatistic* getStatistic(int idx) const;
-        const SchemaMethod* getMethod(int idx) const;
-
-    private:
-        friend struct SchemaObjectClassImpl;
-        friend class  BrokerProxyImpl;
-        friend class  AgentImpl;
-        SchemaObjectClass(SchemaObjectClassImpl* impl);
-        SchemaObjectClassImpl* impl;
-    };
-
-    /**
-     */
-    class SchemaEventClass {
-    public:
-        SchemaEventClass(const char* package, const char* name, Severity severity);
-        SchemaEventClass(const SchemaEventClass& from);
-        ~SchemaEventClass();
-        void addArgument(const SchemaArgument* argument);
-        void setDesc(const char* desc);
-
-        const SchemaClassKey* getClassKey() const;
-        Severity getSeverity() const;
-        int getArgumentCount() const;
-        const SchemaArgument* getArgument(int idx) const;
-
-    private:
-        friend struct SchemaEventClassImpl;
-        friend class  BrokerProxyImpl;
-        friend class  AgentImpl;
-        SchemaEventClass(SchemaEventClassImpl* impl);
-        SchemaEventClassImpl* impl;
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/Typecode.h b/cpp/include/qmf/engine/Typecode.h
deleted file mode 100644
index 613f96a483..0000000000
--- a/cpp/include/qmf/engine/Typecode.h
+++ /dev/null
@@ -1,53 +0,0 @@
-#ifndef _QmfEngineTypecode_
-#define _QmfEngineTypecode_
-
-/*
- * 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.
- */
-
-namespace qmf {
-namespace engine {
-
-    enum Typecode {
-        TYPE_UINT8      = 1,
-        TYPE_UINT16     = 2,
-        TYPE_UINT32     = 3,
-        TYPE_UINT64     = 4,
-        TYPE_SSTR       = 6,
-        TYPE_LSTR       = 7,
-        TYPE_ABSTIME    = 8,
-        TYPE_DELTATIME  = 9,
-        TYPE_REF        = 10,
-        TYPE_BOOL       = 11,
-        TYPE_FLOAT      = 12,
-        TYPE_DOUBLE     = 13,
-        TYPE_UUID       = 14,
-        TYPE_MAP        = 15,
-        TYPE_INT8       = 16,
-        TYPE_INT16      = 17,
-        TYPE_INT32      = 18,
-        TYPE_INT64      = 19,
-        TYPE_OBJECT     = 20,
-        TYPE_LIST       = 21,
-        TYPE_ARRAY      = 22
-    };
-}
-}
-
-#endif
-
diff --git a/cpp/include/qmf/engine/Value.h b/cpp/include/qmf/engine/Value.h
deleted file mode 100644
index 5b45061b78..0000000000
--- a/cpp/include/qmf/engine/Value.h
+++ /dev/null
@@ -1,122 +0,0 @@
-#ifndef _QmfEngineValue_
-#define _QmfEngineValue_
-
-/*
- * 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 <qmf/engine/ObjectId.h>
-#include <qmf/engine/Typecode.h>
-
-namespace qmf {
-namespace engine {
-
-    class Object;
-    struct ValueImpl;
-
-    class Value {
-    public:
-        //        Value();
-        Value(const Value& from);
-        Value(Typecode t, Typecode arrayType = TYPE_UINT8);
-        ~Value();
-
-        Typecode getType() const;
-        bool isNull() const;
-        void setNull();
-
-        bool isObjectId() const;
-        const ObjectId& asObjectId() const;
-        void setObjectId(const ObjectId& oid);
-
-        bool isUint() const;
-        uint32_t asUint() const;
-        void setUint(uint32_t val);
-
-        bool isInt() const;
-        int32_t asInt() const;
-        void setInt(int32_t val);
-
-        bool isUint64() const;
-        uint64_t asUint64() const;
-        void setUint64(uint64_t val);
-
-        bool isInt64() const;
-        int64_t asInt64() const;
-        void setInt64(int64_t val);
-
-        bool isString() const;
-        const char* asString() const;
-        void setString(const char* val);
-
-        bool isBool() const;
-        bool asBool() const;
-        void setBool(bool val);
-
-        bool isFloat() const;
-        float asFloat() const;
-        void setFloat(float val);
-
-        bool isDouble() const;
-        double asDouble() const;
-        void setDouble(double val);
-
-        bool isUuid() const;
-        const uint8_t* asUuid() const;
-        void setUuid(const uint8_t* val);
-
-        bool isObject() const;
-        const Object* asObject() const;
-        void setObject(Object* val);
-
-        bool isMap() const;
-        bool keyInMap(const char* key) const;
-        Value* byKey(const char* key);
-        const Value* byKey(const char* key) const;
-        void deleteKey(const char* key);
-        void insert(const char* key, Value* val);
-        uint32_t keyCount() const;
-        const char* key(uint32_t idx) const;
-
-        bool isList() const;
-        uint32_t listItemCount() const;
-        Value* listItem(uint32_t idx);
-        void appendToList(Value* val);
-        void deleteListItem(uint32_t idx);
-
-        bool isArray() const;
-        Typecode arrayType() const;
-        uint32_t arrayItemCount() const;
-        Value* arrayItem(uint32_t idx);
-        void appendToArray(Value* val);
-        void deleteArrayItem(uint32_t idx);
-
-    private:
-        friend struct ValueImpl;
-        friend class  BrokerProxyImpl;
-        friend struct ObjectImpl;
-        friend struct EventImpl;
-        friend class  AgentImpl;
-        Value(ValueImpl* impl);
-        ValueImpl* impl;
-    };
-}
-}
-
-#endif
-