org.jumpmind.symmetric.model

Class Channel

java.lang.Object

org.jumpmind.symmetric.model.Channel

All Implemented Interfaces:

java.io.Serializable

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

Definition of a channel and it's priority. A channel is a group of tables that get synchronized together.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Channel()
Channel(java.lang.String id, int processingOrder)
Channel(java.lang.String id, int processingOrder, int maxBatchSize, int maxBatchToSend, boolean enabled, long extractPeriodMillis, boolean containsBigLobs)
Channel(java.lang.String id, int processingOrder, int maxBatchSize, int maxBatchToSend, boolean enabled, long extractPeriodMillis, boolean containsBigLobs, boolean reloadFlag, boolean filesyncFlag)
Channel(java.lang.String id, int processingOrder, int maxBatchSize, int maxBatchToSend, boolean enabled, long extractPeriodMillis, boolean containsBigLobs, java.lang.String batchAlgorithm, boolean reloadFlag, boolean filesyncFlag)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
Channel	findInList(java.util.Collection<? extends NodeChannel> channels)
java.lang.String	getBatchAlgorithm()
java.lang.String	getChannelId()
java.util.Date	getCreateTime()
NodeGroupLinkAction	getDataEventAction()
java.lang.String	getDataLoaderType()
long	getExtractPeriodMillis()
java.lang.String	getLastUpdateBy()
java.util.Date	getLastUpdateTime()
int	getMaxBatchSize()
int	getMaxBatchToSend()
int	getMaxDataToRoute()
java.math.BigDecimal	getMaxKBytesPerSecond()
int	getProcessingOrder()
java.lang.String	getQueue()
int	hashCode()
boolean	isContainsBigLob()
boolean	isEnabled()
boolean	isFileSyncFlag()
boolean	isInList(java.util.Collection<? extends NodeChannel> channels) Check to see if this channel id matches one of the channels in the collection
boolean	isReloadFlag()
boolean	isUseOldDataToRoute()
boolean	isUsePkDataToRoute()
boolean	isUseRowDataToRoute()
void	setBatchAlgorithm(java.lang.String batchAlgorithm)
void	setChannelId(java.lang.String id)
void	setContainsBigLob(boolean containsBigLobs)
void	setCreateTime(java.util.Date createTime)
void	setDataEventAction(NodeGroupLinkAction dataEventAction)
void	setDataLoaderType(java.lang.String dataloader)
void	setEnabled(boolean enabled)
void	setExtractPeriodMillis(long extractPeriodMillis)
void	setFileSyncFlag(boolean filesyncFlag)
void	setLastUpdateBy(java.lang.String lastUpdateBy)
void	setLastUpdateTime(java.util.Date lastUpdateTime)
void	setMaxBatchSize(int maxNumberOfEvents)
void	setMaxBatchToSend(int maxBatchToSend)
void	setMaxDataToRoute(int maxDataToRoute)
void	setMaxKBytesPerSecond(java.math.BigDecimal maxKBytesPerSecond)
void	setProcessingOrder(int priority)
void	setQueue(java.lang.String queue)
void	setReloadFlag(boolean reloadFlag)
void	setUseOldDataToRoute(boolean useOldDataToRoute)
void	setUsePkDataToRoute(boolean usePkDataToRoute)
void	setUseRowDataToRoute(boolean useRowDataToRoute)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Channel

public Channel()

Channel

public Channel(java.lang.String id,
               int processingOrder)

Channel

public Channel(java.lang.String id,
               int processingOrder,
               int maxBatchSize,
               int maxBatchToSend,
               boolean enabled,
               long extractPeriodMillis,
               boolean containsBigLobs,
               java.lang.String batchAlgorithm,
               boolean reloadFlag,
               boolean filesyncFlag)

Channel

public Channel(java.lang.String id,
               int processingOrder,
               int maxBatchSize,
               int maxBatchToSend,
               boolean enabled,
               long extractPeriodMillis,
               boolean containsBigLobs,
               boolean reloadFlag,
               boolean filesyncFlag)

Channel

public Channel(java.lang.String id,
               int processingOrder,
               int maxBatchSize,
               int maxBatchToSend,
               boolean enabled,
               long extractPeriodMillis,
               boolean containsBigLobs)

Method Detail

getChannelId

public java.lang.String getChannelId()

setChannelId

public void setChannelId(java.lang.String id)

getProcessingOrder

public int getProcessingOrder()

setProcessingOrder

public void setProcessingOrder(int priority)

setMaxDataToRoute

public void setMaxDataToRoute(int maxDataToRoute)

getMaxDataToRoute

public int getMaxDataToRoute()

getMaxBatchSize

public int getMaxBatchSize()

setMaxBatchSize

public void setMaxBatchSize(int maxNumberOfEvents)

isEnabled

public boolean isEnabled()

setEnabled

public void setEnabled(boolean enabled)

getMaxBatchToSend

public int getMaxBatchToSend()

setMaxBatchToSend

public void setMaxBatchToSend(int maxBatchToSend)

isInList

public boolean isInList(java.util.Collection<? extends NodeChannel> channels)

Check to see if this channel id matches one of the channels in the collection

Returns:

true if a match is found

findInList

public Channel findInList(java.util.Collection<? extends NodeChannel> channels)

setBatchAlgorithm

public void setBatchAlgorithm(java.lang.String batchAlgorithm)

getBatchAlgorithm

public java.lang.String getBatchAlgorithm()

getExtractPeriodMillis

public long getExtractPeriodMillis()

setExtractPeriodMillis

public void setExtractPeriodMillis(long extractPeriodMillis)

setUseOldDataToRoute

public void setUseOldDataToRoute(boolean useOldDataToRoute)

isUseOldDataToRoute

public boolean isUseOldDataToRoute()

setUseRowDataToRoute

public void setUseRowDataToRoute(boolean useRowDataToRoute)

isUseRowDataToRoute

public boolean isUseRowDataToRoute()

setUsePkDataToRoute

public void setUsePkDataToRoute(boolean usePkDataToRoute)

isUsePkDataToRoute

public boolean isUsePkDataToRoute()

setContainsBigLob

public void setContainsBigLob(boolean containsBigLobs)

isContainsBigLob

public boolean isContainsBigLob()

setDataLoaderType

public void setDataLoaderType(java.lang.String dataloader)

getDataLoaderType

public java.lang.String getDataLoaderType()

getCreateTime

public java.util.Date getCreateTime()

setCreateTime

public void setCreateTime(java.util.Date createTime)

getLastUpdateBy

public java.lang.String getLastUpdateBy()

setLastUpdateBy

public void setLastUpdateBy(java.lang.String lastUpdateBy)

getLastUpdateTime

public java.util.Date getLastUpdateTime()

setLastUpdateTime

public void setLastUpdateTime(java.util.Date lastUpdateTime)

setFileSyncFlag

public void setFileSyncFlag(boolean filesyncFlag)

isFileSyncFlag

public boolean isFileSyncFlag()

setReloadFlag

public void setReloadFlag(boolean reloadFlag)

isReloadFlag

public boolean isReloadFlag()

getQueue

public java.lang.String getQueue()

setQueue

public void setQueue(java.lang.String queue)

getMaxKBytesPerSecond

public java.math.BigDecimal getMaxKBytesPerSecond()

setMaxKBytesPerSecond

public void setMaxKBytesPerSecond(java.math.BigDecimal maxKBytesPerSecond)

getDataEventAction

public NodeGroupLinkAction getDataEventAction()

setDataEventAction

public void setDataEventAction(NodeGroupLinkAction dataEventAction)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object