0001075: Turn on sym_trigger.use_capture_lobs and sym_channel.contain…

…s_big_lobs by default for sym tables and the config channel
JumpMind · Feb 25, 2013 · e830a3d · e830a3d
1 parent 153048f
commit e830a3d
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/model/Channel.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/model/Channel.java
@@ -73,12 +73,13 @@ public Channel(String id, int processingOrder) {
     }
 
     public Channel(String id, int processingOrder, int maxBatchSize, int maxBatchToSend, boolean enabled,
-            long extractPeriodMillis) {
+            long extractPeriodMillis, boolean containsBigLobs) {
         this(id, processingOrder);
         this.maxBatchSize = maxBatchSize;
         this.maxBatchToSend = maxBatchToSend;
         this.enabled = enabled;
-        this.extractPeriodMillis = extractPeriodMillis;
+        this.extractPeriodMillis = extractPeriodMillis;
+        this.containsBigLob = containsBigLobs;
     }
 
     public String getChannelId() {

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationService.java
@@ -67,10 +67,10 @@ public ConfigurationService(IParameterService parameterService, ISymmetricDialec
         super(parameterService, dialect);
         this.nodeService = nodeService;
         this.defaultChannels = new ArrayList<Channel>();
-        this.defaultChannels.add(new Channel(Constants.CHANNEL_HEARTBEAT, 2, 100, 100, true, 0));
-        this.defaultChannels.add(new Channel(Constants.CHANNEL_CONFIG, 0, 100, 100, true, 0));
-        this.defaultChannels.add(new Channel(Constants.CHANNEL_RELOAD, 1, 1, 1, true, 0));
-        this.defaultChannels.add(new Channel(Constants.CHANNEL_DEFAULT, 99999, 1000, 100, true, 0));
+        this.defaultChannels.add(new Channel(Constants.CHANNEL_HEARTBEAT, 2, 100, 100, true, 0, false));
+        this.defaultChannels.add(new Channel(Constants.CHANNEL_CONFIG, 0, 100, 100, true, 0, true));
+        this.defaultChannels.add(new Channel(Constants.CHANNEL_RELOAD, 1, 1, 1, true, 0, false));
+        this.defaultChannels.add(new Channel(Constants.CHANNEL_DEFAULT, 99999, 1000, 100, true, 0, false));
         setSqlMap(new ConfigurationServiceSqlMap(symmetricDialect.getPlatform(),
                 createSqlReplacementTokens()));
     }

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TriggerRouterService.java
@@ -364,6 +364,7 @@ protected Trigger buildTriggerForSymmetricTable(String tableName) {
             trigger.setChannelId(Constants.CHANNEL_HEARTBEAT);
         } else {
             trigger.setChannelId(Constants.CHANNEL_CONFIG);
+            trigger.setUseCaptureLobs(true);
         }
         // little trick to force the rebuild of SymmetricDS triggers every time
         // there is a new version of SymmetricDS