18
18
import static com .rabbitmq .stream .impl .Utils .SUBSCRIPTION_PROPERTY_MATCH_UNFILTERED ;
19
19
20
20
import com .rabbitmq .stream .*;
21
+ import edu .umd .cs .findbugs .annotations .SuppressFBWarnings ;
21
22
import java .lang .reflect .Field ;
22
23
import java .lang .reflect .Modifier ;
23
24
import java .time .Duration ;
@@ -112,6 +113,7 @@ public ConsumerBuilder subscriptionListener(SubscriptionListener subscriptionLis
112
113
}
113
114
114
115
@ Override
116
+ @ SuppressFBWarnings ("AT_STALE_THREAD_WRITE_OF_PRIMITIVE" )
115
117
public ManualTrackingStrategy manualTrackingStrategy () {
116
118
this .manualTrackingStrategy = new DefaultManualTrackingStrategy (this );
117
119
this .autoTrackingStrategy = null ;
@@ -120,6 +122,7 @@ public ManualTrackingStrategy manualTrackingStrategy() {
120
122
}
121
123
122
124
@ Override
125
+ @ SuppressFBWarnings ("AT_STALE_THREAD_WRITE_OF_PRIMITIVE" )
123
126
public AutoTrackingStrategy autoTrackingStrategy () {
124
127
this .autoTrackingStrategy = new DefaultAutoTrackingStrategy (this );
125
128
this .manualTrackingStrategy = null ;
@@ -128,6 +131,7 @@ public AutoTrackingStrategy autoTrackingStrategy() {
128
131
}
129
132
130
133
@ Override
134
+ @ SuppressFBWarnings ("AT_STALE_THREAD_WRITE_OF_PRIMITIVE" )
131
135
public ConsumerBuilder noTrackingStrategy () {
132
136
this .noTrackingStrategy = true ;
133
137
this .autoTrackingStrategy = null ;
@@ -140,6 +144,7 @@ public FlowConfiguration flow() {
140
144
return this .flowConfiguration ;
141
145
}
142
146
147
+ @ SuppressFBWarnings ("AT_STALE_THREAD_WRITE_OF_PRIMITIVE" )
143
148
StreamConsumerBuilder lazyInit (boolean lazyInit ) {
144
149
this .lazyInit = lazyInit ;
145
150
return this ;
0 commit comments