mindol1004/spring-boot-rest
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Bael 5121 error handling (#11281)

Browse Source 
* Commit source code to branch

* BAEL-5065 improvement of groupBy with complex key

* Fixed indentation
This commit is contained in:
mbarriola
2021-10-03 22:57:34 -04:00
committed by GitHub
parent 71a4c3e244
commit d1c75c1ffc
1 changed files with 29 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
grpc/src/main/java/com/baeldung/grpc/errorhandling/CommodityClient.java
View File

@@ -29,7 +29,6 @@ public class CommodityClient {
nonBlockingStub = CommodityPriceProviderGrpc.newStub(channel); nonBlockingStub = CommodityPriceProviderGrpc.newStub(channel);
} }
public void getBidirectionalCommodityPriceLists() throws InterruptedException { public void getBidirectionalCommodityPriceLists() throws InterruptedException {
logger.info("#######START EXAMPLE#######: BidirectionalStreaming - getCommodityPriceLists from list of commodities"); logger.info("#######START EXAMPLE#######: BidirectionalStreaming - getCommodityPriceLists from list of commodities");
@@ -55,7 +54,8 @@ public void onNext(StreamingCommodityQuote streamingCommodityQuote) {
errorInfo = any.unpack(ErrorInfo.class); errorInfo = any.unpack(ErrorInfo.class);
logger.info("Reason:" + errorInfo.getReason()); logger.info("Reason:" + errorInfo.getReason());
logger.info("Domain:" + errorInfo.getDomain()); logger.info("Domain:" + errorInfo.getDomain());
logger.info("Insert Token:" + errorInfo.getMetadataMap().get("insertToken")); logger.info("Insert Token:" + errorInfo.getMetadataMap()
.get("insertToken"));
} catch (InvalidProtocolBufferException e) { } catch (InvalidProtocolBufferException e) {
logger.error(e.getMessage()); logger.error(e.getMessage());
} }
@@ -69,7 +69,7 @@ public void onNext(StreamingCommodityQuote streamingCommodityQuote) {
@Override @Override
public void onCompleted() { public void onCompleted() {
logger.info("Finished getBidirectionalCommodityPriceListss"); logger.info("Finished getBidirectionalCommodityPriceLists");
finishLatch.countDown(); finishLatch.countDown();
} }