public class OutgoingBatches
extends java.lang.Object
implements java.io.Serializable
OutgoingBatchs.| Constructor and Description |
|---|
OutgoingBatches() |
OutgoingBatches(java.util.List<OutgoingBatch> batches) |
| 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) |
public OutgoingBatches(java.util.List<OutgoingBatch> batches)
public OutgoingBatches()
public boolean containsBatches()
public java.util.Set<NodeChannel> getActiveChannels()
public void addActiveChannel(NodeChannel nodeChannel)
public void setActiveChannels(java.util.Set<NodeChannel> activeChannels)
public java.util.List<OutgoingBatch> getBatches()
public void setBatches(java.util.List<OutgoingBatch> batches)
public java.util.List<OutgoingBatch> filterBatchesForChannel(Channel channel)
channel - - channel for which corresponding batches are removedpublic int countBatches(boolean includeOnlyErrors)
public java.util.List<OutgoingBatch> filterBatchesForChannel(java.lang.String channelId)
public java.util.List<OutgoingBatch> filterBatchesForChannels(java.util.Set<java.lang.String> channels)
public void removeNonLoadBatches()
public void removeThreadChannelBatches(java.lang.String channelId)
public boolean containsLoadBatches()
public boolean containsBatchesInError()
public java.util.List<OutgoingBatch> getBatchesForChannel(Channel channel)
public java.util.List<OutgoingBatch> getBatchesForChannel(java.lang.String channelId)
public java.util.List<OutgoingBatch> getBatchesForChannels(java.util.Set<java.lang.String> channelIds)
public java.util.List<OutgoingBatch> filterBatchesForInactiveChannels()
public void sortChannels(java.util.List<NodeChannel> channels)