diff --git a/client/src/test/java/org/eclipse/hono/client/device/amqp/TelemetrySenderTest.java b/client/src/test/java/org/eclipse/hono/client/device/amqp/TelemetrySenderTest.java index 6dc145a3cf..d8164901a1 100644 --- a/client/src/test/java/org/eclipse/hono/client/device/amqp/TelemetrySenderTest.java +++ b/client/src/test/java/org/eclipse/hono/client/device/amqp/TelemetrySenderTest.java @@ -42,7 +42,7 @@ public class TelemetrySenderTest extends AbstractAmqpAdapterClientDownstreamSend private static final String ADDRESS = TelemetryConstants.TELEMETRY_ENDPOINT + "/" + TENANT_ID + "/" + DEVICE_ID; /** - * Verifies that the message created by {@link TelemetrySender#send(String, byte[], String, Map)} conforms to the + * Verifies that the message created by {@link TelemetrySender#send(String, byte[], String, java.util.Map)} conforms to the * expectations of the AMQP adapter. */ @Test @@ -60,7 +60,7 @@ public void testSendCreatesValidMessage() { } /** - * Verifies that the message created by {@link TelemetrySender#sendAndWaitForOutcome(String, byte[], String, Map)} + * Verifies that the message created by {@link TelemetrySender#sendAndWaitForOutcome(String, byte[], String, java.util.Map)} * conforms to the expectations of the AMQP adapter. * * @param ctx The test context to use for running asynchronous tests. @@ -86,8 +86,8 @@ public void testSendAndWaitForOutcomeCreatesValidMessage(final VertxTestContext } /** - * Verifies that the message created by {@link TelemetrySender#send(String, byte[], String, Map)} conforms to the - * expectations of the AMQP adapter. + * Verifies that the message created by {@link TelemetrySender#send(String, byte[], String, java.util.Map)} conforms + * to the expectations of the AMQP adapter. */ @Test public void testSendWithTracing() { @@ -105,7 +105,7 @@ public void testSendWithTracing() { } /** - * Verifies that {@link TraceableTelemetrySender#sendAndWaitForOutcome(String, byte[], String, Map, SpanContext)} + * Verifies that {@link TraceableTelemetrySender#sendAndWaitForOutcome(String, byte[], String, java.util.Map, SpanContext)} * uses the given SpanContext. * * @param ctx The test context to use for running asynchronous tests. diff --git a/clients/application-kafka/src/test/java/org/eclipse/hono/application/client/kafka/impl/KafkaBasedCommandSenderTest.java b/clients/application-kafka/src/test/java/org/eclipse/hono/application/client/kafka/impl/KafkaBasedCommandSenderTest.java index 668c67ff10..0e573da127 100644 --- a/clients/application-kafka/src/test/java/org/eclipse/hono/application/client/kafka/impl/KafkaBasedCommandSenderTest.java +++ b/clients/application-kafka/src/test/java/org/eclipse/hono/application/client/kafka/impl/KafkaBasedCommandSenderTest.java @@ -230,7 +230,7 @@ public void testSendOneWayCommandSucceeds(final VertxTestContext ctx) { /** * Verifies that - * {@link org.eclipse.hono.application.client.CommandSender#sendCommand(String, String, String, String, Buffer, String, Map, Duration, SpanContext)} + * {@link org.eclipse.hono.application.client.CommandSender#sendCommand(String, String, String, String, Buffer, String, Map, Duration, io.opentracing.SpanContext)} * fails as the timeout is reached. * * @param ctx The vert.x test context. diff --git a/clients/kafka-common/src/main/java/org/eclipse/hono/client/kafka/producer/CachingKafkaProducerFactory.java b/clients/kafka-common/src/main/java/org/eclipse/hono/client/kafka/producer/CachingKafkaProducerFactory.java index b65c6ad421..0faa6e41dc 100644 --- a/clients/kafka-common/src/main/java/org/eclipse/hono/client/kafka/producer/CachingKafkaProducerFactory.java +++ b/clients/kafka-common/src/main/java/org/eclipse/hono/client/kafka/producer/CachingKafkaProducerFactory.java @@ -43,9 +43,9 @@ *
* Producers are closed and removed from the cache if they throw a {@link #isFatalError(Throwable) fatal exception}.
* This is triggered by {@link KafkaProducer#exceptionHandler(Handler)} and run asynchronously after the
- * {@link io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl#send(ProducerRecord, Handler) send operation} has
- * finished. A following invocation of {@link #getOrCreateProducer(String, KafkaProducerConfigProperties)} will then
- * return a new instance.
+ * {@link io.vertx.kafka.client.producer.impl.KafkaWriteStreamImpl#send(org.apache.kafka.clients.producer.ProducerRecord, Handler)
+ * send operation} has finished. A following invocation of {@link #getOrCreateProducer(String, KafkaProducerConfigProperties)}
+ * will then return a new instance.
*
* @param
* The future will be succeeded if the message has been sent.
*
- * The future will be failed with a {@link ServerErrorException} if the data could
+ * The future will be failed with a {@link org.eclipse.hono.client.ServerErrorException} if the data could
* not be sent. The error code contained in the exception indicates the cause of the failure.
* @throws NullPointerException if topic, tenantId, deviceId or properties are {@code null}.
*/
@@ -81,7 +81,7 @@ public Future
* The future will be succeeded if the message has been sent.
*
- * The future will be failed with a {@link ServerErrorException} if the data could
+ * The future will be failed with a {@link org.eclipse.hono.client.ServerErrorException} if the data could
* not be sent. The error code contained in the exception indicates the cause of the failure.
* @throws NullPointerException if topic, tenantId, deviceId or headers are {@code null}.
*/