Netty Replicator - improve the reconnection and keepalive mechanisms

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

diff --git a/replicate/mdsal-replicate-netty/src/main/resources/OSGI-INF/blueprint/netty-replication-source.xml b/replicate/mdsal-replicate-netty/src/main/resources/OSGI-INF/blueprint/netty-replication-source.xml
index 41b4e106ad7418bc8e0fd8749610b3942f1a68ff..48545feefbf0bea95e6129557a780dc640256734 100644 (file)
--- a/replicate/mdsal-replicate-netty/src/main/resources/OSGI-INF/blueprint/netty-replication-source.xml
+++ b/replicate/mdsal-replicate-netty/src/main/resources/OSGI-INF/blueprint/netty-replication-source.xml
@@ -5,9 +5,15 @@
     <cm:default-properties>
       <cm:property name="enabled" value="false"/>
       <cm:property name="listen-port" value="9999"/>
+      <cm:property name="keepalive-interval-seconds" value="$common(keepalive-interval-seconds)"/>
+      <cm:property name="max-missed-keepalives" value="$common(max-missed-keepalives)"/>
     </cm:default-properties>
   </cm:property-placeholder>
 
+  <bean id="keepaliveInterval" class="java.time.Duration" factory-method="ofSeconds">
+    <argument value="${keepalive-interval-seconds}"/>
+  </bean>
+
   <bean id="nettyReplicationSource" class="org.opendaylight.mdsal.replicate.netty.NettyReplication"
         factory-method="createSource" destroy-method="close">
     <argument ref="bootstrapSupport"/>
@@ -15,5 +21,7 @@
     <argument ref="singletonServiceProvider"/>
     <argument value="${enabled}"/>
     <argument value="${listen-port}"/>
+    <argument ref="keepaliveInterval"/>
+    <argument value="${max-missed-keepalives}"/>
   </bean>
 </blueprint>