File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
azure-servicebus/src/main/java/com/microsoft/azure/servicebus/amqp Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change 22
33import org .apache .qpid .proton .engine .BaseHandler ;
44import org .apache .qpid .proton .engine .Event ;
5+ import org .apache .qpid .proton .engine .Event .Type ;
56import org .slf4j .Logger ;
67import org .slf4j .LoggerFactory ;
78
@@ -11,7 +12,7 @@ public class LoggingHandler extends BaseHandler {
1112 @ Override
1213 public void onUnhandled (Event event )
1314 {
14- if (TRACE_LOGGER .isTraceEnabled ())
15+ if (TRACE_LOGGER .isTraceEnabled () && event . getType () != Type . REACTOR_QUIESCED ) // Too may REACTOR_QUIESCED events will be raised
1516 {
1617 TRACE_LOGGER .trace ("Event raised by protonj: {}" , event .toString ());
1718 }
Original file line number Diff line number Diff line change @@ -25,7 +25,8 @@ public void onReactorInit(Event e)
2525 reactor .setTimeout (ClientConstants .REACTOR_IO_POLL_TIMEOUT );
2626 }
2727
28- @ Override public void onReactorFinal (Event e )
28+ @ Override
29+ public void onReactorFinal (Event e )
2930 {
3031 TRACE_LOGGER .debug ("reactor.onReactorFinal" );
3132 }
You can’t perform that action at this time.
0 commit comments