Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 39e59a0

Browse files
committedJul 25, 2023
[#3520] specific metrics for unknown messages
Signed-off-by: Bob Claerhout <claerhout.bob@gmail.com>
1 parent 4a8911a commit 39e59a0

File tree

43 files changed

+46028
-39
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

43 files changed

+46028
-39
lines changed
 

‎adapter-base/src/main/java/org/eclipse/hono/adapter/AbstractProtocolAdapterBase.java

+1
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@
4242
import org.eclipse.hono.client.telemetry.TelemetrySender;
4343
import org.eclipse.hono.client.util.ServiceClient;
4444
import org.eclipse.hono.service.AbstractServiceBase;
45+
import org.eclipse.hono.service.AdapterDisabledException;
4546
import org.eclipse.hono.service.auth.ValidityBasedTrustOptions;
4647
import org.eclipse.hono.service.metric.MetricsTags.ConnectionAttemptOutcome;
4748
import org.eclipse.hono.service.util.ServiceBaseUtils;

‎adapters/amqp/src/main/java/org/eclipse/hono/adapter/amqp/VertxBasedAmqpProtocolAdapter.java

+4-2
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,6 @@
4141
import org.apache.qpid.proton.message.Message;
4242
import org.eclipse.hono.adapter.AbstractProtocolAdapterBase;
4343
import org.eclipse.hono.adapter.AdapterConnectionsExceededException;
44-
import org.eclipse.hono.adapter.AdapterDisabledException;
4544
import org.eclipse.hono.adapter.AuthorizationException;
4645
import org.eclipse.hono.adapter.auth.device.CredentialsApiAuthProvider;
4746
import org.eclipse.hono.adapter.auth.device.DeviceCredentials;
@@ -67,8 +66,10 @@
6766
import org.eclipse.hono.notification.deviceregistry.DeviceChangeNotification;
6867
import org.eclipse.hono.notification.deviceregistry.LifecycleChange;
6968
import org.eclipse.hono.notification.deviceregistry.TenantChangeNotification;
69+
import org.eclipse.hono.service.AdapterDisabledException;
7070
import org.eclipse.hono.service.auth.DeviceUser;
7171
import org.eclipse.hono.service.http.HttpUtils;
72+
import org.eclipse.hono.service.metric.MetricsTags;
7273
import org.eclipse.hono.service.metric.MetricsTags.ConnectionAttemptOutcome;
7374
import org.eclipse.hono.service.metric.MetricsTags.Direction;
7475
import org.eclipse.hono.service.metric.MetricsTags.EndpointType;
@@ -1325,7 +1326,8 @@ private Future<Void> doUploadMessage(
13251326
ProcessingOutcome.from(t),
13261327
context.isRemotelySettled() ? QoS.AT_MOST_ONCE : QoS.AT_LEAST_ONCE,
13271328
context.getPayloadSize(),
1328-
context.getTimer());
1329+
context.getTimer(),
1330+
MetricsTags.Reason.from(t));
13291331
return Future.failedFuture(t);
13301332

13311333
}).map(ok -> {

0 commit comments

Comments
 (0)
Please sign in to comment.