import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.mdsal.dom.api.DOMDataTreeCursorAwareTransaction;
import org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.mdsal.dom.api.DOMDataTreeCursorAwareTransaction;
import org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier;
private static final Logger LOG = LoggerFactory.getLogger(ProduceTransactionsHandler.class);
private final SettableFuture<RpcResult<ProduceTransactionsOutput>> future = SettableFuture.create();
private static final Logger LOG = LoggerFactory.getLogger(ProduceTransactionsHandler.class);
private final SettableFuture<RpcResult<ProduceTransactionsOutput>> future = SettableFuture.create();
- tx.submit().checkedGet(INIT_TX_TIMEOUT_SECONDS, TimeUnit.SECONDS);
- } catch (final Exception e) {
+ tx.submit().get(INIT_TX_TIMEOUT_SECONDS, TimeUnit.SECONDS);
+ } catch (InterruptedException | ExecutionException | TimeoutException e) {
LOG.warn("Unable to fill the initial item list.", e);
closeProducer(itemProducer);
LOG.warn("Unable to fill the initial item list.", e);
closeProducer(itemProducer);