diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfo.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfo.java
index f93b863e73..e8a000cd07 100644
--- a/symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfo.java
+++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/model/ProcessInfo.java
@@ -202,10 +202,14 @@ public long getCurrentLoadId() {
         return currentLoadId;
     }
 
-    public String getCurrentChannelId() {
+    public String getCurrentChannelThread() {
     	if (getKey().getChannelId() != null && getKey().getChannelId().length() > 0) {
     		return getKey().getChannelId();
     	}
+        return "";
+    }
+    
+    public String getCurrentChannelId() {
         return currentChannelId;
     }