From 37a3bbf542f8e5cd07338855b9ac3a90eb5f124e Mon Sep 17 00:00:00 2001 From: Jegadeesh Babu Date: Fri, 1 Mar 2019 19:28:38 +0530 Subject: Handled interrupted exception sonar fix Sonar fix Issue-ID: APPC-1517 Change-Id: I0a9fb64812c84963b08a53b09358f598d96eb014 Signed-off-by: Jegadeesh Babu --- .../adapter/messaging/dmaap/impl/DmaapProducerImpl.java | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) (limited to 'appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle') diff --git a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/impl/DmaapProducerImpl.java b/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/impl/DmaapProducerImpl.java index 409dbebf3..efff18ed9 100644 --- a/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/impl/DmaapProducerImpl.java +++ b/appc-adapters/appc-dmaap-adapter/appc-dmaap-adapter-bundle/src/main/java/org/onap/appc/adapter/messaging/dmaap/impl/DmaapProducerImpl.java @@ -6,6 +6,8 @@ * ================================================================================ * Copyright (C) 2017 Amdocs * ============================================================================= + * Modifications Copyright (C) 2019 IBM + * ============================================================================= * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at @@ -186,11 +188,14 @@ public class DmaapProducerImpl implements Producer { } LOG.debug("Closing Dmaap producer clients...."); for (MRBatchingPublisher client : clients) { - try { - client.close(1, TimeUnit.SECONDS); - } catch (IOException | InterruptedException e) { - LOG.warn(String.format("Failed to cleanly close Dmaap connection for [%s]", client), e); - } + try { + client.close(1, TimeUnit.SECONDS); + } catch (InterruptedException e) { + LOG.warn(String.format("Failed to cleanly close Dmaap connection for [%s]", client), e); + Thread.currentThread().interrupt(); + } catch (IOException e) { + LOG.warn(String.format("Failed to cleanly close Dmaap connection for [%s]", client), e); + } } } -- cgit 1.2.3-korg