1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
/*
*
* 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 {
Settings& settings;
Opts(Settings& s) : Options("Cluster Options"), settings(s) {
addOptions()
("cluster2-name", optValue(settings.name, "NAME"), "Name of cluster to join")
("cluster2-concurrency", optValue(settings.concurrency, "N"), "Number concurrent streams of processing for multicast/deliver.")
("cluster2-tick", optValue(settings.tick, "uS"), "Length of 'tick' used for timing events in microseconds.")
("cluster2-consume-ticks", optValue(settings.consumeTicks, "N"), "Maximum number of ticks a broker can hold the consume lock on a shared queue.");
// FIXME aconway 2011-10-05: add all relevant options from ClusterPlugin.h.
// FIXME aconway 2011-10-05: rename to final option names.
}
};
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
|
