@@ -11,6 +11,7 @@ import java.util.function.BiConsumer
1111
1212import static datadog.trace.api.ConfigDefaults.DEFAULT_TRACE_BAGGAGE_MAX_BYTES
1313import static datadog.trace.api.ConfigDefaults.DEFAULT_TRACE_BAGGAGE_MAX_ITEMS
14+ import static datadog.trace.api.TracePropagationBehaviorExtract.CONTINUE
1415import static datadog.trace.core.baggage.BaggagePropagator.BAGGAGE_KEY
1516
1617class BaggagePropagatorTest extends DDSpecification {
@@ -35,7 +36,7 @@ class BaggagePropagatorTest extends DDSpecification {
3536 }
3637
3738 def setup () {
38- this . propagator = new BaggagePropagator (true , true , DEFAULT_TRACE_BAGGAGE_MAX_ITEMS , DEFAULT_TRACE_BAGGAGE_MAX_BYTES )
39+ this . propagator = new BaggagePropagator (true , true , DEFAULT_TRACE_BAGGAGE_MAX_ITEMS , DEFAULT_TRACE_BAGGAGE_MAX_BYTES , CONTINUE )
3940 this . setter = new MapCarrierAccessor ()
4041 this . carrier = [:]
4142 this . context = Context . root()
@@ -65,7 +66,7 @@ class BaggagePropagatorTest extends DDSpecification {
6566
6667 def " test baggage inject item limit" () {
6768 setup :
68- propagator = new BaggagePropagator (true , true , 2 , DEFAULT_TRACE_BAGGAGE_MAX_BYTES ) // creating a new instance after injecting config
69+ propagator = new BaggagePropagator (true , true , 2 , DEFAULT_TRACE_BAGGAGE_MAX_BYTES , CONTINUE ) // creating a new instance after injecting config
6970 context = Baggage . create(baggage). storeInto(context)
7071
7172 when :
@@ -82,7 +83,7 @@ class BaggagePropagatorTest extends DDSpecification {
8283
8384 def " test baggage inject bytes limit" () {
8485 setup :
85- propagator = new BaggagePropagator (true , true , DEFAULT_TRACE_BAGGAGE_MAX_ITEMS , 20 ) // creating a new instance after injecting config
86+ propagator = new BaggagePropagator (true , true , DEFAULT_TRACE_BAGGAGE_MAX_ITEMS , 20 , CONTINUE ) // creating a new instance after injecting config
8687 context = Baggage . create(baggage). storeInto(context)
8788
8889 when :
@@ -184,7 +185,7 @@ class BaggagePropagatorTest extends DDSpecification {
184185
185186 def " test baggage cache items limit" (){
186187 setup :
187- propagator = new BaggagePropagator (true , true , 2 , DEFAULT_TRACE_BAGGAGE_MAX_BYTES ) // creating a new instance after injecting config
188+ propagator = new BaggagePropagator (true , true , 2 , DEFAULT_TRACE_BAGGAGE_MAX_BYTES , CONTINUE ) // creating a new instance after injecting config
188189 def headers = [
189190 (BAGGAGE_KEY ) : baggageHeader,
190191 ]
@@ -205,7 +206,7 @@ class BaggagePropagatorTest extends DDSpecification {
205206
206207 def " test baggage cache bytes limit" (){
207208 setup :
208- propagator = new BaggagePropagator (true , true , DEFAULT_TRACE_BAGGAGE_MAX_ITEMS , 20 ) // creating a new instance after injecting config
209+ propagator = new BaggagePropagator (true , true , DEFAULT_TRACE_BAGGAGE_MAX_ITEMS , 20 , CONTINUE ) // creating a new instance after injecting config
209210 def headers = [
210211 (BAGGAGE_KEY ) : baggageHeader,
211212 ]
0 commit comments