File tree Expand file tree Collapse file tree 2 files changed +0
-4
lines changed
src/main/java/com/rabbitmq/stream/impl Expand file tree Collapse file tree 2 files changed +0
-4
lines changed Original file line number Diff line number Diff line change 2929import com .rabbitmq .stream .impl .StreamEnvironment .LocatorNotAvailableException ;
3030import com .rabbitmq .stream .impl .StreamEnvironment .TrackingConsumerRegistration ;
3131import com .rabbitmq .stream .impl .Utils .CompositeConsumerUpdateListener ;
32- import edu .umd .cs .findbugs .annotations .SuppressFBWarnings ;
3332import java .time .Duration ;
3433import java .util .List ;
3534import java .util .Map ;
@@ -69,7 +68,6 @@ final class StreamConsumer extends ResourceBase implements Consumer {
6968 private final OffsetSpecification initialOffsetSpecification ;
7069 private final Lock lock = new ReentrantLock ();
7170
72- @ SuppressFBWarnings ("CT_CONSTRUCTOR_THROW" )
7371 StreamConsumer (
7472 String stream ,
7573 OffsetSpecification offsetSpecification ,
Original file line number Diff line number Diff line change 2727import com .rabbitmq .stream .compression .CompressionCodec ;
2828import com .rabbitmq .stream .impl .Client .Response ;
2929import com .rabbitmq .stream .impl .ProducerUtils .AccumulatedEntity ;
30- import edu .umd .cs .findbugs .annotations .SuppressFBWarnings ;
3130import io .netty .buffer .ByteBuf ;
3231import java .nio .charset .StandardCharsets ;
3332import java .time .Duration ;
@@ -85,7 +84,6 @@ final class StreamProducer extends ResourceBase implements Producer {
8584 private final short publishVersion ;
8685 private final Lock lock = new ReentrantLock ();
8786
88- @ SuppressFBWarnings ("CT_CONSTRUCTOR_THROW" )
8987 StreamProducer (
9088 String name ,
9189 String stream ,
You can’t perform that action at this time.
0 commit comments