File tree Expand file tree Collapse file tree 2 files changed +1
-2
lines changed
src/main/java/com/rabbitmq/client/impl Expand file tree Collapse file tree 2 files changed +1
-2
lines changed Original file line number Diff line number Diff line change 4747 -Dclient.certificate=./tls-gen/basic/result/client_$(hostname)_certificate.pem \
4848 -Dmaven.javadoc.skip=true \
4949 --no-transfer-progress \
50- -Dit.test=Confirm#persistentMandatoryCombinations,RequeueOnConnectionClose#requeueInFlightConsumerNoAck
50+ -Dit.test=FunctionalTestSuite
5151 # - name: Test with blocking IO
5252 # run: |
5353 # ./mvnw verify -Dio.layer=socket -Drabbitmqctl.bin=DOCKER:rabbitmq0 \
Original file line number Diff line number Diff line change @@ -348,7 +348,6 @@ public void flush() {
348348 @ Override
349349 public void close () {
350350 if (this .closed .compareAndSet (false , true )) {
351- this .handler .logEvents ();
352351 Runnable closing = () -> closeNettyState (this .channel , this .eventLoopGroup );
353352 if (this .channel .eventLoop ().inEventLoop ()) {
354353 this .channel .eventLoop ().submit (closing );
You can’t perform that action at this time.
0 commit comments