1 files changed, 108 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Broker.h b/cpp/src/qpid/broker/Broker.h
new file mode 100644
index 0000000000..57bd86f72e
--- /dev/null
+++ b/cpp/src/qpid/broker/Broker.h
@@ -0,0 +1,108 @@
+#ifndef _Broker_
+#define _Broker_
+
+/*
+ *
+ * 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 "Configuration.h"
+#include "ConnectionFactory.h"
+#include "qpid/sys/Runnable.h"
+#include "qpid/sys/Acceptor.h"
+#include "qpid/SharedObject.h"
+#include "MessageStore.h"
+#include "AutoDelete.h"
+#include "ExchangeRegistry.h"
+#include "ConnectionToken.h"
+#include "DirectExchange.h"
+#include "qpid/framing/OutputHandler.h"
+#include "qpid/framing/ProtocolInitiation.h"
+#include "QueueRegistry.h"
+
+namespace qpid {
+namespace broker {
+/**
+ * A broker instance. 
+ */
+class Broker : public sys::Runnable,
+               public SharedObject<Broker>
+{
+  public:
+    static const int16_t DEFAULT_PORT;
+            
+    virtual ~Broker();
+
+    /**
+     * Create a broker.
+     * @param port Port to listen on or 0 to pick a port dynamically.
+     */
+    static shared_ptr create(int16_t port = DEFAULT_PORT);
+
+    /**
+     * Create a broker using a Configuration.
+     */
+    static shared_ptr create(const Configuration& config);
+
+    /**
+     * Return listening port. If called before bind this is
+     * the configured port. If called after it is the actual
+     * port, which will be different if the configured port is
+     * 0.
+     */
+    virtual int16_t getPort() const;
+            
+    /**
+     * Run the broker. Implements Runnable::run() so the broker
+     * can be run in a separate thread.
+     */
+    virtual void run();
+
+    /** Shut down the broker */
+    virtual void shutdown();
+
+    MessageStore& getStore() { return *store; }
+    QueueRegistry& getQueues() { return queues; }
+    ExchangeRegistry& getExchanges() { return exchanges; }
+    uint32_t getTimeout() { return timeout; }
+    uint64_t getStagingThreshold() { return stagingThreshold; }
+    AutoDelete& getCleaner() { return cleaner; }
+    
+  private:
+    Broker(const Configuration& config);
+    sys::Acceptor& getAcceptor() const;
+
+    Configuration config;
+    sys::Acceptor::shared_ptr acceptor;
+    const std::auto_ptr<MessageStore> store;
+    QueueRegistry queues;
+    ExchangeRegistry exchanges;
+    uint32_t timeout;
+    uint64_t stagingThreshold;
+    AutoDelete cleaner;
+    ConnectionFactory factory;
+
+    static MessageStore* createStore(const Configuration& config);
+};
+
+}}
+            
+
+
+#endif  /*!_Broker_*/