Package org.jumpmind.symmetric.model

Class OutgoingBatches

java.lang.Object
org.jumpmind.symmetric.model.OutgoingBatches
All Implemented Interfaces:
Serializable
public class OutgoingBatches extends Object implements Serializable
A container for OutgoingBatchs.
See Also:

  • Constructor Details

    • OutgoingBatches

      public OutgoingBatches(List<OutgoingBatch> batches)

    • OutgoingBatches

      public OutgoingBatches()

  • Method Details

    • containsBatches

      public boolean containsBatches()

    • getActiveChannels

      public Set<NodeChannel> getActiveChannels()

    • addActiveChannel

      public void addActiveChannel(NodeChannel nodeChannel)

    • setActiveChannels

      public void setActiveChannels(Set<NodeChannel> activeChannels)

    • getBatches

      public List<OutgoingBatch> getBatches()

    • setBatches

      public void setBatches(List<OutgoingBatch> batches)

    • filterBatchesForChannel

      public List<OutgoingBatch> filterBatchesForChannel(Channel channel)
      Removes all batches associated with the provided channel from this object.
      Parameters:
      channel - - channel for which corresponding batches are removed
      Returns:
      A list of the batches removed

    • countBatches

      public int countBatches(boolean includeOnlyErrors)

    • filterBatchesForChannel

      public List<OutgoingBatch> filterBatchesForChannel(String channelId)

    • filterBatchesForChannels

      public List<OutgoingBatch> filterBatchesForChannels(Set<String> channels)

    • removeNonLoadBatches

      public void removeNonLoadBatches()

    • removeThreadChannelBatches

      public void removeThreadChannelBatches(String channelId)

    • containsLoadBatches

      public boolean containsLoadBatches()

    • containsBatchesInError

      public boolean containsBatchesInError()

    • getBatchesForChannel

      public List<OutgoingBatch> getBatchesForChannel(Channel channel)

    • getBatchesForChannel

      public List<OutgoingBatch> getBatchesForChannel(String channelId)

    • getBatchesForChannels

      public List<OutgoingBatch> getBatchesForChannels(Set<String> channelIds)

    • filterBatchesForInactiveChannels

      public List<OutgoingBatch> filterBatchesForInactiveChannels()
      Removes all batches that are not associated with an 'activeChannel'.
      Returns:
      List of batches that were filtered

    • sortChannels

      public void sortChannels(List<NodeChannel> channels)