@Test public void shouldServiceQuitWhenFeatureIsDisabled() { EasyMock.expect(configurationMock.isUserHookEnabled()).andReturn(Boolean.FALSE); replayAll(); Boolean triggered = hookService.execute(hookContext); Assert.assertFalse("The hook must not be triggered if feature is disabled!", triggered); }
@Override public boolean execute(HookContext hookContext) { LOGGER.info("Executing user hook for {}. ", hookContext); PostUserCreationHookContext hookCtx = validateHookInput(hookContext); if (!checkUserHookPrerequisites()) { LOGGER.warn("Prerequisites for user hook are not satisfied. Hook not triggered"); return false; } if (hookCtx.getUserGroups().isEmpty()) { LOGGER.info("No users found for executing user hook for"); return false; } UserCreatedEvent userCreatedEvent = (UserCreatedEvent) eventFactory.newUserCreatedEvent(hookCtx); LOGGER.info("Triggering user hook for user: {}", hookContext); ambariEventPublisher.publish(userCreatedEvent); return true; }
UserHookService implements HookService { @Override public boolean execute(HookContext hookContext) { LOGGER.info("Executing user hook for {}. ", hookContext); PostUserCreationHookContext hookCtx = validateHookInput(hookContext); if (!checkUserHookPrerequisites()) { LOGGER.warn("Prerequisites for user hook are not satisfied. Hook not triggered"); return false; } if (hookCtx.getUserGroups().isEmpty()) { LOGGER.info("No users found for executing user hook for"); return false; } UserCreatedEvent userCreatedEvent = (UserCreatedEvent) eventFactory.newUserCreatedEvent(hookCtx); LOGGER.info("Triggering user hook for user: {}", hookContext); ambariEventPublisher.publish(userCreatedEvent); return true; } }
UserHookService implements HookService { @Override public boolean execute(HookContext hookContext) { LOGGER.info("Executing user hook for {}. ", hookContext); PostUserCreationHookContext hookCtx = validateHookInput(hookContext); if (!checkUserHookPrerequisites()) { LOGGER.warn("Prerequisites for user hook are not satisfied. Hook not triggered"); return false; } if (hookCtx.getUserGroups().isEmpty()) { LOGGER.info("No users found for executing user hook for"); return false; } UserCreatedEvent userCreatedEvent = (UserCreatedEvent) eventFactory.newUserCreatedEvent(hookCtx); LOGGER.info("Triggering user hook for user: {}", hookContext); ambariEventPublisher.publish(userCreatedEvent); return true; }  }
UserHookService implements HookService { @Override public boolean execute(HookContext hookContext) { LOGGER.info("Executing user hook for {}. ", hookContext); PostUserCreationHookContext hookCtx = validateHookInput(hookContext); if (!checkUserHookPrerequisites()) { LOGGER.warn("Prerequisites for user hook are not satisfied. Hook not triggered"); return false; } if (hookCtx.getUserGroups().isEmpty()) { LOGGER.info("No users found for executing user hook for"); return false; } UserCreatedEvent userCreatedEvent = (UserCreatedEvent) eventFactory.newUserCreatedEvent(hookCtx); LOGGER.info("Triggering user hook for user: {}", hookContext); ambariEventPublisher.publish(userCreatedEvent); return true; }  @Override boolean execute(HookContext hookContext); @Subscribe void onUserCreatedEvent(UserCreatedEvent event); }
UserHookService implements HookService { @Override public boolean execute(HookContext hookContext) { LOGGER.info("Executing user hook for {}. ", hookContext); PostUserCreationHookContext hookCtx = validateHookInput(hookContext); if (!checkUserHookPrerequisites()) { LOGGER.warn("Prerequisites for user hook are not satisfied. Hook not triggered"); return false; } if (hookCtx.getUserGroups().isEmpty()) { LOGGER.info("No users found for executing user hook for"); return false; } UserCreatedEvent userCreatedEvent = (UserCreatedEvent) eventFactory.newUserCreatedEvent(hookCtx); LOGGER.info("Triggering user hook for user: {}", hookContext); ambariEventPublisher.publish(userCreatedEvent); return true; }  @Override boolean execute(HookContext hookContext); @Subscribe void onUserCreatedEvent(UserCreatedEvent event);  }