Package org.jumpmind.symmetric.service

Interface IOutgoingBatchService

All Known Implementing Classes:
OutgoingBatchService
public interface IOutgoingBatchService
This service provides an API to access to the outgoing batch table.

  • Method Details

    • getNodesInError

      List<String> getNodesInError()

    • updateOutgoingError

      void updateOutgoingError(long batchId, String nodeId)

    • markAllAsSentForNode

      void markAllAsSentForNode(String nodeId, boolean includeConfigChannel)

    • markAllConfigAsSentForNode

      void markAllConfigAsSentForNode(String nodeId)

    • updateAbandonedRoutingBatches

      void updateAbandonedRoutingBatches()

    • findOutgoingBatch

      OutgoingBatch findOutgoingBatch(long batchId, String nodeId)

    • getOutgoingBatches

      OutgoingBatches getOutgoingBatches(String nodeId, boolean includeDisabledChannels)

    • getOutgoingBatches

      OutgoingBatches getOutgoingBatches(String nodeId, String channelId, boolean includeDisabledChannels)

    • getOutgoingBatches

      OutgoingBatches getOutgoingBatches(String nodeId, String channelThread, NodeGroupLinkAction eventAction, NodeGroupLinkAction defaultEventAction, boolean includeDisabledChannels)

    • getOutgoingBatchRange

      OutgoingBatches getOutgoingBatchRange(long startBatchId, long endBatchId)

    • getOutgoingBatchByLoad

      OutgoingBatches getOutgoingBatchByLoad(long loadI)

    • getOutgoingBatchByLoadRangeAndTable

      OutgoingBatches getOutgoingBatchByLoadRangeAndTable(long loadId, long startBatchId, long endBatchId, String tableName)

    • cancelLoadBatches

      int cancelLoadBatches(long loadId)

    • getOutgoingBatchRange

      OutgoingBatches getOutgoingBatchRange(String nodeId, Date startDate, Date endDate, String... channels)

    • getOutgoingBatchErrors

      OutgoingBatches getOutgoingBatchErrors(int maxRows)

    • isInitialLoadComplete

      boolean isInitialLoadComplete(String nodeId)

    • areAllLoadBatchesComplete

      boolean areAllLoadBatchesComplete(String nodeId)

    • isUnsentDataOnChannelForNode

      boolean isUnsentDataOnChannelForNode(String channelId, String nodeId)

    • updateOutgoingBatch

      void updateOutgoingBatch(OutgoingBatch batch)

    • updateOutgoingBatchStatus

      void updateOutgoingBatchStatus(ISqlTransaction transaction, AbstractBatch.Status status, String nodeId, long startBatchId, long endBatchId)

    • updateOutgoingSetupBatchStatusByStatus

      void updateOutgoingSetupBatchStatusByStatus(ISqlTransaction transaction, String targetNodeId, long loadId, long maxBatchId, String fromStatus, String toStatus)

    • updateOutgoingLoadBatchStatusByStatus

      void updateOutgoingLoadBatchStatusByStatus(ISqlTransaction transaction, String targetNodeId, long loadId, long startDataBatchId, long endDataBatchId, String fromStatus, String toStatus)

    • updateOutgoingFinalizeBatchStatusByStatus

      void updateOutgoingFinalizeBatchStatusByStatus(ISqlTransaction transaction, String targetNodeId, long loadId, long minBatchId, String fromStatus, String toStatus)

    • updateCommonBatchExtractStatistics

      void updateCommonBatchExtractStatistics(OutgoingBatch batch)

    • updateOutgoingBatch

      void updateOutgoingBatch(ISqlTransaction transaction, OutgoingBatch outgoingBatch)

    • updateOutgoingBatches

      void updateOutgoingBatches(List<OutgoingBatch> batches)

    • updateOutgoingBatches

      void updateOutgoingBatches(ISqlTransaction transaction, List<OutgoingBatch> batches, int flushSize)

    • insertOutgoingBatch

      void insertOutgoingBatch(OutgoingBatch outgoingBatch)

    • insertOutgoingBatch

      void insertOutgoingBatch(ISqlTransaction transaction, OutgoingBatch outgoingBatch)

    • insertOutgoingBatches

      void insertOutgoingBatches(ISqlTransaction transaction, List<OutgoingBatch> batches, int flushSize, boolean isCommon)

    • countOutgoingBatchesInError

      int countOutgoingBatchesInError()

    • getOutgoingBatchesLatestUpdateSql

      Date getOutgoingBatchesLatestUpdateSql()

    • countOutgoingBatchesUnsent

      int countOutgoingBatchesUnsent()

    • countOutgoingNonSystemBatchesRowsUnsent

      int[] countOutgoingNonSystemBatchesRowsUnsent()

    • countOutgoingBatchesInError

      int countOutgoingBatchesInError(String channelId)

    • countOutgoingBatchesUnsent

      int countOutgoingBatchesUnsent(String channelId)

    • countOutgoingBatchesUnsentHeartbeat

      int countOutgoingBatchesUnsentHeartbeat()

    • countOutgoingBatchesPendingByChannel

      Map<String,Integer> countOutgoingBatchesPendingByChannel(String nodeId)

    • countUnsentRowsByTargetNode

      long countUnsentRowsByTargetNode(String nodeId)

    • countUnsentBatchesByTargetNode

      int countUnsentBatchesByTargetNode(String nodeId, boolean includeHeartbeats)

    • findOutgoingBatchSummary

      List<OutgoingBatchSummary> findOutgoingBatchSummary(AbstractBatch.Status... statuses)

    • findOutgoingBatchSummaryByChannel

      List<OutgoingBatchSummary> findOutgoingBatchSummaryByChannel(AbstractBatch.Status... statuses)

    • findOutgoingBatchSummaryByNode

      List<OutgoingBatchSummary> findOutgoingBatchSummaryByNode(String nodeId, Date sinceCreateTime, AbstractBatch.Status... statuses)

    • countOutgoingBatches

      int countOutgoingBatches(List<String> nodeIds, List<String> channels, List<AbstractBatch.Status> statuses, List<Long> loads)

    • listOutgoingBatches

      List<OutgoingBatch> listOutgoingBatches(List<String> nodeIds, List<String> channels, List<AbstractBatch.Status> statuses, List<Long> loads, long startAtBatchId, Date startAtLastUpdateTime, int rowsExpected, boolean ascending)

    • listOutgoingBatchesWithLimit

      List<OutgoingBatch> listOutgoingBatchesWithLimit(int offset, int limit, List<FilterCriterion> filter, String orderColumn, String orderDirection)

    • countOutgoingBatchesWithLimit

      int countOutgoingBatchesWithLimit(List<FilterCriterion> filter)

    • copyOutgoingBatches

      void copyOutgoingBatches(String channelId, long startBatchId, String fromNodeId, String toNodeId)

    • getAllBatches

      List<Long> getAllBatches()

    • getBatchesInProgress

      List<OutgoingBatch> getBatchesInProgress()

    • getReadyQueues

      Collection<String> getReadyQueues(String nodeId, boolean refreshCache)

    • getReadyQueues

      Map<String,Collection<String>> getReadyQueues(boolean refreshCache)

    • getReadyChannelsFromDb

      Map<String,ReadyChannels> getReadyChannelsFromDb()