org.jumpmind.symmetric.model

Class OutgoingBatches

java.lang.Object

org.jumpmind.symmetric.model.OutgoingBatches

All Implemented Interfaces:

java.io.Serializable

public class OutgoingBatches
extends java.lang.Object
implements java.io.Serializable

A container for OutgoingBatchs.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OutgoingBatches()
OutgoingBatches(java.util.List<OutgoingBatch> batches)

Method Summary

Modifier and Type	Method and Description
void	addActiveChannel(NodeChannel nodeChannel)
boolean	containsBatches()
boolean	containsBatchesInError()
boolean	containsLoadBatches()
int	countBatches(boolean includeOnlyErrors)
java.util.List<OutgoingBatch>	filterBatchesForChannel(Channel channel) Removes all batches associated with the provided channel from this object.
java.util.List<OutgoingBatch>	filterBatchesForChannel(java.lang.String channelId)
java.util.List<OutgoingBatch>	filterBatchesForChannels(java.util.Set<java.lang.String> channels)
java.util.List<OutgoingBatch>	filterBatchesForInactiveChannels() Removes all batches that are not associated with an 'activeChannel'.
java.util.Set<NodeChannel>	getActiveChannels()
java.util.List<OutgoingBatch>	getBatches()
java.util.List<OutgoingBatch>	getBatchesForChannel(Channel channel)
java.util.List<OutgoingBatch>	getBatchesForChannel(java.lang.String channelId)
java.util.List<OutgoingBatch>	getBatchesForChannels(java.util.Set<java.lang.String> channelIds)
void	removeNonLoadBatches()
void	removeThreadChannelBatches(java.lang.String channelId)
void	setActiveChannels(java.util.Set<NodeChannel> activeChannels)
void	setBatches(java.util.List<OutgoingBatch> batches)
void	sortChannels(java.util.List<NodeChannel> channels)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OutgoingBatches

public OutgoingBatches(java.util.List<OutgoingBatch> batches)

OutgoingBatches

public OutgoingBatches()

Method Detail

containsBatches

public boolean containsBatches()

getActiveChannels

public java.util.Set<NodeChannel> getActiveChannels()

addActiveChannel

public void addActiveChannel(NodeChannel nodeChannel)

setActiveChannels

public void setActiveChannels(java.util.Set<NodeChannel> activeChannels)

getBatches

public java.util.List<OutgoingBatch> getBatches()

setBatches

public void setBatches(java.util.List<OutgoingBatch> batches)

filterBatchesForChannel

public java.util.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 java.util.List<OutgoingBatch> filterBatchesForChannel(java.lang.String channelId)

filterBatchesForChannels

public java.util.List<OutgoingBatch> filterBatchesForChannels(java.util.Set<java.lang.String> channels)

removeNonLoadBatches

public void removeNonLoadBatches()

removeThreadChannelBatches

public void removeThreadChannelBatches(java.lang.String channelId)

containsLoadBatches

public boolean containsLoadBatches()

containsBatchesInError

public boolean containsBatchesInError()

getBatchesForChannel

public java.util.List<OutgoingBatch> getBatchesForChannel(Channel channel)

getBatchesForChannel

public java.util.List<OutgoingBatch> getBatchesForChannel(java.lang.String channelId)

getBatchesForChannels

public java.util.List<OutgoingBatch> getBatchesForChannels(java.util.Set<java.lang.String> channelIds)

filterBatchesForInactiveChannels

public java.util.List<OutgoingBatch> filterBatchesForInactiveChannels()

Removes all batches that are not associated with an 'activeChannel'.

Returns:

List of batches that were filtered

sortChannels

public void sortChannels(java.util.List<NodeChannel> channels)