diff --git a/services/beaconchain/src/main/java/tech/pegasys/teku/services/beaconchain/BeaconChainController.java b/services/beaconchain/src/main/java/tech/pegasys/teku/services/beaconchain/BeaconChainController.java index 811524b5a31..30fccc2eebb 100644 --- a/services/beaconchain/src/main/java/tech/pegasys/teku/services/beaconchain/BeaconChainController.java +++ b/services/beaconchain/src/main/java/tech/pegasys/teku/services/beaconchain/BeaconChainController.java @@ -688,19 +688,6 @@ protected void initSlashingEventsSubscriptions() { } } - protected void initSlashingEventsSubscriptions() { - if (beaconConfig.validatorConfig().isShutdownWhenValidatorSlashedEnabled()) { - final ValidatorTimingChannel validatorTimingChannel = - eventChannels.getPublisher(ValidatorTimingChannel.class); - attesterSlashingPool.subscribeOperationAdded( - (operation, validationStatus, fromNetwork) -> - validatorTimingChannel.onAttesterSlashing(operation)); - proposerSlashingPool.subscribeOperationAdded( - (operation, validationStatus, fromNetwork) -> - validatorTimingChannel.onProposerSlashing(operation)); - } - } - protected void initVoluntaryExitPool() { LOG.debug("BeaconChainController.initVoluntaryExitPool()"); VoluntaryExitValidator validator = new VoluntaryExitValidator(spec, recentChainData); diff --git a/validator/client/src/test/java/tech/pegasys/teku/validator/client/ValidatorTimingActionsTest.java b/validator/client/src/test/java/tech/pegasys/teku/validator/client/ValidatorTimingActionsTest.java index f80a9fcb4a5..66c288d7fcd 100644 --- a/validator/client/src/test/java/tech/pegasys/teku/validator/client/ValidatorTimingActionsTest.java +++ b/validator/client/src/test/java/tech/pegasys/teku/validator/client/ValidatorTimingActionsTest.java @@ -68,7 +68,7 @@ public class ValidatorTimingActionsTest { Map.entry(key4, ValidatorStatus.exited_slashed)); @Test - public void shouldPrintAlertForSlashedValidators_AttesterSlashing() { + public void shouldTriggerSlashingActionForSlashedValidators_AttesterSlashing() { final ValidatorTimingActions validatorTimingActions = new ValidatorTimingActions( validatorIndexProvider, delegates, spec, metricsSystem, maybeSlashedValidatorAction);