Stop the DeliveryDelayManager daemon.
432824
public final void stop()
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "stop");

        synchronized (lockObject)
        {
            addEnabled = false; // Prevent further DeliveryDelayables being added
            if (runEnabled)
            {
                runEnabled = false; // This should terminate DeliveryDelayManager
                deliveryDelayManagerStopTime = timeNow();
            }
            if (deliveryDelayAlarm != null) // Cancel any outstanding alarm
            {
                deliveryDelayAlarm.cancel();
                deliveryDelayAlarm = null;
            }
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "stop");
    }
98826
@Override
    public void deliveryDelayManagerStop() {

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "deliveryDelayManagerStop");
        _deliveryDelayManager.stop();
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "deliveryDelayManagerStop");
    }
373879
public synchronized void stop() {
        if (isRunning()) {
            socket.get().close();
            socket.set(null);
            deliverLifecycleAnnouncement(logger, false);
        }
    }
280388
def stop(self):
        
        LOGGER.debug("rabbitmq.Driver.stop")
        for requester in self.requester_registry:
            requester.stop()
        self.requester_registry.clear()

        for service in self.services_registry:
            if service.is_started:
                service.stop()
        self.services_registry.clear()

        pykka.ActorRegistry.stop_all()

        return self
541033
def Stop(self):
    """"""
    self._Close()

    if self._rpc_thread.isAlive():
      self._rpc_thread.join()
    self._rpc_thread = None
383939
def stop(self, ignore_state=False):
        """"""
        self.logger.debug("Stop service")
        self._toggle_running(False, ignore_state)
880166
def stop(self):
        
        LOGGER.debug("natsd.Driver.stop")
        for requester in self.requester_registry:
            requester.stop()
        self.requester_registry.clear()

        for service in self.services_registry:
            if service.is_started:
                service.stop()
        self.services_registry.clear()

        return self
1170014
def stop_other_daemons(self):
        
        if self.smbd.running:
            self.smbd.stop()

        if self.nmbd.running:
            self.nmbd.stop()
929967
def stop(self):
        """"""
        # Remove it completely instead of just stopping it to avoid filling up
        # the list with permanently stopped messages
        _canlib.canSchedulerRemMessage(self._scheduler, self._index)
        self._index = None
572682
def stop(self):
        """"""

        if self._disconnector:
            self._disconnector.stop()

        self.client.disconnect()
90825
def stop(self, handle, reason=None):
        """"""
        params = self._get_params(reason=reason)
        self._transport.stop(handle, params)
807672
public static synchronized void stop() {
		// WsHandlerManager manager = ManagerAdmin.getWsHandlerManager();
		if (svSuperPid != null) {
			LogRepositoryManager destManager = getManager(LogRepositoryBaseImpl.LOGTYPE) ;
			((LogRepositorySubManagerImpl)destManager).inactivateSubProcess() ;
		}
			
		Logger manager = Logger.getLogger("");
		if (binaryHandler != null) {
			manager.removeHandler(binaryHandler);
			binaryHandler.stop();
			binaryHandler = null;
		}
		if (textHandler != null) {
			manager.removeHandler(textHandler);
			textHandler.stop();
			textHandler = null;
		}
		LogRepositorySpaceAlert.getInstance().stop() ;		// 694351
	}
1312192
def stop(self):
        
        self.stopped_by_interrupt = True

        if self.executor:
            self.executor.stop()
137737
def stop(self):
        
        msg = cr.Message()
        msg.type = cr.STOP
        self.send_message(msg)
804594
def request_stop(self, message='', exit_code=0):
        
        # Only a master arbiter can stop the daemons
        if self.is_master:
            # Stop the daemons
            self.daemons_stop(timeout=self.conf.daemons_stop_timeout)

        # Request the daemon stop
        super(Arbiter, self).request_stop(message, exit_code)
615735
public void stop() {
        try {
            if (CollectionUtils.isEmpty(consumer.subscription())) {
                consumer.unsubscribe();
            }
        } finally {
            consumer.close(Duration.ofMillis(10 * 1000L));
        }
    }
456933
protected void stop() {
        this.authenticating = false;
        // clear batcher
        batcher.clear();
        // set non-continuous
        setLifecycle(Replication.Lifecycle.ONESHOT);
        // cancel if middle of retry
        cancelRetryFuture();
        // cancel all pending future tasks.
        while (!pendingFutures.isEmpty()) {
            Future future = pendingFutures.poll();
            if (future != null && !future.isCancelled() && !future.isDone()) {
                future.cancel(true);
                CancellableRunnable runnable = cancellables.get(future);
                if (runnable != null) {
                    runnable.cancel();
                    cancellables.remove(future);
                }
            }
        }
    }