Do not wrap exception with TransportException
Change-Id: Ifd59da2a78a7c95a78758cbcf7a5fe015ed25f13
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportConnection.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportConnection.java
index 39ce10f..fafb2d0 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportConnection.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/impl/CopycatTransportConnection.java
@@ -37,10 +37,10 @@
import com.google.common.collect.Maps;
import static com.google.common.base.Preconditions.checkNotNull;
+import io.atomix.catalyst.serializer.SerializationException;
import io.atomix.catalyst.transport.Address;
import io.atomix.catalyst.transport.Connection;
import io.atomix.catalyst.transport.MessageHandler;
-import io.atomix.catalyst.transport.TransportException;
import io.atomix.catalyst.util.Assert;
import io.atomix.catalyst.util.Listener;
import io.atomix.catalyst.util.Listeners;
@@ -127,8 +127,8 @@
}
handleResponse(r, e, result, context);
});
- } catch (Exception e) {
- result.completeExceptionally(new TransportException("Failed to send request", e));
+ } catch (SerializationException | IOException e) {
+ result.completeExceptionally(e);
}
return result;
}