1 files changed, 1 insertions, 1 deletions
diff --git a/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt b/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt
index 6e707c3a..8de7da32 100644
--- a/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt
+++ b/sources/hv-collector-xnf-simulator/src/main/kotlin/org/onap/dcae/collectors/veshv/simulators/xnf/impl/adapters/VesHvClient.kt
@@ -95,7 +95,7 @@ class VesHvClient(private val configuration: SimulatorConfiguration) {
 
     private fun NettyOutbound.logConnectionClosed() =
             withConnection { conn ->
-                conn.onTerminate().subscribe {
+                conn.onDispose {
                     logger.info { "Connection to ${conn.address()} has been closed" }
                 }
             }