Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Register components

This commit is contained in:
Christian Schneider 2015-11-24 12:35:05 +01:00
parent 61d1f49c70
commit 7afe263089
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
artemis-server-osgi/src/main/java/org/apache/activemq/artemis/osgi/OsgiBroker.java
View File

@ -56,8 +56,8 @@ public class OsgiBroker {
@Activate @Activate
public void activate(ComponentContext cctx) throws Exception { public void activate(ComponentContext cctx) throws Exception {
BundleContext context = cctx.getBundleContext(); final BundleContext context = cctx.getBundleContext();
Dictionary<String, Object> properties = cctx.getProperties(); final Dictionary<String, Object> properties = cctx.getProperties();
configurationUrl = getMandatory(properties, "config"); configurationUrl = getMandatory(properties, "config");
name = getMandatory(properties, "name"); name = getMandatory(properties, "name");
String domain = getMandatory(properties, "domain"); String domain = getMandatory(properties, "domain");
@ -104,6 +104,7 @@ public class OsgiBroker {
for (int i = mqComponents.length - 1; i >= 0; i--) { for (int i = mqComponents.length - 1; i >= 0; i--) {
mqComponents[i].stop(); mqComponents[i].stop();
} }
unregister();
} }
@Override @Override
@ -112,6 +113,7 @@ public class OsgiBroker {
for (ActiveMQComponent component : componentsByStartOrder) { for (ActiveMQComponent component : componentsByStartOrder) {
component.start(); component.start();
} }
register(context, properties);
} }
@Override @Override