changed the name of a parameter to make more sense

JumpMind · Apr 11, 2011 · 834df17 · 834df17
1 parent fe19d8d
commit 834df17
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java
@@ -98,7 +98,7 @@ private ParameterConstants() {
     public final static String ROUTING_FLUSH_JDBC_BATCH_SIZE = "routing.flush.jdbc.batch.size";
     public final static String ROUTING_PEEK_AHEAD_WINDOW = "routing.peek.ahead.window.after.max.size";
     public final static String ROUTING_STALE_DATA_ID_GAP_TIME = "routing.stale.dataid.gap.time.ms";
-    public final static String ROUTING_MAX_DATA_TO_PROCESS_PER_CHANNEL = "routing.max.data.to.process.per.channel";
+    public final static String ROUTING_LARGEST_GAP_SIZE = "routing.largest.gap.size";
     public final static String ROUTING_DATA_READER_TYPE = "routing.data.reader.type";
     public final static String ROUTING_DATA_READER_TYPE_GAP_RETENTION_MINUTES = "routing.data.reader.type.gap.retention.period.minutes";
 

diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapDetector.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapDetector.java
@@ -79,7 +79,7 @@ public void beforeRouting() {
         final int dataIdIncrementBy = parameterService
                 .getInt(ParameterConstants.DATA_ID_INCREMENT_BY);
         final long maxDataToSelect = parameterService
-                .getInt(ParameterConstants.ROUTING_MAX_DATA_TO_PROCESS_PER_CHANNEL);
+                .getInt(ParameterConstants.ROUTING_LARGEST_GAP_SIZE);
         for (final DataGap dataGap : gaps) {
             final boolean lastGap = dataGap.equals(gaps.get(gaps.size()-1));            
             String sql = sqlProvider.getSql("selectDistinctDataIdFromDataEventUsingGapsSql");

diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataService.java
@@ -553,7 +553,7 @@ public DataGap mapRow(ResultSet rs, int rowNum) throws SQLException {
     public List<DataGap> findDataGaps() {
         List<DataGap> gaps = findDataGapsByStatus(DataGap.Status.GP);
         if (gaps.size() == 0) {            
-            final long maxDataToSelect = parameterService.getInt(ParameterConstants.ROUTING_MAX_DATA_TO_PROCESS_PER_CHANNEL);
+            final long maxDataToSelect = parameterService.getInt(ParameterConstants.ROUTING_LARGEST_GAP_SIZE);
             long maxDataId = findMaxDataEventDataId();
             if (maxDataId > 0) {
                 maxDataId++;

diff --git a/symmetric/symmetric-core/src/main/resources/symmetric-default.properties b/symmetric/symmetric-core/src/main/resources/symmetric-default.properties
@@ -568,7 +568,7 @@ routing.data.reader.type.gap.retention.period.minutes=1440
 # exceeds the number rows that will be in a transaction.
 #
 # Tags: routing 
-routing.max.data.to.process.per.channel=50000000
+routing.largest.gap.size=50000000
 
 # This is the number of datae vents that will be batched and committed together while building a batch.
 # Note that this only kicks in if the prospective batch size is bigger than the configured max batch size.