Merge pull request #873 from nimsara66/8129-master

Improve high frequent connection logins over the error 'broken-pipe' …

Author: nimsara66

components/data-bridge/org.wso2.carbon.databridge.agent/src/main/java/org/wso2/carbon/databridge/agent/endpoint/DataEndpoint.java

@@ -350,16 +350,14 @@ public void setPoolSemaphore(Semaphore semaphore) {
         }
 
         private void publish() throws DataEndpointException, SessionTimeoutException, UndefinedEventTypeException {
-            Object client = getClient();
             if (invalidateTransportPool) {
-                log.debug(
-                        "invalidateTransportPool' is 'true'. Going to discard existing client and get new client " +
-                                "for the DataEndpoint");
-                discardClient(client);
-                client = getClient();
+                transportPool.clear(getDataEndpointConfiguration().getPublisherKey());
+                log.debug("invalidateTransportPool' is 'true'. Discarding clients for the DataEndpoint: " +
+                        getDataEndpointConfiguration().getPublisherKey());
                 invalidateTransportPool = false;
                 log.debug("'invalidateTransportPool' is set to 'false' for the DataEndpoint");
             }
+            Object client = getClient();
             try {
                 send(client, this.events);
                 semaphoreRelease();