@Test public void testGetServiceStatus() { final Jvm jvm = new Jvm(new Identifier<Jvm>(1L), "some-jvm", new HashSet<Group>()); jvmStateService.getServiceStatus(jvm); verify(mockJvmCommandFactory).executeCommand(eq(jvm), eq(JvmControlOperation.CHECK_SERVICE_STATUS)); }
@Override public RemoteCommandReturnInfo getServiceStatus(final Jvm jvm) { return jvmCommandFactory.executeCommand(jvm, JvmControlOperation.CHECK_SERVICE_STATUS); }
JvmStateServiceImpl implements JvmStateService { @Override public RemoteCommandReturnInfo getServiceStatus(final Jvm jvm) { return jvmCommandFactory.executeCommand(jvm, JvmControlOperation.CHECK_SERVICE_STATUS); } }
JvmStateServiceImpl implements JvmStateService { @Override public RemoteCommandReturnInfo getServiceStatus(final Jvm jvm) { return jvmCommandFactory.executeCommand(jvm, JvmControlOperation.CHECK_SERVICE_STATUS); } @Autowired  JvmStateServiceImpl(final JvmPersistenceService jvmPersistenceService,
                               @Qualifier("jvmInMemoryStateManagerService")
                               final InMemoryStateManagerService<Identifier<Jvm>, CurrentState<Jvm, JvmState>> inMemoryStateManagerService,
                               final JvmStateResolverWorker jvmStateResolverWorker,
                               final MessagingService messagingService,
                               final GroupStateNotificationService groupStateNotificationService,
                               @Value("${jvm.state.update.interval:60000}")
                               final long jvmStateUpdateInterval,
                               final JvmCommandFactory jvmCommandFactory,
                               final SshConfiguration sshConfig,
                               @Value("${jvm.state.key.lock.timeout.millis:600000}")
                               final long lockTimeout,
                               @Value("${jvm.state.key.lock.stripe.count:120}")
                               final int keyLockStripeCount); }
JvmStateServiceImpl implements JvmStateService { @Override public RemoteCommandReturnInfo getServiceStatus(final Jvm jvm) { return jvmCommandFactory.executeCommand(jvm, JvmControlOperation.CHECK_SERVICE_STATUS); } @Autowired  JvmStateServiceImpl(final JvmPersistenceService jvmPersistenceService,
                               @Qualifier("jvmInMemoryStateManagerService")
                               final InMemoryStateManagerService<Identifier<Jvm>, CurrentState<Jvm, JvmState>> inMemoryStateManagerService,
                               final JvmStateResolverWorker jvmStateResolverWorker,
                               final MessagingService messagingService,
                               final GroupStateNotificationService groupStateNotificationService,
                               @Value("${jvm.state.update.interval:60000}")
                               final long jvmStateUpdateInterval,
                               final JvmCommandFactory jvmCommandFactory,
                               final SshConfiguration sshConfig,
                               @Value("${jvm.state.key.lock.timeout.millis:600000}")
                               final long lockTimeout,
                               @Value("${jvm.state.key.lock.stripe.count:120}")
                               final int keyLockStripeCount); @Override @Scheduled(fixedDelayString = "${ping.jvm.period.millis}") void verifyAndUpdateJvmStates(); @Override void updateNotInMemOrStaleState(final Jvm jvm, final JvmState state, final String errMsg); @Override RemoteCommandReturnInfo getServiceStatus(final Jvm jvm); @Override void updateState(Jvm jvm, final JvmState state); @Override void updateState(final Jvm jvm, final JvmState state, final String errMsg); }
JvmStateServiceImpl implements JvmStateService { @Override public RemoteCommandReturnInfo getServiceStatus(final Jvm jvm) { return jvmCommandFactory.executeCommand(jvm, JvmControlOperation.CHECK_SERVICE_STATUS); } @Autowired  JvmStateServiceImpl(final JvmPersistenceService jvmPersistenceService,
                               @Qualifier("jvmInMemoryStateManagerService")
                               final InMemoryStateManagerService<Identifier<Jvm>, CurrentState<Jvm, JvmState>> inMemoryStateManagerService,
                               final JvmStateResolverWorker jvmStateResolverWorker,
                               final MessagingService messagingService,
                               final GroupStateNotificationService groupStateNotificationService,
                               @Value("${jvm.state.update.interval:60000}")
                               final long jvmStateUpdateInterval,
                               final JvmCommandFactory jvmCommandFactory,
                               final SshConfiguration sshConfig,
                               @Value("${jvm.state.key.lock.timeout.millis:600000}")
                               final long lockTimeout,
                               @Value("${jvm.state.key.lock.stripe.count:120}")
                               final int keyLockStripeCount); @Override @Scheduled(fixedDelayString = "${ping.jvm.period.millis}") void verifyAndUpdateJvmStates(); @Override void updateNotInMemOrStaleState(final Jvm jvm, final JvmState state, final String errMsg); @Override RemoteCommandReturnInfo getServiceStatus(final Jvm jvm); @Override void updateState(Jvm jvm, final JvmState state); @Override void updateState(final Jvm jvm, final JvmState state, final String errMsg);  }