@Test @Ignore("Superseded by AlfrescoSolrTrackerTest") public void doTrackWithNoTransactionsDoesNothing() throws AuthenticationException, IOException, JSONException, EncoderException { TrackerState state = new TrackerState(); when(srv.getTrackerInitialState()).thenReturn(state); when(this.metadataTracker.getTrackerState()).thenReturn(state); Transactions txs = mock(Transactions.class); List<Transaction> txsList = new ArrayList<>(); when(txs.getTransactions()).thenReturn(txsList); when(repositoryClient.getTransactions(anyLong(), anyLong(), anyLong(), anyLong(), anyInt(), isNull(ShardState.class))).thenReturn(txs); when(repositoryClient.getTransactions(anyLong(), anyLong(), anyLong(), anyLong(), anyInt(), any(ShardState.class))).thenReturn(txs); when(repositoryClient.getTransactions(anyLong(), anyLong(), anyLong(), anyLong(), anyInt())).thenReturn(txs); this.metadataTracker.doTrack("AnIterationId"); verify(srv, never()).commit(); }
@Override protected void doTrack(String iterationId) throws AuthenticationException, IOException, JSONException { ModelTracker modelTracker = this.infoSrv.getAdminHandler().getTrackerRegistry().getModelTracker(); if (modelTracker != null && modelTracker.hasModels()) { trackRepository(); } else { invalidateState(); } }
MetadataTracker extends ActivatableTracker { @Override protected void doTrack(String iterationId) throws AuthenticationException, IOException, JSONException { ModelTracker modelTracker = this.infoSrv.getAdminHandler().getTrackerRegistry().getModelTracker(); if (modelTracker != null && modelTracker.hasModels()) { trackRepository(); } else { invalidateState(); } } }
MetadataTracker extends ActivatableTracker { @Override protected void doTrack(String iterationId) throws AuthenticationException, IOException, JSONException { ModelTracker modelTracker = this.infoSrv.getAdminHandler().getTrackerRegistry().getModelTracker(); if (modelTracker != null && modelTracker.hasModels()) { trackRepository(); } else { invalidateState(); } } MetadataTracker(Properties p, SOLRAPIClient client, String coreName,
            InformationServer informationServer);  MetadataTracker( Properties p, SOLRAPIClient client, String coreName,
                InformationServer informationServer, boolean checkRepoServicesAvailability);   MetadataTracker(); }
MetadataTracker extends ActivatableTracker { @Override protected void doTrack(String iterationId) throws AuthenticationException, IOException, JSONException { ModelTracker modelTracker = this.infoSrv.getAdminHandler().getTrackerRegistry().getModelTracker(); if (modelTracker != null && modelTracker.hasModels()) { trackRepository(); } else { invalidateState(); } } MetadataTracker(Properties p, SOLRAPIClient client, String coreName,
            InformationServer informationServer);  MetadataTracker( Properties p, SOLRAPIClient client, String coreName,
                InformationServer informationServer, boolean checkRepoServicesAvailability);   MetadataTracker(); @Override Semaphore getWriteLock(); @Override Semaphore getRunLock(); void maintenance(); boolean hasMaintenance(); @Override NodeReport checkNode(Long dbid); NodeReport checkNode(Node node); List<Node> getFullNodesForDbTransaction(Long txid); IndexHealthReport checkIndex(Long toTx, Long fromTime, Long toTime); void addTransactionToPurge(Long txId); void addNodeToPurge(Long nodeId); void addTransactionToReindex(Long txId); void addNodeToReindex(Long nodeId); void addTransactionToIndex(Long txId); void addNodeToIndex(Long nodeId); void invalidateState(); void addQueryToReindex(String query); }
MetadataTracker extends ActivatableTracker { @Override protected void doTrack(String iterationId) throws AuthenticationException, IOException, JSONException { ModelTracker modelTracker = this.infoSrv.getAdminHandler().getTrackerRegistry().getModelTracker(); if (modelTracker != null && modelTracker.hasModels()) { trackRepository(); } else { invalidateState(); } } MetadataTracker(Properties p, SOLRAPIClient client, String coreName,
            InformationServer informationServer);  MetadataTracker( Properties p, SOLRAPIClient client, String coreName,
                InformationServer informationServer, boolean checkRepoServicesAvailability);   MetadataTracker(); @Override Semaphore getWriteLock(); @Override Semaphore getRunLock(); void maintenance(); boolean hasMaintenance(); @Override NodeReport checkNode(Long dbid); NodeReport checkNode(Node node); List<Node> getFullNodesForDbTransaction(Long txid); IndexHealthReport checkIndex(Long toTx, Long fromTime, Long toTime); void addTransactionToPurge(Long txId); void addNodeToPurge(Long nodeId); void addTransactionToReindex(Long txId); void addNodeToReindex(Long nodeId); void addTransactionToIndex(Long txId); void addNodeToIndex(Long nodeId); void invalidateState(); void addQueryToReindex(String query);  }