MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Change `MessagePersisterServiceCommand` to extend `ServerCommand`

This commit is contained in:
Chris Eager 2023-05-30 09:43:46 -05:00 committed by Chris Eager
parent 18480e9d18
commit dd552e8e8f
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
service/src/main/java/org/whispersystems/textsecuregcm/workers/MessagePersisterServiceCommand.java
View File

@ -6,7 +6,7 @@
package org.whispersystems.textsecuregcm.workers; package org.whispersystems.textsecuregcm.workers;
import io.dropwizard.Application; import io.dropwizard.Application;
import io.dropwizard.cli.EnvironmentCommand; import io.dropwizard.cli.ServerCommand;
import io.dropwizard.setup.Environment; import io.dropwizard.setup.Environment;
import java.time.Duration; import java.time.Duration;
import java.util.Optional; import java.util.Optional;
@ -19,7 +19,7 @@ import org.whispersystems.textsecuregcm.storage.DynamicConfigurationManager;
import org.whispersystems.textsecuregcm.storage.MessagePersister; import org.whispersystems.textsecuregcm.storage.MessagePersister;
import org.whispersystems.textsecuregcm.util.logging.UncaughtExceptionHandler; import org.whispersystems.textsecuregcm.util.logging.UncaughtExceptionHandler;
public class MessagePersisterServiceCommand extends EnvironmentCommand<WhisperServerConfiguration> { public class MessagePersisterServiceCommand extends ServerCommand<WhisperServerConfiguration> {
private static final String WORKER_COUNT = "workers"; private static final String WORKER_COUNT = "workers";
@ -69,6 +69,8 @@ public class MessagePersisterServiceCommand extends EnvironmentCommand<WhisperSe
environment.lifecycle().manage(deps.messagesCache()); environment.lifecycle().manage(deps.messagesCache());
environment.lifecycle().manage(messagePersister); environment.lifecycle().manage(messagePersister);
super.run(environment, namespace, configuration);
} }
} }