@Test public void testShutdown() throws Exception { connection.shutdown(); verify(readTransaction, atLeastOnce()).read(any(LogicalDatastoreType.class), any(InstanceIdentifier.class)); }
@Override public void shutdown() { LOG.info("Shutting down SXP datastore connection: {}", this); super.shutdown(); Connection connection = datastoreAccess != null ? datastoreAccess.readSynchronous(getIdentifier(), LogicalDatastoreType.OPERATIONAL) : null; if (connection != null) setConnection(connection); }
SxpDatastoreConnection extends org.opendaylight.sxp.core.SxpConnection { @Override public void shutdown() { LOG.info("Shutting down SXP datastore connection: {}", this); super.shutdown(); Connection connection = datastoreAccess != null ? datastoreAccess.readSynchronous(getIdentifier(), LogicalDatastoreType.OPERATIONAL) : null; if (connection != null) setConnection(connection); } }
SxpDatastoreConnection extends org.opendaylight.sxp.core.SxpConnection { @Override public void shutdown() { LOG.info("Shutting down SXP datastore connection: {}", this); super.shutdown(); Connection connection = datastoreAccess != null ? datastoreAccess.readSynchronous(getIdentifier(), LogicalDatastoreType.OPERATIONAL) : null; if (connection != null) setConnection(connection); } private  SxpDatastoreConnection(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection, String domain); }
SxpDatastoreConnection extends org.opendaylight.sxp.core.SxpConnection { @Override public void shutdown() { LOG.info("Shutting down SXP datastore connection: {}", this); super.shutdown(); Connection connection = datastoreAccess != null ? datastoreAccess.readSynchronous(getIdentifier(), LogicalDatastoreType.OPERATIONAL) : null; if (connection != null) setConnection(connection); } private  SxpDatastoreConnection(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection, String domain); static SxpDatastoreConnection create(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection,
            String domain); @Override void setNodeIdRemote(NodeId remoteNodeId); @Override void setUpdateOrKeepaliveMessageTimestamp(); @Override void shutdown(); }
SxpDatastoreConnection extends org.opendaylight.sxp.core.SxpConnection { @Override public void shutdown() { LOG.info("Shutting down SXP datastore connection: {}", this); super.shutdown(); Connection connection = datastoreAccess != null ? datastoreAccess.readSynchronous(getIdentifier(), LogicalDatastoreType.OPERATIONAL) : null; if (connection != null) setConnection(connection); } private  SxpDatastoreConnection(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection, String domain); static SxpDatastoreConnection create(DatastoreAccess datastoreAccess, SxpNode owner, Connection connection,
            String domain); @Override void setNodeIdRemote(NodeId remoteNodeId); @Override void setUpdateOrKeepaliveMessageTimestamp(); @Override void shutdown();  }