You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Is your feature request related to a problem? Please describe.
public void stop(String logicalQueueName) {
stopQueue(logicalQueueName);
try {
if (isRunning(logicalQueueName)) {
Future<?> future = this.scheduledFutureByQueue.remove(logicalQueueName);
if (future != null) {
future.get(this.queueStopTimeout, TimeUnit.MILLISECONDS);
}
}
}
catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
catch (ExecutionException | TimeoutException e) {
getLogger().warn("Error stopping queue with name: '" + logicalQueueName + "'", e);
}
}
There used to be a queueStopTimeout in the previous version, that let us, shut the queue down by interrupting the thread, when the application shuts down. In v3
@Override
public void stop() {
if (!this.isRunning) {
return;
}
logger.debug("Stopping container {}", this.id);
synchronized (this.lifecycleMonitor) {
this.isRunning = false;
doStop();
}
logger.info("Container {} stopped", this.id);
}
Please advice if this exists, leave implementation, do you see a "hacky" way?
You'll find listenerShutdownTimeout and acknowledgementShutdownTimeout there which you can configure to achieve your goal. Set to Duration.ZERO if you don't want any wait.
Type: Feature
Is your feature request related to a problem? Please describe.
public void stop(String logicalQueueName) {
stopQueue(logicalQueueName);
Another hacky thing I had to do: #1055
The text was updated successfully, but these errors were encountered: