@Test @Ignore("Superseded by AlfrescoSolrTrackerTest") public void testGetFullNodesForDbTransaction() throws AuthenticationException, IOException, JSONException { List<Node> nodes = getNodes(); when(repositoryClient.getNodes(any(GetNodesParameters.class), anyInt())).thenReturn(nodes); List<Node> nodes4Tx = this.metadataTracker.getFullNodesForDbTransaction(TX_ID); assertSame(nodes4Tx, nodes); }
public List<Node> getFullNodesForDbTransaction(Long txid) { try { GetNodesParameters gnp = new GetNodesParameters(); ArrayList<Long> txs = new ArrayList<>(); txs.add(txid); gnp.setTransactionIds(txs); gnp.setStoreProtocol(storeRef.getProtocol()); gnp.setStoreIdentifier(storeRef.getIdentifier()); gnp.setCoreName(coreName); return client.getNodes(gnp, Integer.MAX_VALUE); } catch (IOException | AuthenticationException | JSONException e) { throw new AlfrescoRuntimeException("Failed to get nodes", e); } }
MetadataTracker extends ActivatableTracker { public List<Node> getFullNodesForDbTransaction(Long txid) { try { GetNodesParameters gnp = new GetNodesParameters(); ArrayList<Long> txs = new ArrayList<>(); txs.add(txid); gnp.setTransactionIds(txs); gnp.setStoreProtocol(storeRef.getProtocol()); gnp.setStoreIdentifier(storeRef.getIdentifier()); gnp.setCoreName(coreName); return client.getNodes(gnp, Integer.MAX_VALUE); } catch (IOException | AuthenticationException | JSONException e) { throw new AlfrescoRuntimeException("Failed to get nodes", e); } } }
MetadataTracker extends ActivatableTracker { public List<Node> getFullNodesForDbTransaction(Long txid) { try { GetNodesParameters gnp = new GetNodesParameters(); ArrayList<Long> txs = new ArrayList<>(); txs.add(txid); gnp.setTransactionIds(txs); gnp.setStoreProtocol(storeRef.getProtocol()); gnp.setStoreIdentifier(storeRef.getIdentifier()); gnp.setCoreName(coreName); return client.getNodes(gnp, Integer.MAX_VALUE); } catch (IOException | AuthenticationException | JSONException e) { throw new AlfrescoRuntimeException("Failed to get nodes", e); } } MetadataTracker(Properties p, SOLRAPIClient client, String coreName,
            InformationServer informationServer);  MetadataTracker( Properties p, SOLRAPIClient client, String coreName,
                InformationServer informationServer, boolean checkRepoServicesAvailability);   MetadataTracker(); }
MetadataTracker extends ActivatableTracker { public List<Node> getFullNodesForDbTransaction(Long txid) { try { GetNodesParameters gnp = new GetNodesParameters(); ArrayList<Long> txs = new ArrayList<>(); txs.add(txid); gnp.setTransactionIds(txs); gnp.setStoreProtocol(storeRef.getProtocol()); gnp.setStoreIdentifier(storeRef.getIdentifier()); gnp.setCoreName(coreName); return client.getNodes(gnp, Integer.MAX_VALUE); } catch (IOException | AuthenticationException | JSONException e) { throw new AlfrescoRuntimeException("Failed to get nodes", e); } } 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 { public List<Node> getFullNodesForDbTransaction(Long txid) { try { GetNodesParameters gnp = new GetNodesParameters(); ArrayList<Long> txs = new ArrayList<>(); txs.add(txid); gnp.setTransactionIds(txs); gnp.setStoreProtocol(storeRef.getProtocol()); gnp.setStoreIdentifier(storeRef.getIdentifier()); gnp.setCoreName(coreName); return client.getNodes(gnp, Integer.MAX_VALUE); } catch (IOException | AuthenticationException | JSONException e) { throw new AlfrescoRuntimeException("Failed to get nodes", e); } } 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);  }