summaryrefslogtreecommitdiff
path: root/cpp/src/broker/Broker.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/broker/Broker.h')
-rw-r--r--cpp/src/broker/Broker.h108
1 files changed, 0 insertions, 108 deletions
diff --git a/cpp/src/broker/Broker.h b/cpp/src/broker/Broker.h
deleted file mode 100644
index f713f0955b..0000000000
--- a/cpp/src/broker/Broker.h
+++ /dev/null
@@ -1,108 +0,0 @@
-#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 "../sys/Runnable.h"
-#include "../sys/Acceptor.h"
-#include "../SharedObject.h"
-#include "MessageStore.h"
-#include "AutoDelete.h"
-#include "ExchangeRegistry.h"
-#include "ConnectionToken.h"
-#include "DirectExchange.h"
-#include "../framing/OutputHandler.h"
-#include "../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_*/