// context
try {
_database.begin();
Connection connection = _database.getConnection();
adapter.addDestination(connection, destination.getName(), queue);
_database.commit();
} catch (Exception exception) { // JMSException, PersistenceException
cleanup("Failed to create persistent destination "
+ destination.getName(), exception);
}