summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/Cluster2Plugin.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/cluster/Cluster2Plugin.cpp')
-rw-r--r--cpp/src/qpid/cluster/Cluster2Plugin.cpp65
1 files changed, 0 insertions, 65 deletions
diff --git a/cpp/src/qpid/cluster/Cluster2Plugin.cpp b/cpp/src/qpid/cluster/Cluster2Plugin.cpp
deleted file mode 100644
index 28b7dcec2e..0000000000
--- a/cpp/src/qpid/cluster/Cluster2Plugin.cpp
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- *
- * Copyright (c) 2006 The Apache Software Foundation
- *
- * Licensed 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/Options.h>
-#include <qpid/broker/Broker.h>
-#include "Core.h"
-
-namespace qpid {
-namespace cluster {
-using broker::Broker;
-
-// TODO aconway 2010-10-19: experimental new cluster code.
-
-/**
- * Plugin for the cluster.
- */
-struct Cluster2Plugin : public Plugin {
- struct Opts : public Options {
- Core::Settings& settings;
- Opts(Core::Settings& s) : Options("Cluster Options"), settings(s) {
- addOptions()
- ("cluster2-name", optValue(settings.name, "NAME"), "Name of cluster to join");
- // TODO aconway 2010-10-19: copy across other options from ClusterPlugin.h
- }
- };
-
- Core::Settings settings;
- Opts options;
- Core* core; // Core deletes itself on shutdown.
-
- Cluster2Plugin() : options(settings), core(0) {}
-
- Options* getOptions() { return &options; }
-
- void earlyInitialize(Plugin::Target& target) {
- if (settings.name.empty()) return;
- Broker* broker = dynamic_cast<Broker*>(&target);
- if (!broker) return;
- core = new Core(settings, *broker);
- }
-
- void initialize(Plugin::Target& target) {
- Broker* broker = dynamic_cast<Broker*>(&target);
- if (broker && core) core->initialize();
- }
-};
-
-static Cluster2Plugin instance; // Static initialization.
-
-}} // namespace qpid::cluster