BUG-2383: wire up AdjRibInWriter

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

diff --git a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/RIBImpl.java b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/RIBImpl.java
index c2cf319b09248f8aea55bb5c64cf19dee8bdb680..1531935ebe86800cb356b47a220b90dcd4860e2b 100644 (file)
--- a/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/RIBImpl.java
+++ b/bgp/rib-impl/src/main/java/org/opendaylight/protocol/bgp/rib/impl/RIBImpl.java
@@ -121,6 +121,7 @@ public final class RIBImpl extends DefaultRibReference implements AutoCloseable,
     private final BlockingQueue<Peer> peers;
     private final DataBroker dataBroker;
     private final DOMDataBroker domDataBroker;
+    private final RIBExtensionConsumerContext extensions;
 
     private final Runnable scheduler = new Runnable() {
         @Override
@@ -168,6 +169,7 @@ public final class RIBImpl extends DefaultRibReference implements AutoCloseable,
         this.peers = new LinkedBlockingQueue<>();
         this.dataBroker = dps;
         this.domDataBroker = Preconditions.checkNotNull(domDataBroker);
+        this.extensions = Preconditions.checkNotNull(extensions);
 
         LOG.debug("Instantiating RIB table {} at {}", ribId, getInstanceIdentifier());
 
@@ -449,4 +451,9 @@ public final class RIBImpl extends DefaultRibReference implements AutoCloseable,
     public DOMTransactionChain createPeerChain(final TransactionChainListener listener) {
         return domDataBroker.createTransactionChain(listener);
     }
+
+    @Override
+    public RIBExtensionConsumerContext getRibExtensions() {
+        return extensions;
+    }
 }