@Nonnull
    Lookup getLookup();

    /**
     * The TCCL, if implementation requires it.
     */
    @Nonnull
    Optional<ClassLoader> currentThreadClassLoader();

    /**
     * Performs a clean shutdown of backing container.
     */
    @Override
    void close() throws Exception;

  @Throws(InterruptedException::class)
  abstract fun dispatch(request: RecordedRequest): MockResponse

  open fun peek(): MockResponse = MockResponse().apply { this.socketPolicy = SocketPolicy.KEEP_OPEN }

  open fun shutdown() {}

        }
    }

    /**
     * Cleanup and shutdown the multi-channel manager.
     */
    public void shutdown() {
        log.info("Shutting down MultiChannelManager");

        // Close all channels
        for (String sessionId : new ArrayList<>(sessionChannels.keySet())) {
            removeChannels(sessionId);
        }

        // Shutdown thread pools
        healthCheckExecutor.shutdown();

        }
    }

    @Test
    @DisplayName("MultiChannelManager should shutdown cleanly")
    void testShutdown() {
        assertDoesNotThrow(() -> {
            multiChannelManager.shutdown();
        });
    }

    @Test
    @DisplayName("createDefaultContext should work")
    void testCreateDefaultContext() throws Exception {

  public open fun peek(): MockResponse = MockResponse()

  /**
   * Release any resources held by this dispatcher. Any requests that are currently being dispatched
   * should return immediately. Responses returned after shutdown will not be transmitted: their
   * socket connections have already been closed.
   */
  public open override fun close() {}

            // Recovery not possible, remove synchronously
            removeChannel(failedChannel);
            return;
        }
    }

    /**
     * Shutdown the failover handler
     */
    public void shutdown() {
        executor.shutdown();
        try {
            if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
                executor.shutdownNow();
            }

            changeNotifier.stopWatching(directoryPath);
            baseLeaseManager.releaseLease(entry.getLeaseKey());
        }
    }

    /**
     * Shutdown the directory lease manager
     */
    public void shutdown() {
        scheduler.shutdown();
        try {
            if (!scheduler.awaitTermination(5, TimeUnit.SECONDS)) {
                scheduler.shutdownNow();
            }

            method.invoke(null, (Object[]) null);
        } catch (final ClassNotFoundException e) {
            // ignore
        } catch (final Exception e) {
            logger.warn("Could not shutdown Commons HttpClient.", e);
        }
    }

func (er erasureObjects) NewNSLock(bucket string, objects ...string) RWLocker {
	return er.nsMutex.NewNSLock(er.getLockers, bucket, objects...)
}

// Shutdown function for object storage interface.
func (er erasureObjects) Shutdown(ctx context.Context) error {
	// Add any object layer shutdown activities here.
	closeStorageDisks(er.getDisks()...)
	return nil
}

// defaultWQuorum write quorum based on setDriveCount and defaultParityCount

            throw new AssertionError(
                "ForwardingExecutorService should have used the default method"
                    + " ExecutorService.close() (which would forward to methods like shutdown() on"
                    + " the delegate) instead of forwarding to delegate.close()");
          }
        };
    ExecutorService wrapper =
        new ForwardingExecutorService() {
          @Override