@@ -497,7 +497,7 @@ public void run() {
497497 EventInput eventInput = null ;
498498 try {
499499 try {
500- logger .debug ("current state is {0 }" , state .get ());
500+ logger .debug ("current state is {}" , state .get ());
501501 final Invocation .Builder request = prepareHandshakeRequest ();
502502 if (state .get () == State .OPEN ) { // attempt to connect only if even source is open
503503 logger .debug ("Connecting..." );
@@ -517,7 +517,7 @@ public void run() {
517517
518518 while (state .get () == State .OPEN && !execThread .isInterrupted ()) {
519519 if (eventInput == null || eventInput .isClosed ()) {
520- logger .debug ("Connection lost - scheduling reconnect in {0 } ms" , reconnectDelay );
520+ logger .debug ("Connection lost - scheduling reconnect in {} ms" , reconnectDelay );
521521 scheduleReconnect (reconnectDelay );
522522 break ;
523523 } else {
@@ -534,7 +534,7 @@ public void run() {
534534 delay = (delay > 0 ) ? delay : 0 ;
535535 }
536536
537- logger .debug ("Recovering from HTTP 503 - scheduling to reconnect in {0 } ms" , delay );
537+ logger .debug ("Recovering from HTTP 503 - scheduling to reconnect in {} ms" , delay );
538538 scheduleReconnect (delay );
539539 } catch (Exception ex ) {
540540 logger .debug ("Recovering from exception " + ex .getMessage () + "-- scheduling reconnect" );
@@ -614,7 +614,7 @@ private void notify(final EventListener listener, final InboundEvent event) {
614614 private void scheduleReconnect (final long delay ) {
615615 final State s = state .get ();
616616 if (s != State .OPEN ) {
617- logger .debug ("Aborting reconnect of event source in {0 } state" , state );
617+ logger .debug ("Aborting reconnect of event source in {} state" , state );
618618 return ;
619619 }
620620
0 commit comments