Skip to content

Commit 35a2156

Browse files
committed
Spotless apply
1 parent 5ec63df commit 35a2156

File tree

3 files changed

+5
-7
lines changed

3 files changed

+5
-7
lines changed

dd-java-agent/instrumentation/aws-java-eventbridge-2.0/src/main/java/datadog/trace/instrumentation/aws/v2/eventbridge/EventBridgeInterceptor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ private String getTraceContextToInject(
8686
datadog.context.Context context = span;
8787
if (traceConfig().isDataStreamsEnabled()) {
8888
DataStreamsTags tags =
89-
DataStreamsTags.createWithBus("bus", DataStreamsTags.Direction.Outbound, eventBusName);
89+
DataStreamsTags.createWithBus(DataStreamsTags.Direction.Outbound, eventBusName);
9090
DataStreamsContext dsmContext = DataStreamsContext.fromTags(tags);
9191
context = context.with(dsmContext);
9292
}

dd-trace-core/src/test/groovy/datadog/trace/core/datastreams/DefaultPathwayContextTest.groovy

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -611,7 +611,7 @@ class DefaultPathwayContextTest extends DDCoreSpecification {
611611
AgentTracer.forceRegister(tracerApi)
612612
613613
def dataStreams = new DefaultDataStreamsMonitoring(sink, features, timeSource, { globalTraceConfig },
614-
wellKnownTags, payloadWriter, DEFAULT_BUCKET_DURATION_NANOS)
614+
wellKnownTags, payloadWriter, DEFAULT_BUCKET_DURATION_NANOS)
615615
616616
DataStreamsTags.setGlobalBaseHash(baseHash)
617617
def context = new DefaultPathwayContext(timeSource, baseHash, null)
@@ -666,7 +666,7 @@ class DefaultPathwayContextTest extends DDCoreSpecification {
666666
}
667667
668668
def dataStreams = new DefaultDataStreamsMonitoring(sink, features, timeSource, { traceConfig },
669-
wellKnownTags, payloadWriter, DEFAULT_BUCKET_DURATION_NANOS)
669+
wellKnownTags, payloadWriter, DEFAULT_BUCKET_DURATION_NANOS)
670670
671671
Map<String, String> carrier = ["someotherkey": "someothervalue"]
672672
def contextVisitor = new Base64MapContextVisitor()

internal-api/src/main/java/datadog/trace/api/datastreams/DataStreamsTags.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,6 @@
22

33
import datadog.trace.util.FNV64Hash;
44

5-
import javax.xml.crypto.Data;
6-
75
public class DataStreamsTags {
86
public enum Direction {
97
Unknown,
@@ -100,9 +98,9 @@ public static DataStreamsTags createManual(String type, Direction direction, Str
10098
null, direction, null, topic, type, null, null, null, true, null, null, null, null, null);
10199
}
102100

103-
public static DataStreamsTags createWithBus(String type, Direction direction, String bus) {
101+
public static DataStreamsTags createWithBus(Direction direction, String bus) {
104102
return new DataStreamsTags(
105-
bus, direction, null, null, type, null, null, null, null, null, null, null, null, null);
103+
bus, direction, null, null, "bus", null, null, null, null, null, null, null, null, null);
106104
}
107105

108106
public static DataStreamsTags createWithPartition(

0 commit comments

Comments
 (0)