diff options
author | Alan Conway <aconway@apache.org> | 2007-06-29 17:59:00 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-06-29 17:59:00 +0000 |
commit | 90f063a35251345f80616c898e1f6cc7a7d0c393 (patch) | |
tree | 8d17b607338f654fc5ba78da44134e7cebe5b9fb /qpid/cpp/src/qpidd.cpp | |
parent | 53507c3ddb1936c7e64804ccf0b19d84f6da8fff (diff) | |
download | qpid-python-90f063a35251345f80616c898e1f6cc7a7d0c393.tar.gz |
* Summary:
- Improved plugin framework and HandlerUpdater interface.
- Cluster handlers for traffic to/from cluster.
- Cluster HandlerUpdater configures channel chains for cluster.
- Cluster PluginProvider registers cluster objects with broker.
* src/qpid/framing/AMQFrame.h: Made data members public. Handlers
need to be able to modify frame data, getters/setters are just a
nuisance here.
* src/tests/Cluster.cpp: Updated for cluster changes, using
handlers instead of friendship to hook test into Cluster code.
* src/qpid/framing/amqp_types.h: Added CHANNEL_MAX and
CHANNEL_HIGH_BIT constants.
* src/qpid/framing/HandlerUpdater.h: Renamed ChannelInitializer,
broke dependency on broker channel types.
* src/qpid/framing/Handler.h: Added constructors and nextHandler()
* src/qpid/framing/AMQFrame.h (class AMQFrame): Inlined getChannel()
* src/qpid/cluster/ClusterPluginProvider.cpp: Provider for cluster
plugins.
* src/qpid/cluster/Cluster.cpp: Use ChannelManager. Factor out
plugin details to ClusterPluginProvider.
* src/qpid/cluster/ChannelManager.h: Insert cluster handlers
into channel chains, route frames between cluster and channels.
* src/qpid/broker/BrokerAdapter.cpp (startOk): use CHANNEL_MAX
constant.
* src/qpid/broker/Broker.cpp:
- Refactored for new plugin framework.
- Added getUrl().
* src/qpid/Url.h: Added constructor from Address.
* src/qpid/Plugin.h: Generalized plugin framework, broke
dependency on Broker interfaces. We may want to use plug-ins for
clients also at some point.
* src/tests/run_test: Fix bug when VALGRIND is not set.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@551981 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpidd.cpp')
-rw-r--r-- | qpid/cpp/src/qpidd.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpidd.cpp b/qpid/cpp/src/qpidd.cpp index 28a6cf263e..e17deeee2e 100644 --- a/qpid/cpp/src/qpidd.cpp +++ b/qpid/cpp/src/qpidd.cpp @@ -74,7 +74,7 @@ struct QpiddOptions : public qpid::Options { }; // Globals -Broker::shared_ptr brokerPtr; +shared_ptr<Broker> brokerPtr; QpiddOptions options; void handle_signal(int /*signal*/){ @@ -112,7 +112,7 @@ void parent(Daemon& demon) { /** Code for forked child */ void child(Daemon& demon) { - brokerPtr=Broker::create(options.broker); + brokerPtr.reset(new Broker(options.broker)); uint16_t realPort=brokerPtr->getPort(); demon.ready(realPort); // Notify parent. brokerPtr->run(); @@ -161,7 +161,7 @@ int main(int argc, char* argv[]) demon.fork(parent, child); } else { // Non-daemon broker. - brokerPtr = Broker::create(options.broker); + brokerPtr.reset(new Broker(options.broker)); if (options.broker.port == 0) cout << uint16_t(brokerPtr->getPort()) << endl; brokerPtr->run(); |