| | |
| | | * |
| | | * Copyright 2008-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011-2016 ForgeRock AS. |
| | | * Portions Copyright 2025 3A Systems LLC. |
| | | * Portions Copyright 2025-2026 3A Systems LLC. |
| | | */ |
| | | package org.opends.server.replication.service; |
| | | |
| | |
| | | import java.util.concurrent.ConcurrentHashMap; |
| | | import java.util.concurrent.ExecutorService; |
| | | import java.util.concurrent.Executors; |
| | | import java.util.concurrent.TimeUnit; |
| | | import java.util.concurrent.TimeoutException; |
| | | import java.util.concurrent.atomic.AtomicInteger; |
| | | import java.util.concurrent.atomic.AtomicReference; |
| | |
| | | { |
| | | broker.stop(); |
| | | } |
| | | try { |
| | | exportThreadPool.shutdown(); |
| | | boolean timedOut = exportThreadPool.awaitTermination(100, TimeUnit.SECONDS); |
| | | logger.info(LocalizableMessage.raw("export pool termination timed out: " + timedOut)); |
| | | } catch (InterruptedException e) { |
| | | // Give up waiting. |
| | | } |
| | | |
| | | // Stop the listener thread |
| | | if (listenerThread != null) |