1 files changed, 4 insertions, 2 deletions
diff --git a/cpp/src/qpid/cluster/ClusterPlugin.cpp b/cpp/src/qpid/cluster/ClusterPlugin.cpp
index 7e0bdcbea8..2f7d12dcfe 100644
--- a/cpp/src/qpid/cluster/ClusterPlugin.cpp
+++ b/cpp/src/qpid/cluster/ClusterPlugin.cpp
@@ -158,8 +158,10 @@ struct ClusterPlugin : public Plugin {
         }
     }
 
-    void initialize(Plugin::Target& ) {
-        cluster->initialize();
+    void initialize(Plugin::Target& target) {
+        Broker* broker = dynamic_cast<Broker*>(&target);
+        if (broker && cluster)
+            cluster->initialize();
     }
 };