### Question:
FullSyncIdentityConnector implements IdentityConnector { @Override public void init(IdentityConnectorContext context) throws Exception { service = checkNotNull(context.getIdentityService()); repositoryContext = RepositoryContext.fromConfiguration(); identitySyncType = Configuration.getValue( IDENTITY_SYNC_TYPE, IdentitySyncType.USERS_AND_GROUPS, IdentitySyncType::valueOf) .get(); logger.log(Level.CONFIG, "Identity Connector configured to sync [{0}]", identitySyncType); ExecutorService executor = Executors.newCachedThreadPool( new ThreadFactoryBuilder() .setDaemon(false) .setNameFormat("FullSyncIdentityConnector") .build()); listeningExecutorService = MoreExecutors.listeningDecorator(executor); stateManager.init( identityStateLoader.orElse( new FromGoogleIdentityStateLoader( service, repositoryContext.getIdentitySourceConfiguration(), listeningExecutorService, identitySyncType))); identityRepository.init(repositoryContext); traversalExceptionHandler = Configuration.getValue( TRAVERSE_EXCEPTION_HANDLER, new AbortCountExceptionHandler(0, 0, TimeUnit.SECONDS), new ExceptionHandlerParser()) .get(); } FullSyncIdentityConnector(Repository identityRepository);  FullSyncIdentityConnector(
      Repository identityRepository, IdentityStateLoader identityStateLoader); @VisibleForTesting  FullSyncIdentityConnector(
      Repository identityRepository,
      IdentityStateLoader identityStateLoader,
      StateManager stateManager); @Override void init(IdentityConnectorContext context); @Override void traverse(); @Override void saveCheckpoint(boolean isShutdown); @Override void destroy();  }### Answer:
@Test public void testConstructorAndInit() throws Exception { initConfig(new Properties()); IdentityConnector connector = new FullSyncIdentityConnector(mockIdentityRepository); connector.init(mockConnectorContext); verify(mockIdentityRepository).init(any()); }