Fix OpenTracing span potentially not getting finished; improve logging.

Signed-off-by: Carsten Lohmann <[email protected]>

Author: calohmn

client/src/main/java/org/eclipse/hono/client/impl/GatewayMapperImpl.java

@@ -83,6 +83,9 @@ public Future<String> getMappedGatewayDevice(final String tenantId, final String
 
         return registrationClientFactory.getOrCreateRegistrationClient(tenantId).compose(client -> {
             return client.assertRegistration(deviceId, null, span.context());
+        }).recover(t -> {
+            LOG.debug("Error getting registration assertion", t);
+            return Future.failedFuture(t);
         }).compose(registrationAssertionJson -> {
             final Future<String> mappedGatewayFuture = Future.future();
             final Object viaObject = registrationAssertionJson.getValue(RegistrationConstants.FIELD_VIA);
@@ -136,12 +139,12 @@ public Future<String> getMappedGatewayDevice(final String tenantId, final String
                 span.setTag(MessageHelper.APP_PROPERTY_GATEWAY_ID, result);
                 span.finish();
                 return result;
-            }).recover(t -> {
-                TracingHelper.logError(span, t);
-                Tags.HTTP_STATUS.set(span, ServiceInvocationException.extractStatusCode(t));
-                span.finish();
-                return Future.failedFuture(t);
             });
+        }).recover(t -> {
+            TracingHelper.logError(span, t);
+            Tags.HTTP_STATUS.set(span, ServiceInvocationException.extractStatusCode(t));
+            span.finish();
+            return Future.failedFuture(t);
         });
     }
 

client/src/main/java/org/eclipse/hono/client/impl/GatewayMappingCommandHandler.java

@@ -91,7 +91,7 @@ public void handle(final CommandContext originalCommandContext) {
                     TracingHelper.logError(originalCommandContext.getCurrentSpan(),
                             "no mapped gateway set for device " + originalDeviceId);
                 } else {
-                    LOG.error("error getting mapped gateway for device {}", originalDeviceId, mappedGatewayResult.cause());
+                    LOG.debug("error getting mapped gateway for device {}", originalDeviceId, mappedGatewayResult.cause());
                     TracingHelper.logError(originalCommandContext.getCurrentSpan(),
                             "error getting mapped gateway for device: " + mappedGatewayResult.cause());
                 }