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

system_out_제거

Browse Source
This commit is contained in:
cho
2026-03-03 14:09:55 +09:00
parent dfcec99576
commit 8b72299689
42 changed files with 173 additions and 172 deletions
Download Patch File Download Diff File Expand all files Collapse all files
settings.gradle
+3 -1
View File
@@ -3,7 +3,9 @@ rootProject.name = 'elink-online-common'
include 'elink-online-core-jpa' include 'elink-online-core-jpa'
include 'elink-online-core' include 'elink-online-core'
include 'elink-online-transformer' include 'elink-online-transformer'
include 'elink-online-alarm'
project (':elink-online-core-jpa').projectDir = new File(settingsDir, "../elink-online-core-jpa") project (':elink-online-core-jpa').projectDir = new File(settingsDir, "../elink-online-core-jpa")
project (':elink-online-core').projectDir = new File(settingsDir, "../elink-online-core") project (':elink-online-core').projectDir = new File(settingsDir, "../elink-online-core")
project (':elink-online-transformer').projectDir = new File(settingsDir, "../elink-online-transformer") project (':elink-online-transformer').projectDir = new File(settingsDir, "../elink-online-transformer")
project (':elink-online-alarm').projectDir = new File(settingsDir, "../elink-online-alarm")
src/main/java/com/eactive/eai/adapter/db/sql/AdapterUtils.java
+2 -2
View File
@@ -14,8 +14,8 @@ public class AdapterUtils {
map.put("Unid", "ID00000001"); map.put("Unid", "ID00000001");
String prefix = "%", surfix = "%"; String prefix = "%", surfix = "%";
System.out.println(updateSql); // System.out.println(updateSql);
System.out.println(getUpdateQuery(updateSql, map, prefix, surfix)); // System.out.println(getUpdateQuery(updateSql, map, prefix, surfix));
} }
public static Properties getAdapterProerties(String propGroupName) { public static Properties getAdapterProerties(String propGroupName) {
src/main/java/com/eactive/eai/adapter/db/sql/DBInboudSqlAdapter.java
+1 -1
View File
@@ -56,7 +56,7 @@ public class DBInboudSqlAdapter {
if(isLocal != null && "true".equalsIgnoreCase(isLocal)) { if(isLocal != null && "true".equalsIgnoreCase(isLocal)) {
isLocalTest = true; isLocalTest = true;
} }
System.out.println("$$$ DBInboudSqlAdapter] isLocalTest = " + isLocalTest); // System.out.println("$$$ DBInboudSqlAdapter] isLocalTest = " + isLocalTest);
} }
public boolean execute() { public boolean execute() {
src/main/java/com/eactive/eai/adapter/http/client/impl/HttpClient5AdapterServiceRest.java
+2 -2
View File
@@ -1122,10 +1122,10 @@ public class HttpClient5AdapterServiceRest extends HttpClient5AdapterServiceSupp
ECDHESA256Cipher cipher = new ECDHESA256Cipher(); ECDHESA256Cipher cipher = new ECDHESA256Cipher();
encryptedMessage = cipher.encrypt(eaiBody.toString()); encryptedMessage = cipher.encrypt(eaiBody.toString());
System.out.println("Encrypted JWE: " + encryptedMessage); // System.out.println("Encrypted JWE: " + encryptedMessage);
String decrypted = cipher.decrypt(encryptedMessage); String decrypted = cipher.decrypt(encryptedMessage);
System.out.println("Decrypted Payload: " + decrypted); // System.out.println("Decrypted Payload: " + decrypted);
//아래 인증서로 테스트 //아래 인증서로 테스트
ECDHESA256Cipher cipherCert = new ECDHESA256Cipher(certPath); ECDHESA256Cipher cipherCert = new ECDHESA256Cipher(certPath);
src/main/java/com/eactive/eai/adapter/http/dynamic/impl/HttpAdapterServiceBypass.java
+1 -1
View File
@@ -504,6 +504,6 @@ public class HttpAdapterServiceBypass extends HttpAdapterServiceSupport {
String orgUri = "/HTT/CbsInNetSys/abcd/123456"; String orgUri = "/HTT/CbsInNetSys/abcd/123456";
String result = ""; String result = "";
result = getExtUri(orgUri, 3); result = getExtUri(orgUri, 3);
System.out.println(result); // System.out.println(result);
} }
} }
src/main/java/com/eactive/eai/adapter/http/dynamic/wrapper/KeepAliveTrueWrapper.java
+1 -1
View File
@@ -54,7 +54,7 @@ public class KeepAliveTrueWrapper implements HandlerWrapper {
// 최대 요청 횟수를 초과한 경우 연결을 종료하고 로그를 출력 // 최대 요청 횟수를 초과한 경우 연결을 종료하고 로그를 출력
if (count > maxRequestCount) { if (count > maxRequestCount) {
exchange.getConnection().close(); exchange.getConnection().close();
System.out.println("Connection closed due to exceeding max requests limit."); // System.out.println("Connection closed due to exceeding max requests limit.");
return; return;
} }
handler.handleRequest(exchange); handler.handleRequest(exchange);
src/main/java/com/eactive/eai/adapter/jtc/JtcBeanSample.java
+5 -5
View File
@@ -45,7 +45,7 @@ public class JtcBeanSample implements JtmaxService {
String bufferType = tux.getBufferTypeString(); String bufferType = tux.getBufferTypeString();
if ("STRING".equals(bufferType)) { if ("STRING".equals(bufferType)) {
TuxStringBuffer tuxbuf = (TuxStringBuffer) tux; TuxStringBuffer tuxbuf = (TuxStringBuffer) tux;
System.out.println("received string value : " + tuxbuf.getString()); // System.out.println("received string value : " + tuxbuf.getString());
TuxStringBuffer ret = new TuxStringBuffer(WebtSystem.getDefaultCharset()); TuxStringBuffer ret = new TuxStringBuffer(WebtSystem.getDefaultCharset());
ret.setString(tuxbuf.getString().toUpperCase()); ret.setString(tuxbuf.getString().toUpperCase());
return ret; return ret;
@@ -60,8 +60,8 @@ public class JtcBeanSample implements JtmaxService {
} }
String rtnstr = rcvstr.toUpperCase(); String rtnstr = rcvstr.toUpperCase();
System.out.println("received string value : " + rcvstr); // System.out.println("received string value : " + rcvstr);
System.out.println("return string value : " + rtnstr); // System.out.println("return string value : " + rtnstr);
TuxCarrayBuffer ret = new TuxCarrayBuffer(WebtSystem.getDefaultCharset()); TuxCarrayBuffer ret = new TuxCarrayBuffer(WebtSystem.getDefaultCharset());
ret.setBytes(rtnstr.getBytes());; ret.setBytes(rtnstr.getBytes());;
return ret; return ret;
@@ -73,8 +73,8 @@ public class JtcBeanSample implements JtmaxService {
String rcvstr = tuxbuf.getField("SEC100").get().stringValue(); String rcvstr = tuxbuf.getField("SEC100").get().stringValue();
String rtnstr = rcvstr.toUpperCase(); String rtnstr = rcvstr.toUpperCase();
System.out.println("received string value : " + rcvstr); // System.out.println("received string value : " + rcvstr);
System.out.println("return string value : " + rtnstr); // System.out.println("return string value : " + rtnstr);
TuxFieldBuffer ret = new TuxFieldBuffer(false); // FML 16임으로 false로 TuxFieldBuffer ret = new TuxFieldBuffer(false); // FML 16임으로 false로
// ret.createField(sample.fml_sec2).add(rtnstr); // ret.createField(sample.fml_sec2).add(rtnstr);
ret.createField("SEC2").add(rtnstr); ret.createField("SEC2").add(rtnstr);
src/main/java/com/eactive/eai/adapter/jtc/JtcClientSample.java
+3 -3
View File
@@ -73,7 +73,7 @@ public class JtcClientSample {
try { try {
// if(cd == null) { // if(cd == null) {
System.out.println("tpconnect failed!"); // System.out.println("tpconnect failed!");
// } // }
// else { // else {
@@ -84,12 +84,12 @@ public class JtcClientSample {
sndbuf.setString("conversation service"); sndbuf.setString("conversation service");
TuxBuffer rcvbuf = service.tpcall(sndbuf); TuxBuffer rcvbuf = service.tpcall(sndbuf);
System.out.println(rcvbuf.getString()); // System.out.println(rcvbuf.getString());
// } // }
} }
catch (WebtException e) { catch (WebtException e) {
e.printStackTrace(); e.printStackTrace();
System.out.println("error Occurred"); // System.out.println("error Occurred");
} }
finally { finally {
src/main/java/com/eactive/eai/adapter/jtc/JtcServerAdapterBean.java
+1 -1
View File
@@ -58,7 +58,7 @@ public class JtcServerAdapterBean implements JtmaxService {
try { try {
if ("STRING".equals(bufferType)) { if ("STRING".equals(bufferType)) {
TuxStringBuffer tuxbuf = (TuxStringBuffer) tux; TuxStringBuffer tuxbuf = (TuxStringBuffer) tux;
System.out.println("received string value : " + tuxbuf.getString()); // System.out.println("received string value : " + tuxbuf.getString());
byte[] request = tuxbuf.getString().getBytes(); byte[] request = tuxbuf.getString().getBytes();
RequestDispatcher dispatcher = RequestDispatcher.getRequestDispatcher(adapterGroupName); RequestDispatcher dispatcher = RequestDispatcher.getRequestDispatcher(adapterGroupName);
byte[] response = (byte[]) dispatcher.handle(adapterName, request, prop); byte[] response = (byte[]) dispatcher.handle(adapterName, request, prop);
src/main/java/com/eactive/eai/adapter/jtc/TestMsgListener.java
+2 -3
View File
@@ -31,12 +31,11 @@ public class TestMsgListener implements TuxAsyncMsgListener {
} }
public void handleError(Exception e) { public void handleError(Exception e) {
System.out.println(e); // System.out.println(e);
} }
public void handleEvent(TuxBuffer rcvBuffer) { public void handleEvent(TuxBuffer rcvBuffer) {
System.out.println(Thread.currentThread().getName() // System.out.println(Thread.currentThread().getName()+" ] rcv " + rcvBuffer);
+" ] rcv " + rcvBuffer);
try { try {
// TODO : Call Internal service // TODO : Call Internal service
} }
src/main/java/com/eactive/eai/adapter/socket2/app/dump/DumpServer.java
+3 -3
View File
@@ -9,7 +9,7 @@ import com.eactive.eai.adapter.socket2.protocol.ISocketAdapter;
public class DumpServer { public class DumpServer {
static public void main(String[] args) throws Exception { static public void main(String[] args) throws Exception {
if (args.length != 1) { if (args.length != 1) {
System.out.println("Usage : dump <port>"); // System.out.println("Usage : dump <port>");
return; return;
} }
int port = Integer.parseInt(args[0]); int port = Integer.parseInt(args[0]);
@@ -53,12 +53,12 @@ public class DumpServer {
System.out.print("> "); System.out.print("> ");
String cmd = (new java.io.BufferedReader(new java.io.InputStreamReader(System.in))).readLine(); String cmd = (new java.io.BufferedReader(new java.io.InputStreamReader(System.in))).readLine();
if ("".equals(cmd)) { if ("".equals(cmd)) {
System.out.println(SocketAdapterManager.getInstance()); // System.out.println(SocketAdapterManager.getInstance());
} else if ("exit".equals(cmd)) { } else if ("exit".equals(cmd)) {
System.exit(1); System.exit(1);
} }
} catch(Exception e) { } catch(Exception e) {
System.out.println(e.toString()); // System.out.println(e.toString());
} }
} }
} }
src/main/java/com/eactive/eai/adapter/socket2/app/echo/EchoServer.java
+2 -2
View File
@@ -46,12 +46,12 @@ public class EchoServer {
System.out.print("> "); System.out.print("> ");
String cmd = (new java.io.BufferedReader(new java.io.InputStreamReader(System.in))).readLine(); String cmd = (new java.io.BufferedReader(new java.io.InputStreamReader(System.in))).readLine();
if ("".equals(cmd)) { if ("".equals(cmd)) {
System.out.println(SocketAdapterManager.getInstance()); // System.out.println(SocketAdapterManager.getInstance());
} else if ("exit".equals(cmd)) { } else if ("exit".equals(cmd)) {
System.exit(1); System.exit(1);
} }
} catch(Exception e) { } catch(Exception e) {
System.out.println("processCommand errpr "+ e.toString()); // System.out.println("processCommand errpr "+ e.toString());
} }
} }
} }
src/main/java/com/eactive/eai/adapter/socket2/app/muxer/Muxer.java
+7 -7
View File
@@ -49,15 +49,15 @@ public class Muxer {
} }
public synchronized byte[] handle(byte[] message) { public synchronized byte[] handle(byte[] message) {
System.out.println("##############################################################"); // System.out.println("##############################################################");
System.out.println("CiscoListener | message received : " + new String(message)); // System.out.println("CiscoListener | message received : " + new String(message));
System.out.println("##############################################################"); // System.out.println("##############################################################");
return message; return message;
} }
static public void main(String[] args) throws Exception { static public void main(String[] args) throws Exception {
if (args.length != 3) { if (args.length != 3) {
System.out.println("java " + Muxer.class.getName() + " <inbound-port> <outbound-hostname> <outbound-port>"); // System.out.println("java " + Muxer.class.getName() + " <inbound-port> <outbound-hostname> <outbound-port>");
return; return;
} }
@@ -77,9 +77,9 @@ class MuxerRequestProcessor implements IRequestProcessor {
} }
public synchronized byte[] handle(byte[] message) throws EAIException { public synchronized byte[] handle(byte[] message) throws EAIException {
System.out.println("##############################################################"); // System.out.println("##############################################################");
System.out.println("MuxerRequestProcessor | message received : " + new String(message)); // System.out.println("MuxerRequestProcessor | message received : " + new String(message));
System.out.println("##############################################################"); // System.out.println("##############################################################");
return (byte[]) outboundAdapter.sendMessage(message); return (byte[]) outboundAdapter.sendMessage(message);
} }
src/main/java/com/eactive/eai/adapter/socket2/app/proxy/ProxyServer.java
+1 -1
View File
@@ -34,7 +34,7 @@ public class ProxyServer {
static public void main(String[] args) throws Exception { static public void main(String[] args) throws Exception {
if (args.length != 3) { if (args.length != 3) {
System.out.println("java " + ProxyServer.class.getName() + " <proxy-port> <remote-hostname> <remote-port>"); // System.out.println("java " + ProxyServer.class.getName() + " <proxy-port> <remote-hostname> <remote-port>");
return; return;
} }
src/main/java/com/eactive/eai/adapter/socket2/app/tester/LoadRunner.java
+28 -28
View File
@@ -188,9 +188,9 @@ public class LoadRunner {
} }
stopLatch.countDown(); stopLatch.countDown();
} catch (Exception e) { } catch (Exception e) {
System.out.println(e.toString()); // System.out.println(e.toString());
} catch (Error e) { } catch (Error e) {
System.out.println(e.toString()); // System.out.println(e.toString());
} }
} }
}); });
@@ -202,7 +202,7 @@ public class LoadRunner {
stopLatch.await(); stopLatch.await();
} catch (InterruptedException ex) { } catch (InterruptedException ex) {
//ex.printStackTrace(); //ex.printStackTrace();
System.out.println("wait error"); // System.out.println("wait error");
} }
executor.shutdown(); executor.shutdown();
@@ -211,27 +211,27 @@ public class LoadRunner {
boolean result = executor.awaitTermination(1000, TimeUnit.MILLISECONDS); boolean result = executor.awaitTermination(1000, TimeUnit.MILLISECONDS);
if (result) if (result)
break; break;
System.out.println("[LoadRunner] shutdown() progressing ... await 1 seconds more"); // System.out.println("[LoadRunner] shutdown() progressing ... await 1 seconds more");
} catch (InterruptedException e) { } catch (InterruptedException e) {
//e.printStackTrace(); //e.printStackTrace();
System.out.println("awaitTermination error"); // System.out.println("awaitTermination error");
} }
} }
latch.await(); latch.await();
stopWatch.stop(); stopWatch.stop();
System.out.println(); // System.out.println();
System.out.println(); // System.out.println();
System.out.println("==============================================================="); // System.out.println("===============================================================");
System.out.println(" think time : " + thinkTime + " ms"); // System.out.println(" think time : " + thinkTime + " ms");
System.out.println(" thread count : " + threadCount); // System.out.println(" thread count : " + threadCount);
System.out.println(" loop count : " + loopCount); // System.out.println(" loop count : " + loopCount);
System.out.println(" total request : " + (threadCount * loopCount)); // System.out.println(" total request : " + (threadCount * loopCount));
System.out.println(" elapsed : " + stopWatch.toString()); // System.out.println(" elapsed : " + stopWatch.toString());
System.out.println(" tps : " + new Integer(threadCount * loopCount * 1000).longValue() / stopWatch.getTime()); // System.out.println(" tps : " + new Integer(threadCount * loopCount * 1000).longValue() / stopWatch.getTime());
System.out.println("==============================================================="); // System.out.println("===============================================================");
System.out.println(); // System.out.println();
} }
@@ -245,13 +245,13 @@ public class LoadRunner {
break; break;
} else if ("".equals(line.trim())) { } else if ("".equals(line.trim())) {
} else if ("help".equals(line.trim())) { } else if ("help".equals(line.trim())) {
System.out.println("==============================================================="); // System.out.println("===============================================================");
System.out.println("LoadRunner v1.0 (http port = 8282)"); // System.out.println("LoadRunner v1.0 (http port = 8282)");
System.out.println("==============================================================="); // System.out.println("===============================================================");
System.out.println(" help : help"); // System.out.println(" help : help");
System.out.println(" start : start [thread count] [loop count] [think time]"); // System.out.println(" start : start [thread count] [loop count] [think time]");
System.out.println(" exit : exit"); // System.out.println(" exit : exit");
System.out.println(""); // System.out.println("");
} else if (line.trim().startsWith("start")) { } else if (line.trim().startsWith("start")) {
String[] tokens = line.trim().split("[ ]+"); String[] tokens = line.trim().split("[ ]+");
if (tokens.length > 1) if (tokens.length > 1)
@@ -264,10 +264,10 @@ public class LoadRunner {
} else if ("exit".equals(line.trim())) { } else if ("exit".equals(line.trim())) {
System.exit(1); System.exit(1);
} else { } else {
System.out.println("Unknow command. type help."); // System.out.println("Unknow command. type help.");
} }
} catch(Exception e) { } catch(Exception e) {
System.out.println("Error " + e.toString()); // System.out.println("Error " + e.toString());
} }
} }
} }
@@ -298,7 +298,7 @@ public class LoadRunner {
if(br != null) br.close(); if(br != null) br.close();
} }
catch(Exception ee) { catch(Exception ee) {
System.out.println("close error"); // System.out.println("close error");
} }
} }
@@ -369,10 +369,10 @@ public class LoadRunner {
if (args.length == 2) { if (args.length == 2) {
hostname = args[0]; hostname = args[0];
System.out.println("remote host : " + hostname); // System.out.println("remote host : " + hostname);
filename = args[1]; filename = args[1];
} else { } else {
System.out.println("Usage : loadrunner [ip] [file]"); // System.out.println("Usage : loadrunner [ip] [file]");
return; return;
} }
src/main/java/com/eactive/eai/adapter/socket2/app/tester/LoadRunner2.java
+29 -29
View File
@@ -189,10 +189,10 @@ public class LoadRunner2 {
stopLatch.countDown(); stopLatch.countDown();
} catch (Exception e) { } catch (Exception e) {
// e.printStackTrace(); // e.printStackTrace();
System.out.println("executor.execute Exception"); // System.out.println("executor.execute Exception");
} catch (Error e) { } catch (Error e) {
// e.printStackTrace(); // e.printStackTrace();
System.out.println("executor.execute error"); // System.out.println("executor.execute error");
} }
} }
}); });
@@ -204,7 +204,7 @@ public class LoadRunner2 {
stopLatch.await(); stopLatch.await();
} catch (InterruptedException ex) { } catch (InterruptedException ex) {
// ex.printStackTrace(); // ex.printStackTrace();
System.out.println("InterruptedException"); // System.out.println("InterruptedException");
} }
executor.shutdown(); executor.shutdown();
@@ -213,27 +213,27 @@ public class LoadRunner2 {
boolean result = executor.awaitTermination(1000, TimeUnit.MILLISECONDS); boolean result = executor.awaitTermination(1000, TimeUnit.MILLISECONDS);
if (result) if (result)
break; break;
System.out.println("[LoadRunner] shutdown() progressing ... await 1 seconds more"); // System.out.println("[LoadRunner] shutdown() progressing ... await 1 seconds more");
} catch (InterruptedException e) { } catch (InterruptedException e) {
// e.printStackTrace(); // e.printStackTrace();
System.out.println("[LoadRunner] shutdown() progressing ...InterruptedException"); // System.out.println("[LoadRunner] shutdown() progressing ...InterruptedException");
} }
} }
latch.await(); latch.await();
stopWatch.stop(); stopWatch.stop();
System.out.println(); // System.out.println();
System.out.println(); // System.out.println();
System.out.println("==============================================================="); // System.out.println("===============================================================");
System.out.println(" think time : " + thinkTime + " ms"); // System.out.println(" think time : " + thinkTime + " ms");
System.out.println(" thread count : " + threadCount); // System.out.println(" thread count : " + threadCount);
System.out.println(" loop count : " + loopCount); // System.out.println(" loop count : " + loopCount);
System.out.println(" total request : " + (threadCount * loopCount)); // System.out.println(" total request : " + (threadCount * loopCount));
System.out.println(" elapsed : " + stopWatch.toString()); // System.out.println(" elapsed : " + stopWatch.toString());
System.out.println(" tps : " + new Integer(threadCount * loopCount * 1000).longValue() / stopWatch.getTime()); // System.out.println(" tps : " + new Integer(threadCount * loopCount * 1000).longValue() / stopWatch.getTime());
System.out.println("==============================================================="); // System.out.println("===============================================================");
System.out.println(); // System.out.println();
} }
@@ -247,13 +247,13 @@ public class LoadRunner2 {
break; break;
} else if ("".equals(line.trim())) { } else if ("".equals(line.trim())) {
} else if ("help".equals(line.trim())) { } else if ("help".equals(line.trim())) {
System.out.println("==============================================================="); // System.out.println("===============================================================");
System.out.println("LoadRunner v1.0 (http port = 8282)"); // System.out.println("LoadRunner v1.0 (http port = 8282)");
System.out.println("==============================================================="); // System.out.println("===============================================================");
System.out.println(" help : help"); // System.out.println(" help : help");
System.out.println(" start : start [thread count] [loop count] [think time]"); // System.out.println(" start : start [thread count] [loop count] [think time]");
System.out.println(" exit : exit"); // System.out.println(" exit : exit");
System.out.println(""); // System.out.println("");
} else if (line.trim().startsWith("start")) { } else if (line.trim().startsWith("start")) {
String[] tokens = line.trim().split("[ ]+"); String[] tokens = line.trim().split("[ ]+");
if (tokens.length > 1) if (tokens.length > 1)
@@ -266,11 +266,11 @@ public class LoadRunner2 {
} else if ("exit".equals(line.trim())) { } else if ("exit".equals(line.trim())) {
System.exit(1); System.exit(1);
} else { } else {
System.out.println("Unknow command. type help."); // System.out.println("Unknow command. type help.");
} }
} catch(Exception e) { } catch(Exception e) {
// e.printStackTrace(); // e.printStackTrace();
System.out.println("Exception"); // System.out.println("Exception");
} }
} }
} }
@@ -293,14 +293,14 @@ public class LoadRunner2 {
} }
} }
catch(Exception e) { catch(Exception e) {
System.out.println(e.toString()); // System.out.println(e.toString());
} }
finally { finally {
try { try {
br.close(); br.close();
} }
catch(Exception e) { catch(Exception e) {
System.out.println(e.toString()); // System.out.println(e.toString());
} }
} }
@@ -371,10 +371,10 @@ public class LoadRunner2 {
if (args.length == 2) { if (args.length == 2) {
hostname = args[0]; hostname = args[0];
System.out.println("remote host : " + hostname); // System.out.println("remote host : " + hostname);
filename = args[1]; filename = args[1];
} else { } else {
System.out.println("Usage : loadrunner [ip] [file]"); // System.out.println("Usage : loadrunner [ip] [file]");
return; return;
} }
src/main/java/com/eactive/eai/adapter/socket2/common/ExpiringMap.java
+5 -5
View File
@@ -623,14 +623,14 @@ public class ExpiringMap<K, V> implements Map<K, V> {
ExpiringMap m = new ExpiringMap(1); ExpiringMap m = new ExpiringMap(1);
String key ="aaaaaaa"; String key ="aaaaaaa";
m.put(key,key); m.put(key,key);
System.out.println(m.get(key)); // System.out.println(m.get(key));
Thread.sleep(1 * 1000L); Thread.sleep(1 * 1000L);
System.out.println(m.get(key)); // System.out.println(m.get(key));
Thread.sleep(1 * 1000L); Thread.sleep(1 * 1000L);
System.out.println(m.get(key)); // System.out.println(m.get(key));
Thread.sleep(1 * 1000L); Thread.sleep(1 * 1000L);
System.out.println(m.get(key)); // System.out.println(m.get(key));
Thread.sleep(1 * 1000L); Thread.sleep(1 * 1000L);
System.out.println(m.get(key)); // System.out.println(m.get(key));
} }
} }
src/main/java/com/eactive/eai/adapter/socket2/protocol/admin/TelnetAdminHandler.java
+1 -1
View File
@@ -18,7 +18,7 @@ public class TelnetAdminHandler extends ProtocolHandler {
@Override @Override
public void messageReceived(IoSession session, Object message) throws Exception { public void messageReceived(IoSession session, Object message) throws Exception {
String msg = message.toString().trim(); String msg = message.toString().trim();
System.out.println("<RECV> " + msg); // System.out.println("<RECV> " + msg);
if ("quit".equals(msg) || "exit".equals(msg)) { if ("quit".equals(msg) || "exit".equals(msg)) {
session.write("bye......"); session.write("bye......");
src/main/java/com/eactive/eai/adapter/socket2/protocol/http/Server.java
+2 -2
View File
@@ -42,10 +42,10 @@ public class Server {
acceptor acceptor
.bind(new InetSocketAddress(port), new ServerHandler(), cfg); .bind(new InetSocketAddress(port), new ServerHandler(), cfg);
System.out.println("Server now listening on port " + port); // System.out.println("Server now listening on port " + port);
} catch (Exception ex) { } catch (Exception ex) {
// ex.printStackTrace(); // ex.printStackTrace();
System.out.println("Error" + ex.toString()); // System.out.println("Error" + ex.toString());
} }
} }
} }
src/main/java/com/eactive/eai/adapter/socket2/protocol/http/codec/HttpResponse.java
+2 -2
View File
@@ -61,7 +61,7 @@ public class HttpResponse {
try { try {
body.write(b); body.write(b);
} catch (IOException ex) { } catch (IOException ex) {
System.out.println("appendBody error"); // System.out.println("appendBody error");
} }
} }
@@ -69,7 +69,7 @@ public class HttpResponse {
try { try {
body.write(s.getBytes()); body.write(s.getBytes());
} catch (IOException ex) { } catch (IOException ex) {
System.out.println("appendBody string error"); // System.out.println("appendBody string error");
} }
} }
src/main/java/com/eactive/eai/adapter/socket2/tool/admin/NetAdmin.java
+3 -3
View File
@@ -10,8 +10,8 @@ public class NetAdmin {
if (args.length == 1) { if (args.length == 1) {
hostname = args[0]; hostname = args[0];
} else if (args.length == 2) { } else if (args.length == 2) {
System.out.println("args[0] " + args[0]); // System.out.println("args[0] " + args[0]);
System.out.println("args[1] " + args[1]); // System.out.println("args[1] " + args[1]);
hostname = args[0]; hostname = args[0];
port = Integer.parseInt(args[1]); port = Integer.parseInt(args[1]);
} }
@@ -32,6 +32,6 @@ public class NetAdmin {
sb.append("set connection - Max Connection 수 조정 ( netadmin set connection adapterName #OfConnection )"); sb.append("set connection - Max Connection 수 조정 ( netadmin set connection adapterName #OfConnection )");
sb.append("set thread - Max Thread 수 조정 ( netadmin set thread adapterName #OfSession )"); sb.append("set thread - Max Thread 수 조정 ( netadmin set thread adapterName #OfSession )");
sb.append("set trace - 소켓어뎁터 추적관리 레벨 조정 ( netadmin set trace adapterName [ 0 | 1 | 2] )\n"); sb.append("set trace - 소켓어뎁터 추적관리 레벨 조정 ( netadmin set trace adapterName [ 0 | 1 | 2] )\n");
System.out.println(sb.toString()); // System.out.println(sb.toString());
} }
} }
src/main/java/com/eactive/eai/adapter/socket2/tool/admin/Shell.java
+5 -5
View File
@@ -64,7 +64,7 @@ public class Shell {
public void loop() throws Exception { public void loop() throws Exception {
BufferedReader in = new BufferedReader(new InputStreamReader(System.in)); BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
System.out.println(welcomeMsg); // System.out.println(welcomeMsg);
do { do {
// set prompt // set prompt
prompt = "\nnetadmin-" + hostname + ":" + port + "| " + context + "> "; prompt = "\nnetadmin-" + hostname + ":" + port + "| " + context + "> ";
@@ -74,7 +74,7 @@ public class Shell {
try { try {
if(line != null) process(line); if(line != null) process(line);
} catch(Exception e) { } catch(Exception e) {
System.out.println("loop error "+ e.toString()); // System.out.println("loop error "+ e.toString());
} }
} while(true); } while(true);
} }
@@ -87,9 +87,9 @@ public class Shell {
SimpleFuture future = admin.stop(); SimpleFuture future = admin.stop();
future.join(); future.join();
} catch(Exception e) { } catch(Exception e) {
System.out.println("stop error"); // System.out.println("stop error");
} }
System.out.println(byeMsg); // System.out.println(byeMsg);
System.exit(1); System.exit(1);
} }
@@ -103,6 +103,6 @@ public class Shell {
context = res; context = res;
} }
} }
System.out.println(new String(response)); // System.out.println(new String(response));
} }
} }
src/main/java/com/eactive/eai/adapter/wca/WCASessionThread.java
+2 -2
View File
@@ -393,7 +393,7 @@ public class WCASessionThread implements Runnable {
myLog.logMsg(MyLog.WARN, "myLog Path : " + sMyLogPath); myLog.logMsg(MyLog.WARN, "myLog Path : " + sMyLogPath);
} }
catch(Exception ignore) { catch(Exception ignore) {
System.out.println("WCASessionThread> Exception Msg = " + ignore.toString()); // System.out.println("WCASessionThread> Exception Msg = " + ignore.toString());
} }
/* 20080523 End */ /* 20080523 End */
} }
@@ -739,7 +739,7 @@ public class WCASessionThread implements Runnable {
} }
} }
catch (Exception ignore) { catch (Exception ignore) {
System.out.println("WCASessionThread:run> Exception Msg = " + ignore.toString()); // System.out.println("WCASessionThread:run> Exception Msg = " + ignore.toString());
} }
/* 20080523 SMS 로그 추가 끝 */ /* 20080523 SMS 로그 추가 끝 */
} }
src/main/java/com/eactive/eai/adapter/wca/data/WCAQueue.java
+1 -1
View File
@@ -382,7 +382,7 @@ public class WCAQueue {
if (pBuff.length >= WCAHeader.WCA_HEADER_LEN + 3) if (pBuff.length >= WCAHeader.WCA_HEADER_LEN + 3)
System.arraycopy(pBuff, WCAHeader.WCA_HEADER_LEN, pDFSBuff, 0, pDFSBuff.length); System.arraycopy(pBuff, WCAHeader.WCA_HEADER_LEN, pDFSBuff, 0, pDFSBuff.length);
System.out.println("------> DFS : " + new String(pDFSBuff)); // System.out.println("------> DFS : " + new String(pDFSBuff));
if((new String(pDFSBuff)).equals(new String(WCADefine.DFS_MSG))) if((new String(pDFSBuff)).equals(new String(WCADefine.DFS_MSG)))
bDFSFlag = true; bDFSFlag = true;
else bDFSFlag = false; else bDFSFlag = false;
src/main/java/com/eactive/eai/adapter/wca/util/MyLog.java
+2 -2
View File
@@ -544,7 +544,7 @@ public class MyLog {
logMsg("LOG LEVLE = " + nLogLevel + ", LOG SIZE = " + MAX_LOG_FILE_SIZE + "M"); logMsg("LOG LEVLE = " + nLogLevel + ", LOG SIZE = " + MAX_LOG_FILE_SIZE + "M");
} }
catch (Exception e) { catch (Exception e) {
System.out.println("openLogStream error -"+e.toString()); // System.out.println("openLogStream error -"+e.toString());
} }
} }
@@ -559,7 +559,7 @@ public class MyLog {
} }
} }
catch (Exception e) { catch (Exception e) {
System.out.println("closeLogStream error -"+e.toString()); // System.out.println("closeLogStream error -"+e.toString());
} }
} }
src/main/java/com/eactive/eai/authoutbound/client/impl/HttpClientAccessTokenServiceWithParam.java
+2 -2
View File
@@ -228,10 +228,10 @@ public class HttpClientAccessTokenServiceWithParam implements HttpClientAccessTo
OAuth2AccessTokenVO accessToken = new OAuth2AccessTokenVO(); OAuth2AccessTokenVO accessToken = new OAuth2AccessTokenVO();
try (CloseableHttpResponse response = httpClient.execute(httpPost)) { try (CloseableHttpResponse response = httpClient.execute(httpPost)) {
if (response.getCode() != 200) { if (response.getCode() != 200) {
System.out.println("OAuth token receive status fail value= "+ response.getCode()); logger.info("OAuth token receive status fail value= " + response.getCode());
throw new Exception("OAuth token receive status fail value= " + response.getCode()); throw new Exception("OAuth token receive status fail value= " + response.getCode());
} }
System.out.println("OAuth token receive status SUCCESS value= "+ response.getCode()); logger.info("OAuth token receive status SUCCESS value= "+ response.getCode());
HttpEntity entity = response.getEntity(); HttpEntity entity = response.getEntity();
String responseString = EntityUtils.toString(entity, encode); String responseString = EntityUtils.toString(entity, encode);
src/main/java/com/eactive/eai/common/circuitBreaker/PrometheusController.java
+1 -1
View File
@@ -7,7 +7,7 @@ public class PrometheusController {
public PrometheusController() { public PrometheusController() {
System.out.println("init"); // System.out.println("init");
} }
// @GetMapping("/prometheus") // @GetMapping("/prometheus")
src/main/java/com/eactive/eai/common/logger/EAILogDAO.java
+2 -2
View File
@@ -880,7 +880,7 @@ public class EAILogDAO {
} }
originalAttribute = sb.toString(); originalAttribute = sb.toString();
System.out.println("DB 암호화 #2 : {"+ originalAttribute +"} -> {"+attribute+"}"); // System.out.println("DB 암호화 #2 : {"+ originalAttribute +"} -> {"+attribute+"}");
//logger.debug("DB 암호화 #2 : {} -> {}", originalAttribute, attribute); //logger.debug("DB 암호화 #2 : {} -> {}", originalAttribute, attribute);
} }
} }
@@ -964,7 +964,7 @@ public class EAILogDAO {
try { try {
encryptedBytes1 = safedb.encrypt(userName, tableName, columnName1, byteMsg); encryptedBytes1 = safedb.encrypt(userName, tableName, columnName1, byteMsg);
System.out.println("Encrypted Data : [" + new String(encryptedBytes1) + "]"); // System.out.println("Encrypted Data : [" + new String(encryptedBytes1) + "]");
byte[] decryptedBytes1 = safedb.decrypt(userName, tableName, columnName1, encryptedBytes1); byte[] decryptedBytes1 = safedb.decrypt(userName, tableName, columnName1, encryptedBytes1);
src/main/java/com/eactive/eai/common/state/ElinkStateManager.java
+1 -1
View File
@@ -19,7 +19,7 @@ public class ElinkStateManager {
if (logger != null) { if (logger != null) {
logger.warn(message); logger.warn(message);
} }
System.out.println(DatetimeUtil.getCurrentTime() + " " + LOG_PREFIX + message); // System.out.println(DatetimeUtil.getCurrentTime() + " " + LOG_PREFIX + message);
} }
public static synchronized ElinkStateManager getInstance() { public static synchronized ElinkStateManager getInstance() {
src/main/java/com/eactive/eai/env/SystemPropConfig.java
Vendored
+2 -2
View File
@@ -25,14 +25,14 @@ public class SystemPropConfig implements ServletContextAware {
@PostConstruct @PostConstruct
public void loadlPropertiesToSystemProp() { public void loadlPropertiesToSystemProp() {
System.out.println("loadPropertiesToSystemProp: "+SYSTEM_PROP_FILE_PATH); // System.out.println("loadPropertiesToSystemProp: "+SYSTEM_PROP_FILE_PATH);
Properties sysProp = new Properties(); Properties sysProp = new Properties();
try(InputStream is = servletContext.getResourceAsStream(SYSTEM_PROP_FILE_PATH)){ try(InputStream is = servletContext.getResourceAsStream(SYSTEM_PROP_FILE_PATH)){
sysProp.load(is); sysProp.load(is);
sysProp.forEach((key, value) -> { sysProp.forEach((key, value) -> {
if (StringUtils.isBlank(System.getProperty((String) key))) { if (StringUtils.isBlank(System.getProperty((String) key))) {
System.setProperty((String) key, (String) value); System.setProperty((String) key, (String) value);
System.out.println("Set system prop: "+key+"="+value); // System.out.println("Set system prop: "+key+"="+value);
} }
}); });
} catch (Throwable th) { } catch (Throwable th) {
src/main/java/com/eactive/eai/flowcontroller/C2RFCProcess.java
+1 -1
View File
@@ -358,7 +358,7 @@ public class C2RFCProcess extends Process {
if (this.callProp != null) { if (this.callProp != null) {
String mode = this.callProp.getProperty(EAIKeys.CALL_MODE_KEY); String mode = this.callProp.getProperty(EAIKeys.CALL_MODE_KEY);
if (mode != null && EAIKeys.CALL_MODE_WARMUP.equals(mode)) { if (mode != null && EAIKeys.CALL_MODE_WARMUP.equals(mode)) {
System.out.println(guidLogPrefix + " Warming Up Called"); // System.out.println(guidLogPrefix + " Warming Up Called");
return false; return false;
} else { } else {
return true; return true;
src/main/java/com/eactive/eai/inbound/processor/RequestProcessor.java
+1 -1
View File
@@ -346,7 +346,7 @@ public class RequestProcessor extends RequestProcessorSupport {
// 3. EAIMessage Object 생성 // 3. EAIMessage Object 생성
//String eaiSvcCd = mapper.getEaiSvcCode(standardMessage); // commnet by jwhong //String eaiSvcCd = mapper.getEaiSvcCode(standardMessage); // commnet by jwhong
String eaiSvcCd = prop.getProperty("API_SERVICE_CODE"); String eaiSvcCd = prop.getProperty("API_SERVICE_CODE");
System.out.println("***** eaiSvcCd is"+ eaiSvcCd); logger.info("eaiSvcCd = "+eaiSvcCd);
if (StringUtils.isEmpty(eaiSvcCd)) eaiSvcCd = mapper.getEaiSvcCode(standardMessage); // HTT 어댑터로 들어오는거래는 Prop에 서비스코드가 없음. if (StringUtils.isEmpty(eaiSvcCd)) eaiSvcCd = mapper.getEaiSvcCode(standardMessage); // HTT 어댑터로 들어오는거래는 Prop에 서비스코드가 없음.
String guid = mapper.getGuid(standardMessage); String guid = mapper.getGuid(standardMessage);
String guidSeq = mapper.getGuidSeq(standardMessage); String guidSeq = mapper.getGuidSeq(standardMessage);
src/main/java/com/eactive/eai/message/StandardMessageUtil.java
+8 -8
View File
@@ -363,13 +363,13 @@ public class StandardMessageUtil {
StandardMessage stdmsg = generateMessageFromCsvFile(filePath); StandardMessage stdmsg = generateMessageFromCsvFile(filePath);
System.out.println("==========================================================================="); // System.out.println("===========================================================================");
System.out.println(stdmsg.getChilds().size()); // System.out.println(stdmsg.getChilds().size());
System.out.println(stdmsg); // System.out.println(stdmsg);
System.out.println("==========================================================================="); // System.out.println("===========================================================================");
System.out.println(stdmsg.getLlDataPath()); // System.out.println(stdmsg.getLlDataPath());
System.out.println(stdmsg.getBizDataPath()); // System.out.println(stdmsg.getBizDataPath());
System.out.println(stdmsg.getZzDataPath()); // System.out.println(stdmsg.getZzDataPath());
System.out.println("==========================================================================="); // System.out.println("===========================================================================");
} }
} }
src/main/java/com/eactive/eai/util/ByteCharSequence.java
+1 -1
View File
@@ -52,6 +52,6 @@ public class ByteCharSequence implements CharSequence{
if (m.find()){ if (m.find()){
index = m.start(); index = m.start();
} }
System.out.println("index = " + index); // System.out.println("index = " + index);
} }
} }
src/main/java/com/eactive/eai/util/CryptoUtil.java
+5 -5
View File
@@ -51,20 +51,20 @@ public class CryptoUtil {
String key = "ONAuROzlqWB4VuBwO5C/FA=="; String key = "ONAuROzlqWB4VuBwO5C/FA==";
String text = "Hello AES 한글"; String text = "Hello AES 한글";
System.out.println("Original Text: " + text); // System.out.println("Original Text: " + text);
long startEncryptTime = System.nanoTime(); long startEncryptTime = System.nanoTime();
String enc = encryptAES(key, text); String enc = encryptAES(key, text);
long endEncryptTime = System.nanoTime(); long endEncryptTime = System.nanoTime();
long encryptDuration = endEncryptTime - startEncryptTime; long encryptDuration = endEncryptTime - startEncryptTime;
System.out.println("Encrypted Text: " + enc); // System.out.println("Encrypted Text: " + enc);
System.out.println("Encryption took: " + encryptDuration + " nanoseconds"); // System.out.println("Encryption took: " + encryptDuration + " nanoseconds");
long startDecryptTime = System.nanoTime(); long startDecryptTime = System.nanoTime();
String dec = decryptAES(key, enc); String dec = decryptAES(key, enc);
long endDecryptTime = System.nanoTime(); long endDecryptTime = System.nanoTime();
long decryptDuration = endDecryptTime - startDecryptTime; long decryptDuration = endDecryptTime - startDecryptTime;
System.out.println("Decrypted Text: " + dec); // System.out.println("Decrypted Text: " + dec);
System.out.println("Decryption took: " + decryptDuration + " nanoseconds"); // System.out.println("Decryption took: " + decryptDuration + " nanoseconds");
} }
} }
src/main/java/com/eactive/eai/util/IpUtil.java
+2 -2
View File
@@ -38,9 +38,9 @@ public class IpUtil {
String matchdIps = "192.168.0.1,192.168.0.0/24,192.168.1.*"; String matchdIps = "192.168.0.1,192.168.0.0/24,192.168.1.*";
String requestIp = "192.168.1.2"; String requestIp = "192.168.1.2";
if (IpUtil.isMatchIp(matchdIps, requestIp)) { if (IpUtil.isMatchIp(matchdIps, requestIp)) {
System.out.println(true); // System.out.println(true);
} else { } else {
System.out.println(false); // System.out.println(false);
} }
} }
src/main/java/com/eactive/eai/util/JsonBeatiUtil.java
+1 -1
View File
@@ -135,7 +135,7 @@ public class JsonBeatiUtil {
data += "} "; data += "} ";
data = "{\"EAI_UJSON2DEPTHEXT_REQ1\":{\"abc\":\"cba \",\"grid1\":[{\"long1\":1,\"data2\":\" \",\"grid2\":[{\"data3\":\"12345\",\"big4\":\"14.00000\"},{\"data3\":\"13 \",\"big4\":\"14.00001\"}]},{\"long1\":10000,\"data2\":\" \",\"grid2\":[{\"data3\":\"23 \",\"big4\":\"24.00000\"}]},{\"long1\":1000000000,\"data2\":\" \",\"grid2\":[{\"data3\":\"33 \",\"big4\":\"0.00000\"},{\"data3\":\" \",\"big4\":\"0.00034\"},{\"data3\":\"35 \",\"big4\":\"0.00036\"}]}],\"abcd\":\"123\",\"grid3\":[{\"long1\":1,\"data2\":\" \",\"grid4\":[{\"data5\":\"00023\",\"big6\":\"24\"}]},{\"long1\":1000000000,\"data2\":\" \",\"grid4\":[{\"data5\":\"00033\",\"big6\":\"0\"},{\"data5\":\" \",\"big6\":\"34\"},{\"data5\":\"00035\",\"big6\":\"900000003600011\"}]}]}}"; data = "{\"EAI_UJSON2DEPTHEXT_REQ1\":{\"abc\":\"cba \",\"grid1\":[{\"long1\":1,\"data2\":\" \",\"grid2\":[{\"data3\":\"12345\",\"big4\":\"14.00000\"},{\"data3\":\"13 \",\"big4\":\"14.00001\"}]},{\"long1\":10000,\"data2\":\" \",\"grid2\":[{\"data3\":\"23 \",\"big4\":\"24.00000\"}]},{\"long1\":1000000000,\"data2\":\" \",\"grid2\":[{\"data3\":\"33 \",\"big4\":\"0.00000\"},{\"data3\":\" \",\"big4\":\"0.00034\"},{\"data3\":\"35 \",\"big4\":\"0.00036\"}]}],\"abcd\":\"123\",\"grid3\":[{\"long1\":1,\"data2\":\" \",\"grid4\":[{\"data5\":\"00023\",\"big6\":\"24\"}]},{\"long1\":1000000000,\"data2\":\" \",\"grid4\":[{\"data5\":\"00033\",\"big6\":\"0\"},{\"data5\":\" \",\"big6\":\"34\"},{\"data5\":\"00035\",\"big6\":\"900000003600011\"}]}]}}";
System.out.println(JsonBeatiUtil.SimpleBeautiful(data)); // System.out.println(JsonBeatiUtil.SimpleBeautiful(data));
} }
} }
src/main/java/com/eactive/eai/util/JsonPathUtil.java
+6 -6
View File
@@ -104,22 +104,22 @@ public class JsonPathUtil {
public static void main(String[] args) { public static void main(String[] args) {
String jsonString = "{ \"person\": { \"name\": \"John\", \"age\": 30, \"groups\": [ { \"id\": 1, \"name\": \"Group A\" }, { \"id\": 2, \"name\": \"Group B\" }, { \"id\": 3, \"name\": \"Group C\" } ] } }"; String jsonString = "{ \"person\": { \"name\": \"John\", \"age\": 30, \"groups\": [ { \"id\": 1, \"name\": \"Group A\" }, { \"id\": 2, \"name\": \"Group B\" }, { \"id\": 3, \"name\": \"Group C\" } ] } }";
System.out.println("Source JSON: \n" + jsonString); // System.out.println("Source JSON: \n" + jsonString);
// 경로를 사용하여 값 가져오기 (반복되는 그룹 포함) // 경로를 사용하여 값 가져오기 (반복되는 그룹 포함)
String getPath = "/person/groups/1/name"; String getPath = "/person/groups/1/name";
String secondGroupName = getValueAtPath(jsonString, getPath); String secondGroupName = getValueAtPath(jsonString, getPath);
System.out.println("getPath: " + getPath + " -> " + secondGroupName); // System.out.println("getPath: " + getPath + " -> " + secondGroupName);
// 경로를 사용하여 값 설정하기 (반복되는 그룹 포함) 및 Pretty 출력 // 경로를 사용하여 값 설정하기 (반복되는 그룹 포함) 및 Pretty 출력
String putPath = "/person/groups/2/name"; String putPath = "/person/groups/2/name";
String updatedJsonString = setValueAtPath(jsonString, putPath, "Group Z", true); String updatedJsonString = setValueAtPath(jsonString, putPath, "Group Z", true);
System.out.println("putPath: " + putPath); // System.out.println("putPath: " + putPath);
System.out.println("Updated JSON (Pretty): \n" + updatedJsonString); // System.out.println("Updated JSON (Pretty): \n" + updatedJsonString);
getPath = "/person/name"; getPath = "/person/name";
System.out.println("getPath: " + getPath + " -> " + getValueAtPath(jsonString, getPath)); // System.out.println("getPath: " + getPath + " -> " + getValueAtPath(jsonString, getPath));
getPath = "/person/age"; getPath = "/person/age";
System.out.println("getPath: " + getPath + " -> " + getValueAtPath(jsonString, getPath)); // System.out.println("getPath: " + getPath + " -> " + getValueAtPath(jsonString, getPath));
} }
} }
src/main/java/com/eactive/eai/util/json/JsonPathsTransform.java
+1 -1
View File
@@ -47,7 +47,7 @@ public class JsonPathsTransform {
String encLog = transformer.getClass().getName() + " : " String encLog = transformer.getClass().getName() + " : "
+ String.format("path=%s, orgText[%s] plain[%s] newText[%s]", path, currentValue, + String.format("path=%s, orgText[%s] plain[%s] newText[%s]", path, currentValue,
transformer.getProperty("PLAIN_VALUE"), newValue); transformer.getProperty("PLAIN_VALUE"), newValue);
System.out.println(encLog); // System.out.println(encLog);
logger.debug(encLog); logger.debug(encLog);
} }
} catch (Exception e) { } catch (Exception e) {
src/main/java/com/eactive/eai/util/json/JsonSimplePathsTransform.java
+1 -1
View File
@@ -30,7 +30,7 @@ public class JsonSimplePathsTransform {
if(logger.isDebug()) { if(logger.isDebug()) {
// FIXME : kbank - 로그내용 수정 // FIXME : kbank - 로그내용 수정
String encLog = transformer.getClass().getName() +" : "+ String.format("path=%s, orgText[%s] plain[%s] newText[%s]", path, currentValue, transformer.getProperty("PLAIN_VALUE"), newValue); String encLog = transformer.getClass().getName() +" : "+ String.format("path=%s, orgText[%s] plain[%s] newText[%s]", path, currentValue, transformer.getProperty("PLAIN_VALUE"), newValue);
System.out.println(encLog); // System.out.println(encLog);
logger.debug(encLog); logger.debug(encLog);
} }
setNodeValue(getParentNode(rootNode, getParentPath(path)), getFieldName(path), newValue); setNodeValue(getParentNode(rootNode, getParentPath(path)), getFieldName(path), newValue);
src/main/java/com/kbstar/eai/common/header/SHINBOHeaderAction.java
+1 -1
View File
@@ -171,7 +171,7 @@ public class SHINBOHeaderAction extends HeaderActionSupport
SHINBOHeaderAction sha = new SHINBOHeaderAction(); SHINBOHeaderAction sha = new SHINBOHeaderAction();
byte[] res = sha.addHeaderAD(orgData, message); byte[] res = sha.addHeaderAD(orgData, message);
System.out.println("res]" +new String(res)); // System.out.println("res]" +new String(res));
} }
*/ */
} }
src/main/java/com/kbstar/eai/common/loader/EAILogFIleLoader.java
+23 -23
View File
@@ -202,7 +202,7 @@ public class EAILogFIleLoader {
in = new FileInputStream(configPath); in = new FileInputStream(configPath);
p.load(in); p.load(in);
} catch (Exception e){ } catch (Exception e){
System.out.println("환경설정 파일이 없습니다. - 파일명 : " + configPath); // System.out.println("환경설정 파일이 없습니다. - 파일명 : " + configPath);
throw e; throw e;
} }
finally{ finally{
@@ -211,7 +211,7 @@ public class EAILogFIleLoader {
in.close(); in.close();
} }
catch(Exception e) { catch(Exception e) {
System.out.println("close error"); // System.out.println("close error");
} }
} }
} }
@@ -225,16 +225,16 @@ public class EAILogFIleLoader {
// String iniKey = p.getProperty("ini.key"); // String iniKey = p.getProperty("ini.key");
String encpval = p.getProperty("jdbc.pvalue"); String encpval = p.getProperty("jdbc.pvalue");
System.out.println("========================================================="); // System.out.println("=========================================================");
System.out.println(" EAILogFileLoader Configuration - "+ new Date()); // System.out.println(" EAILogFileLoader Configuration - "+ new Date());
System.out.println("========================================================="); // System.out.println("=========================================================");
// System.out.println("driver = " + driver); // System.out.println("driver = " + driver);
// System.out.println("url = " + url); // System.out.println("url = " + url);
// System.out.println("ivalue = " + ival); // System.out.println("ivalue = " + ival);
// System.out.println("pvalue = " + encpval); // System.out.println("pvalue = " + encpval);
// System.out.println("Table Owner = " + tableOwner); // System.out.println("Table Owner = " + tableOwner);
// System.out.println("iniFilePath = " + iniFilePath); // System.out.println("iniFilePath = " + iniFilePath);
System.out.println("========================================================="); // System.out.println("=========================================================");
// ScpDbAgent agt = new ScpDbAgent(); // ScpDbAgent agt = new ScpDbAgent();
// try { // try {
@@ -256,7 +256,7 @@ public class EAILogFIleLoader {
try { try {
date = new SimpleDateFormat("yyyyMMdd").parse(timeStr); // "yyyyMMddHHmmssSSS" date = new SimpleDateFormat("yyyyMMdd").parse(timeStr); // "yyyyMMddHHmmssSSS"
} catch (ParseException e) { } catch (ParseException e) {
System.out.println("getDayOfWeekNum error - "+timeStr); // System.out.println("getDayOfWeekNum error - "+timeStr);
// e.printStackTrace(); // e.printStackTrace();
} }
long time = date.getTime(); long time = date.getTime();
@@ -281,7 +281,7 @@ public class EAILogFIleLoader {
String[] info = null; String[] info = null;
try { try {
System.out.println(">> Log Date : " + cDay + ", rows=" + list.size()); // System.out.println(">> Log Date : " + cDay + ", rows=" + list.size());
if( driver != null ) { if( driver != null ) {
Class.forName(driver); Class.forName(driver);
@@ -601,7 +601,7 @@ public class EAILogFIleLoader {
// conn.commit(); // conn.commit();
} }
catch(Exception ex) { catch(Exception ex) {
System.out.println("ERROR SKIP INSERT - row : "+ position +", Error : " + ex.toString()); // System.out.println("ERROR SKIP INSERT - row : "+ position +", Error : " + ex.toString());
// ex.printStackTrace(); // ex.printStackTrace();
if(!isForce) throw ex; if(!isForce) throw ex;
} }
@@ -611,17 +611,17 @@ public class EAILogFIleLoader {
catch(SQLException se) { catch(SQLException se) {
// if(conn != null) conn.rollback(); // if(conn != null) conn.rollback();
if(info!=null) { if(info!=null) {
System.out.println("ERROR : DB 오류 - " + info.toString()); // System.out.println("ERROR : DB 오류 - " + info.toString());
} }
else { else {
System.out.println("ERROR : DB 오류 - " + se.toString()); // System.out.println("ERROR : DB 오류 - " + se.toString());
} }
// se.printStackTrace(); // se.printStackTrace();
throw se; throw se;
} }
catch(Exception e) { catch(Exception e) {
// if(conn != null) conn.rollback(); // if(conn != null) conn.rollback();
System.out.println(e.toString()); // System.out.println(e.toString());
// e.printStackTrace(); // e.printStackTrace();
throw e; throw e;
} }
@@ -630,13 +630,13 @@ public class EAILogFIleLoader {
if(preparedStatement != null) preparedStatement.close(); if(preparedStatement != null) preparedStatement.close();
} }
catch (SQLException sqle) { catch (SQLException sqle) {
System.out.println("SQLException was thrown: " + sqle.toString()); // System.out.println("SQLException was thrown: " + sqle.toString());
} }
try { try {
if(conn != null) conn.close(); if(conn != null) conn.close();
} }
catch (SQLException sqle) { catch (SQLException sqle) {
System.out.println("SQLException was thrown: " + sqle.toString()); // System.out.println("SQLException was thrown: " + sqle.toString());
} }
} }
} }
@@ -666,14 +666,14 @@ public class EAILogFIleLoader {
} while (!"".equals(subMsgStr) && seq < 99); // TSEAILG02.BzwkDataSerno : NUMBER(2) } while (!"".equals(subMsgStr) && seq < 99); // TSEAILG02.BzwkDataSerno : NUMBER(2)
} catch(Exception e) { } catch(Exception e) {
System.out.println("DB Logging[SLAVE] Failed - " + info[0] + "|" + info[1] + "|" + info[2] +"|seq="+seq); // System.out.println("DB Logging[SLAVE] Failed - " + info[0] + "|" + info[1] + "|" + info[2] +"|seq="+seq);
throw e; throw e;
} finally { } finally {
if(preparedStatement != null) { if(preparedStatement != null) {
try { try {
preparedStatement.close(); preparedStatement.close();
} catch (SQLException e) { } catch (SQLException e) {
System.out.println("SQLException was thrown: " + e.toString()); // System.out.println("SQLException was thrown: " + e.toString());
} }
} }
} }
@@ -729,21 +729,21 @@ public class EAILogFIleLoader {
} }
} }
catch(Exception e) { catch(Exception e) {
System.out.println(e.toString()); // System.out.println(e.toString());
} }
finally { finally {
try { try {
if(br != null) br.close(); if(br != null) br.close();
} }
catch(Exception e) { catch(Exception e) {
System.out.println(e.toString()); // System.out.println(e.toString());
} }
} }
if(count > 0) { if(count > 0) {
loadLog(cDay, list, true); loadLog(cDay, list, true);
} }
System.out.println(String.format("## FILE=%s, INSERT ROW COUNTS : (%d/%d)", filePath, insertCount, totalCount)); // System.out.println(String.format("## FILE=%s, INSERT ROW COUNTS : (%d/%d)", filePath, insertCount, totalCount));
} }
private String[] split(String data, String deli) { private String[] split(String data, String deli) {
@@ -786,7 +786,7 @@ public class EAILogFIleLoader {
String filePath = "C:\\trlog\\tran.log"; //args[1]; String filePath = "C:\\trlog\\tran.log"; //args[1];
try { try {
if(isReal && args.length < 2) { if(isReal && args.length < 2) {
System.out.println(getUsage()); // System.out.println(getUsage());
System.exit(-1); System.exit(-1);
} }
@@ -795,13 +795,13 @@ public class EAILogFIleLoader {
filePath = args[1]; filePath = args[1];
} }
System.out.println("\n## START LOADING Infomation - " + configPath); // System.out.println("\n## START LOADING Infomation - " + configPath);
loader = new EAILogFIleLoader(); loader = new EAILogFIleLoader();
loader.init(configPath); loader.init(configPath);
loader.parse(filePath); loader.parse(filePath);
} catch (Exception e) { } catch (Exception e) {
System.out.println("ERROR MAIN"); // System.out.println("ERROR MAIN");
System.out.println(e.toString()); // System.out.println(e.toString());
System.exit(-2); System.exit(-2);
} }
System.exit(0); System.exit(0);