From 4e0b471b8fb53af8320ec148c00f6852fe364dd5 Mon Sep 17 00:00:00 2001
From: Yuk-Ming Lam <ymlam@gracelam.com>
Date: Tue, 9 Feb 2021 16:38:30 -0500
Subject: [PATCH] Unified getServiceThreadPoolSize and
 getPostbackSenderPoolSize.

---
 src/main/java/altk/comm/engine/Broadcast.java | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/src/main/java/altk/comm/engine/Broadcast.java b/src/main/java/altk/comm/engine/Broadcast.java
index 111af67..d080dff 100644
--- a/src/main/java/altk/comm/engine/Broadcast.java
+++ b/src/main/java/altk/comm/engine/Broadcast.java
@@ -72,7 +72,6 @@ public abstract class Broadcast
     private int completedJobCount;
     
     private ScheduledExecutorService scheduler;
-	private int serviceThreadPoolSize_default;
 	private int jobsTotal;
 	private int scheduledJobs;
 	
@@ -415,7 +414,6 @@ public abstract class Broadcast
     {
         myLogger.debug("Entering Broadcast.doPost method");
         BroadcastException myException = null;
-        serviceThreadPoolSize_default = commEngine.getServiceThreadPoolSize();
         try
         {
             boolean notInService = commEngine.notInService();
@@ -492,7 +490,7 @@ public abstract class Broadcast
             jobsTotal = recipientList.size();
             postback = new Postback(this,
             		commEngine.getPostbackMaxQueueSize(),
-            		commEngine.getPostbackSenderPoolSize(),
+            		getPostbackSenderPoolSize(),
             		commEngine.getPostbackMaxBatchSize());
             
             // Create service thread pool to dispatch jobs,
@@ -525,10 +523,9 @@ public abstract class Broadcast
         }
     }
     
-    protected int getServiceThreadPoolSize()
-    {
-    	return serviceThreadPoolSize_default;
-    }
+    protected abstract int getServiceThreadPoolSize();
+    
+    protected abstract int getPostbackSenderPoolSize();
     
     protected abstract void returnPrerequisites(ServicePrerequisites prerequisites);