Correct formatting

apple · Nov 3, 2023 · c40775c · c40775c
1 parent a8f13f8
commit c40775c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...sher/src/main/java/io/servicetalk/opentracing/zipkin/publisher/reporter/HttpReporter.java b/...sher/src/main/java/io/servicetalk/opentracing/zipkin/publisher/reporter/HttpReporter.java
@@ -130,7 +130,7 @@ private PublisherSource.Processor<Span, Span> initReporter(final Builder builder
                     .map(span -> {
                         // Always encode spans as list: https://github.com/apple/servicetalk/pull/2092
                         final byte[] bytes = spanEncoder.encodeList(Collections.singletonList(span));
-                        LOGGER.trace("Encoded received span: {}, result={} bytes", span, bytes.length);
+                        LOGGER.trace("Encoded received span={}, bytes={}", span, bytes.length);
                         return allocator.wrap(bytes);
                     });
         } else {
@@ -143,8 +143,8 @@ private PublisherSource.Processor<Span, Span> initReporter(final Builder builder
                     .filter(accumulate -> !accumulate.isEmpty())
                     .map(bufferedSpans -> {
                         final byte[] bytes = spanEncoder.encodeList(bufferedSpans);
-                        LOGGER.trace("Encoded received list of spans (size={}): {}, result={} bytes",
-                                bufferedSpans.size(), bufferedSpans, bytes.length);
+                        LOGGER.trace("Encoded received list of spans (size={}, bytes={}): {}",
+                                bufferedSpans.size(), bytes.length, bufferedSpans);
                         return allocator.wrap(bytes);
                     });
         }
@@ -297,7 +297,7 @@ private static final class ListAccumulator implements Accumulator<Span, List<Spa
 
         @Override
         public void accumulate(@Nonnull final Span item) {
-            LOGGER.trace("Accumulating received span: {}", item);
+            LOGGER.trace("Accumulating received span={}", item);
             accumulate.add(requireNonNull(item));
         }
 

diff --git a/...isher/src/main/java/io/servicetalk/opentracing/zipkin/publisher/reporter/UdpReporter.java b/...isher/src/main/java/io/servicetalk/opentracing/zipkin/publisher/reporter/UdpReporter.java
@@ -197,7 +197,7 @@ protected void initChannel(final Channel ch) {
                             public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
                                 if (msg instanceof Span) {
                                     byte[] bytes = codec.spanBytesEncoder().encode((Span) msg);
-                                    LOGGER.trace("Encoded received span: {}, result={} bytes", msg, bytes.length);
+                                    LOGGER.trace("Encoded received span={}, bytes={}", msg, bytes.length);
                                     ByteBuf buf = ctx.alloc().buffer(bytes.length).writeBytes(bytes);
                                     ctx.write(new DatagramPacket(buf, (InetSocketAddress) collectorAddress), promise);
                                 } else {