1414
1515package org .hyperledger .fabric .sdk ;
1616
17-
1817import java .io .File ;
1918import java .io .FileNotFoundException ;
2019import java .io .InputStream ;
2928import javax .json .JsonObjectBuilder ;
3029import javax .json .JsonValue ;
3130
31+ import io .grpc .ManagedChannelBuilder ;
3232import org .hyperledger .fabric .sdk .exception .InvalidArgumentException ;
3333import org .hyperledger .fabric .sdk .exception .NetworkConfigurationException ;
3434import org .hyperledger .fabric .sdk .security .CryptoSuite ;
3939import org .junit .Test ;
4040import org .junit .rules .ExpectedException ;
4141
42+ import static org .hyperledger .fabric .sdk .testutils .TestUtils .getField ;
43+ import static org .junit .Assert .assertEquals ;
4244import static org .junit .Assert .assertNotNull ;
4345import static org .junit .Assert .assertNull ;
4446import static org .junit .Assert .assertTrue ;
@@ -342,6 +344,13 @@ public void testLoadFromConfigFileYamlOverrides() throws Exception {
342344 config .setPeerProperties (peerName , peerProperties );
343345 }
344346
347+ for (String orderName : config .getOrdererNames ()) {
348+ Properties ordererProperties = config .getOrdererProperties (orderName );
349+ ordererProperties .put ("grpc.NettyChannelBuilderOption.maxInboundMessageSize" , 9000000 );
350+ ordererProperties .put ("grpc.NettyChannelBuilderOption.keepAliveWithoutCalls" , new Object [] {false });
351+ config .setOrdererProperties (orderName , ordererProperties );
352+ }
353+
345354 //HFClient client = HFClient.loadFromConfig(f);
346355 assertNotNull (config );
347356
@@ -363,6 +372,27 @@ public void testLoadFromConfigFileYamlOverrides() throws Exception {
363372 assertNotNull (properties .get ("grpc.NettyChannelBuilderOption.keepAliveTimeout" ));
364373 assertNotNull (properties .get ("grpc.NettyChannelBuilderOption.keepAliveWithoutCalls" ));
365374
375+ Endpoint ep = new Endpoint (peer .getUrl (), properties );
376+ ManagedChannelBuilder <?> channelBuilder = ep .getChannelBuilder ();
377+
378+ assertEquals (5L * 60L * 1000000000L , getField (channelBuilder , "keepAliveTimeNanos" ));
379+ assertEquals (8L * 1000000000L , getField (channelBuilder , "keepAliveTimeoutNanos" ));
380+ assertEquals (true , getField (channelBuilder , "keepAliveWithoutCalls" ));
381+ }
382+
383+ for (Orderer orderer : channel .getOrderers ()) {
384+
385+ Properties properties = orderer .getProperties ();
386+
387+ assertNotNull (properties );
388+ assertNotNull (properties .get ("grpc.NettyChannelBuilderOption.maxInboundMessageSize" ));
389+ assertNotNull (properties .get ("grpc.NettyChannelBuilderOption.keepAliveWithoutCalls" ));
390+
391+ Endpoint ep = new Endpoint (orderer .getUrl (), properties );
392+ ManagedChannelBuilder <?> channelBuilder = ep .getChannelBuilder ();
393+
394+ assertEquals (9000000 , getField (channelBuilder , "maxInboundMessageSize" ));
395+ assertEquals (false , getField (channelBuilder , "keepAliveWithoutCalls" ));
366396 }
367397
368398 }
0 commit comments