X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=restconf%2Frestconf-nb-rfc8040%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Frestconf%2Fnb%2Frfc8040%2Fhandlers%2FTransactionChainHandler.java;h=0e2df38e5fce0038081d037e7d66cc606ea2d1de;hb=57bcac385acfdc4255d1e67e7da6e348feba6630;hp=7c2440bc3f4666b81f4c4bd527e076cd17cff554;hpb=4e99f8da93b99168e8f43f68e238ff4e1fdda8cd;p=netconf.git diff --git a/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/handlers/TransactionChainHandler.java b/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/handlers/TransactionChainHandler.java index 7c2440bc3f..0e2df38e5f 100644 --- a/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/handlers/TransactionChainHandler.java +++ b/restconf/restconf-nb-rfc8040/src/main/java/org/opendaylight/restconf/nb/rfc8040/handlers/TransactionChainHandler.java @@ -8,6 +8,9 @@ package org.opendaylight.restconf.nb.rfc8040.handlers; import java.util.Objects; +import javax.annotation.PreDestroy; +import javax.inject.Inject; +import javax.inject.Singleton; import org.opendaylight.mdsal.dom.api.DOMDataBroker; import org.opendaylight.mdsal.dom.api.DOMDataTreeTransaction; import org.opendaylight.mdsal.dom.api.DOMTransactionChain; @@ -18,8 +21,8 @@ import org.slf4j.LoggerFactory; /** * Implementation of {@link TransactionChainHandler}. - * */ +@Singleton public class TransactionChainHandler implements Handler, AutoCloseable { private static final Logger LOG = LoggerFactory.getLogger(TransactionChainHandler.class); @@ -45,6 +48,7 @@ public class TransactionChainHandler implements Handler, Au /** * Prepare transaction chain service for Restconf services. */ + @Inject public TransactionChainHandler(final DOMDataBroker dataBroker) { this.dataBroker = Objects.requireNonNull(dataBroker); transactionChain = Objects.requireNonNull(dataBroker.createTransactionChain(transactionChainListener)); @@ -62,6 +66,7 @@ public class TransactionChainHandler implements Handler, Au } @Override + @PreDestroy public synchronized void close() { transactionChain.close(); }