Package org.jumpmind.symmetric.model

Class Channel

java.lang.Object
org.jumpmind.symmetric.model.Channel
All Implemented Interfaces:
Serializable, Cloneable
public class Channel extends Object implements Serializable, Cloneable
Definition of a channel and it's priority. A channel is a group of tables that get synchronized together.
See Also:

  • Constructor Details

    • Channel

      public Channel()

    • Channel

      public Channel(String id, int processingOrder)

    • Channel

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

    • Channel

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

    • Channel

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

    • Channel

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

  • Method Details

    • getChannelId

      public String getChannelId()

    • setChannelId

      public void setChannelId(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(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(Collection<? extends NodeChannel> channels)

    • setBatchAlgorithm

      public void setBatchAlgorithm(String batchAlgorithm)

    • getBatchAlgorithm

      public 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(String dataloader)

    • getDataLoaderType

      public String getDataLoaderType()

    • getCreateTime

      public Date getCreateTime()

    • setCreateTime

      public void setCreateTime(Date createTime)

    • getLastUpdateBy

      public String getLastUpdateBy()

    • setLastUpdateBy

      public void setLastUpdateBy(String lastUpdateBy)

    • getLastUpdateTime

      public Date getLastUpdateTime()

    • setLastUpdateTime

      public void setLastUpdateTime(Date lastUpdateTime)

    • setFileSyncFlag

      public void setFileSyncFlag(boolean filesyncFlag)

    • isFileSyncFlag

      public boolean isFileSyncFlag()

    • setReloadFlag

      public void setReloadFlag(boolean reloadFlag)

    • isReloadFlag

      public boolean isReloadFlag()

    • getQueue

      public String getQueue()

    • setQueue

      public void setQueue(String queue)

    • getMaxKBytesPerSecond

      public BigDecimal getMaxKBytesPerSecond()

    • setMaxKBytesPerSecond

      public void setMaxKBytesPerSecond(BigDecimal maxKBytesPerSecond)

    • getDataEventAction

      public NodeGroupLinkAction getDataEventAction()

    • setDataEventAction

      public void setDataEventAction(NodeGroupLinkAction dataEventAction)

    • getDescription

      public String getDescription()

    • setDescription

      public void setDescription(String description)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • copy

      public Channel copy()