@@ -134,7 +134,7 @@ protected ManagedChannel newManagedChannel(final String name) {
134
134
final T builder = newChannelBuilder (name );
135
135
configure (builder , name );
136
136
final ManagedChannel channel = builder .build ();
137
- final Duration timeout = properties .getChannel (name ).getImmediateConnectTimeout ();
137
+ final Duration timeout = this . properties .getChannel (name ).getImmediateConnectTimeout ();
138
138
if (!timeout .isZero ()) {
139
139
connectOnStartup (name , channel , timeout );
140
140
}
@@ -260,7 +260,7 @@ protected void watchConnectivityState(final String name, final ManagedChannel ch
260
260
}
261
261
}
262
262
263
- private void connectOnStartup (String name , ManagedChannel channel , Duration timeout ) {
263
+ private void connectOnStartup (final String name , final ManagedChannel channel , final Duration timeout ) {
264
264
log .debug ("Initiating connection to channel {}" , name );
265
265
channel .getState (true );
266
266
@@ -270,7 +270,7 @@ private void connectOnStartup(String name, ManagedChannel channel, Duration time
270
270
try {
271
271
log .debug ("Waiting for connection to channel {}" , name );
272
272
connected = !readyLatch .await (timeout .toMillis (), TimeUnit .MILLISECONDS );
273
- } catch (InterruptedException e ) {
273
+ } catch (final InterruptedException e ) {
274
274
Thread .currentThread ().interrupt ();
275
275
connected = false ;
276
276
}
@@ -280,7 +280,7 @@ private void connectOnStartup(String name, ManagedChannel channel, Duration time
280
280
log .info ("Successfully connected to channel {}" , name );
281
281
}
282
282
283
- private void waitForReady (ManagedChannel channel , CountDownLatch readySignal ) {
283
+ private void waitForReady (final ManagedChannel channel , final CountDownLatch readySignal ) {
284
284
final ConnectivityState state = channel .getState (false );
285
285
log .debug ("Waiting for ready state. Currently in {}" , state );
286
286
if (state == ConnectivityState .READY ) {
0 commit comments