Provide auto-reconnection for Sink

[mdsal.git] / replicate / mdsal-replicate-netty / src / main / resources / OSGI-INF / blueprint / netty-replication-sink.xml

diff --git a/replicate/mdsal-replicate-netty/src/main/resources/OSGI-INF/blueprint/netty-replication-sink.xml b/replicate/mdsal-replicate-netty/src/main/resources/OSGI-INF/blueprint/netty-replication-sink.xml
index a5bbbc00635bb173df11d6f4b65cedf5477b0643..7aefce2e3538a4a14f447cb2065790a2eec9267c 100644 (file)
--- a/replicate/mdsal-replicate-netty/src/main/resources/OSGI-INF/blueprint/netty-replication-sink.xml
+++ b/replicate/mdsal-replicate-netty/src/main/resources/OSGI-INF/blueprint/netty-replication-sink.xml
@@ -8,6 +8,7 @@
       <cm:property name="source-host" value="127.0.0.1"/>
       <cm:property name="source-port" value="9999"/>
       <cm:property name="reconnect-delay-millis" value="3000"/>
+      <cm:property name="keepalive-interval-seconds" value="10"/>
     </cm:default-properties>
   </cm:property-placeholder>
 
@@ -15,6 +16,10 @@
     <argument value="$(reconnect-delay-millis)"/>
   </bean>
 
+  <bean id="keepaliveInterval" class="java.time.Duration" factory-method="ofSeconds">
+    <argument value="$(keepalive-interval-seconds)"/>
+  </bean>
+
   <bean id="sourceAddress" class="java.net.InetAddress" factory-method="getByName">
     <argument value="$(source-host)"/>
   </bean>
@@ -28,6 +33,7 @@
     <argument ref="sourceAddress"/>
     <argument value="$(source-port)"/>
     <argument ref="reconnectDelay"/>
+    <argument ref="keepaliveInterval"/>
   </bean>
 
 </blueprint>