| commit | f48fb3235322ec2d29227191896e1dea4857469c | [log] [tgz] |
|---|---|---|
| author | Christophe Munilla <cmunilla@cmssi.fr> | Mon Mar 29 22:08:35 2021 +0200 |
| committer | Christophe Munilla <cmunilla@cmssi.fr> | Mon Mar 29 22:08:35 2021 +0200 |
| tree | 66736ab2d4562112377e27af43465dad28db5ba1 | |
| parent | 1437afa1593f4f058da4693142ee74661ec604fc [diff] |
Do not reference Broker if no application idetifier or key have been configured Increase the number of used threads when collecting multiple resource data in one call
diff --git a/platform/sensinact-core/src/main/java/org/eclipse/sensinact/gateway/core/SensiNact.java b/platform/sensinact-core/src/main/java/org/eclipse/sensinact/gateway/core/SensiNact.java index 6fd40f5..950ecbd 100644 --- a/platform/sensinact-core/src/main/java/org/eclipse/sensinact/gateway/core/SensiNact.java +++ b/platform/sensinact-core/src/main/java/org/eclipse/sensinact/gateway/core/SensiNact.java
@@ -1998,7 +1998,7 @@ return object; } List<Future<String>> results = new ArrayList<Future<String>>(); - ExecutorService executor = Executors.newFixedThreadPool(10); + ExecutorService executor = Executors.newFixedThreadPool(20); if (sessionKey.localID() == 0) { Collection<ServiceReference<SensinactCoreBaseIface>> references = null;
diff --git a/platform/southbound/mqtt/ttn-device/src/main/java/org/eclipse/sensinact/gateway/sthbnd/ttn/osgi/TtnActivator.java b/platform/southbound/mqtt/ttn-device/src/main/java/org/eclipse/sensinact/gateway/sthbnd/ttn/osgi/TtnActivator.java index c031e3e..be68dcd 100644 --- a/platform/southbound/mqtt/ttn-device/src/main/java/org/eclipse/sensinact/gateway/sthbnd/ttn/osgi/TtnActivator.java +++ b/platform/southbound/mqtt/ttn-device/src/main/java/org/eclipse/sensinact/gateway/sthbnd/ttn/osgi/TtnActivator.java
@@ -49,11 +49,11 @@ @Property(name = "the.things.network.broker.protocol",defaultValue = "SSL") public String brokerProtocol; - /* (non-Javadoc) - * @see org.eclipse.sensinact.gateway.generic.BasisActivator#configure() - */ + @Override - public void configure() { + public void configure() { + if(appId == null || appKey == null) + return; MqttAuthentication authentication = new MqttAuthentication.Builder() .username(appId) .password(appKey)