diff --git a/src/main/java/com/sunyard/sge/database/SydApiBuilder.java b/src/main/java/com/sunyard/sge/database/SydApiBuilder.java index c036133..fdf4337 100644 --- a/src/main/java/com/sunyard/sge/database/SydApiBuilder.java +++ b/src/main/java/com/sunyard/sge/database/SydApiBuilder.java @@ -38,7 +38,7 @@ public class SydApiBuilder { } HsmLinkInfo[] linkInfo = HsmLinkInfo.mutiHsmLinkInfo(pcIpList, iPortList, iConnectTimeOut, iDealTimeOut); - this.pool = new SydApiPool(linkInfo); + this.pool = new SydApiPool(config, linkInfo); longLinkWorks = new CommWorker(); warmUp( pcIpList, iPortList, iConnectTimeOut, iDealTimeOut ); } diff --git a/src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java b/src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java index f1f8f27..b8e50fd 100644 --- a/src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java +++ b/src/main/java/com/sunyard/sge/database/pool/HsmLinkInfo.java @@ -14,6 +14,7 @@ public class HsmLinkInfo { private int iDealTimeOut; + public HsmLinkInfo(String pcIp, int iPort, int iConnectTimeOut, int iDealTimeOut) { this.pcIp = pcIp; this.iPort = iPort; diff --git a/src/main/java/com/sunyard/sge/database/pool/SydApiPool.java b/src/main/java/com/sunyard/sge/database/pool/SydApiPool.java index 5b57ace..1279220 100644 --- a/src/main/java/com/sunyard/sge/database/pool/SydApiPool.java +++ b/src/main/java/com/sunyard/sge/database/pool/SydApiPool.java @@ -6,6 +6,7 @@ import com.sunyard.sge.database.SydApi4Database; import com.sunyard.sge.database.SydApiBaseFunction; import com.sunyard.sge.log.LogFactory; import com.sunyard.sge.pool.ObjectInPool; +import com.sunyard.sge.pool.PoolConfig; import com.sunyard.sge.pool.ThreadBasedConnectPool; import org.apache.logging.log4j.Logger; import racal.sunyard.main.SydApi4j; @@ -16,6 +17,10 @@ public class SydApiPool extends ThreadBasedConnectPool { super(); this.linkInfos = linkInfos; } + public SydApiPool(PoolConfig config, HsmLinkInfo[] linkInfos) { + super(config); + this.linkInfos = linkInfos; + } // 继承 初始化 protected SydApi initialValue() {