djb-eapim/bapweb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bapSvr11 로 서버명 변경

Browse Source
This commit is contained in:
zoomk
2025-10-28 15:03:44 +09:00
parent cf716775fd
commit c152a7cab3
5 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/com/eactive/eai/batch/scheduler/ScheduleHandlerProcess.java
+1 -1
View File
@@ -46,7 +46,7 @@ public class ScheduleHandlerProcess{
try{ try{
BatchDoc batchDoc = moveJobToProcessing(info); BatchDoc batchDoc = moveJobToProcessing(info);
String instName = System.getProperty(Keys.SERVER_KEY); String instName = System.getProperty(Keys.SERVER_KEY);
String jobQueue = instName.equals("fepBapSvr11") ? Keys.BAP01_JOB_QUEUE : Keys.BAP02_JOB_QUEUE; String jobQueue = instName.equals("bapSvr11") ? Keys.BAP01_JOB_QUEUE : Keys.BAP02_JOB_QUEUE;
JMSSender.sendToQueue(batchDoc, Keys.CONNECT_FACTORY, jobQueue); JMSSender.sendToQueue(batchDoc, Keys.CONNECT_FACTORY, jobQueue);
//JMSQueueSender sender = new JMSQueueSender(); //JMSQueueSender sender = new JMSQueueSender();
// logger.debug("[ScheduleHandlerProcess][clientRequest]batchDoc-->" + batchDoc.getBatchMsg().getHeader().getUUID()); // logger.debug("[ScheduleHandlerProcess][clientRequest]batchDoc-->" + batchDoc.getBatchMsg().getHeader().getUUID());
src/com/eactive/eai/common/routing/jms/AbstractQueueConsumer.java
+1 -1
View File
@@ -30,7 +30,7 @@ public abstract class AbstractQueueConsumer implements Runnable, ExceptionListe
try { try {
String serverName = System.getProperty(Keys.SERVER_KEY); String serverName = System.getProperty(Keys.SERVER_KEY);
if("fepBapSvr11".equals(serverName)) { if("bapSvr11".equals(serverName)) {
queue = queue.replace("21", "11"); queue = queue.replace("21", "11");
}else { }else {
queue = queue.replace("11", "21"); queue = queue.replace("11", "21");
src/com/eactive/eai/common/routing/jms/JobPolingHandlerQueueConsumerService.java
+2 -2
View File
@@ -35,7 +35,7 @@ public class JobPolingHandlerQueueConsumerService implements InitializingBean,
} }
public void setUri(String uri) { public void setUri(String uri) {
if("fepBapSvr11".equals(serverName)) { if("bapSvr11".equals(serverName)) {
uri = uri.replace("21", "11"); uri = uri.replace("21", "11");
}else { }else {
uri = uri.replace("11", "21"); uri = uri.replace("11", "21");
@@ -48,7 +48,7 @@ public class JobPolingHandlerQueueConsumerService implements InitializingBean,
} }
public void setQueue(String queue) { public void setQueue(String queue) {
if("fepBapSvr11".equals(serverName)) { if("bapSvr11".equals(serverName)) {
queue = queue.replace("21", "11"); queue = queue.replace("21", "11");
}else { }else {
queue = queue.replace("11", "21"); queue = queue.replace("11", "21");
src/com/eactive/eai/common/routing/jms/TimerEventListenerQueueConsumerService.java
+2 -2
View File
@@ -35,7 +35,7 @@ public class TimerEventListenerQueueConsumerService implements InitializingBean
} }
public void setUri(String uri) { public void setUri(String uri) {
if("fepBapSvr11".equals(serverName)) { if("bapSvr11".equals(serverName)) {
uri = uri.replace("21", "11"); uri = uri.replace("21", "11");
}else { }else {
uri = uri.replace("11", "21"); uri = uri.replace("11", "21");
@@ -48,7 +48,7 @@ public class TimerEventListenerQueueConsumerService implements InitializingBean
} }
public void setQueue(String queue) { public void setQueue(String queue) {
if("fepBapSvr11".equals(serverName)) { if("bapSvr11".equals(serverName)) {
queue = queue.replace("21", "11"); queue = queue.replace("21", "11");
}else { }else {
queue = queue.replace("11", "21"); queue = queue.replace("11", "21");
src/com/eactive/eai/common/scheduler/TimerEventJob.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class TimerEventJob implements Job {
try { try {
String instName = System.getProperty(Keys.SERVER_KEY); String instName = System.getProperty(Keys.SERVER_KEY);
String timerQueue = instName.equals("fepBapSvr11") ? Keys.BAP01_TIMER_QUEUE : Keys.BAP02_TIMER_QUEUE; String timerQueue = instName.equals("bapSvr11") ? Keys.BAP01_TIMER_QUEUE : Keys.BAP02_TIMER_QUEUE;
//sender.send(Keys.CONNECT_FACTORY, Keys.TIMER_QUEUE, msg, jobKey.getName()); //sender.send(Keys.CONNECT_FACTORY, Keys.TIMER_QUEUE, msg, jobKey.getName());
JMSSender.sendToQueue(msg, Keys.CONNECT_FACTORY, timerQueue); JMSSender.sendToQueue(msg, Keys.CONNECT_FACTORY, timerQueue);
} catch (Exception e) { } catch (Exception e) {