BUG-7706: Fix ServiceUnavailableException

[bgpcep.git] / bgp / rib-impl / src / main / java / org / opendaylight / protocol / bgp / rib / impl / spi / BGPDispatcher.java

diff --git a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/spi/BGPDispatcher.java b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/spi/BGPDispatcher.java
index 0b2b35a764957e604685e0264964ae4c04e4a2e9..18e40f9559558391885a131099a079cb6da06e5c 100755 (executable)
--- a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/spi/BGPDispatcher.java
+++ b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/spi/BGPDispatcher.java
@@ -23,31 +23,33 @@ public interface BGPDispatcher{
      * Creates BGP client.
      *
      * @param remoteAddress remote Peer address
-     * @param peerRegistry BGP peer registry
      * @param retryTimer Retry timer
      * @return Future promising a client session
      */
-    Future<? extends BGPSession> createClient(InetSocketAddress remoteAddress, BGPPeerRegistry peerRegistry, int retryTimer);
+    Future<? extends BGPSession> createClient(InetSocketAddress remoteAddress, int retryTimer);
 
     /**
      * Creates Reconnecting client.
      *
      * @param remoteAddress remote Peer Address
-     * @param peerRegistry BGP peer registry
      * @param retryTimer Retry timer
      * @param keys for TCPMD5
      * @return Future promising a client session
      */
-    Future<Void> createReconnectingClient(InetSocketAddress remoteAddress,
-        BGPPeerRegistry peerRegistry, int retryTimer, Optional<KeyMapping> keys);
+    Future<Void> createReconnectingClient(InetSocketAddress remoteAddress, int retryTimer, Optional<KeyMapping> keys);
 
     /**
      * Create new BGP server to accept incoming bgp connections (bound to provided socket localAddress).
      *
-     * @param peerRegistry BGP peer registry
      * @param localAddress Peer localAddress
      *
      * @return ChannelFuture promising a client session
      */
-    ChannelFuture createServer(BGPPeerRegistry peerRegistry, InetSocketAddress localAddress);
+    ChannelFuture createServer(InetSocketAddress localAddress);
+
+    /**
+     * Return BGP Peer Registry
+     * @return BGPPeerRegistry
+     */
+    BGPPeerRegistry getBGPPeerRegistry();
 }