DropBox(메시지 처리) 진행중

main
semin.baek 11 months ago
parent 1132a04223
commit 3355d16f28

@ -44,6 +44,7 @@ dependencies {
implementation group: 'org.mariadb.jdbc', name: 'mariadb-java-client', version: '3.5.2' implementation group: 'org.mariadb.jdbc', name: 'mariadb-java-client', version: '3.5.2'
implementation group: 'com.microsoft.sqlserver', name: 'mssql-jdbc', version: '12.8.1.jre8' implementation group: 'com.microsoft.sqlserver', name: 'mssql-jdbc', version: '12.8.1.jre8'
implementation group: 'com.ibm.db2', name: 'jcc', version: '12.1.0.0' implementation group: 'com.ibm.db2', name: 'jcc', version: '12.1.0.0'
developmentOnly 'org.springframework.boot:spring-boot-devtools'
} }

@ -70,7 +70,7 @@ public class Settings {
@SuppressWarnings("unchecked") @SuppressWarnings("unchecked")
private void parseDropBoxes(Map<String, Object> settingMap) { private void parseDropBoxes(Map<String, Object> settingMap) {
List<Map<String, String>> dropBoxMapList = (List<Map<String, String>>)settingMap.get("drop-box"); List<Map<String, String>> dropBoxMapList = (List<Map<String, String>>)settingMap.get("drop-box");
//TODO drop-box executor 개발 //TODO drop-box executor 개발 -> ListenerController
for(Map<String, String> dropBoxMap : dropBoxMapList) { for(Map<String, String> dropBoxMap : dropBoxMapList) {
DropBoxDto dropBoxDto = DropBoxDto.builder() DropBoxDto dropBoxDto = DropBoxDto.builder()
.dropBoxId(dropBoxMap.get("drop-box-id")).taskType(dropBoxMap.get("task-type")) .dropBoxId(dropBoxMap.get("drop-box-id")).taskType(dropBoxMap.get("task-type"))

@ -31,7 +31,7 @@ public class MessageUtils {
if(map.get("sender") == null) { if(map.get("sender") == null) {
throw new InCompleteMessageException("sender 엘리먼트를 찾을 수 없습니다."); throw new InCompleteMessageException("sender 엘리먼트를 찾을 수 없습니다.");
} }
else if(map.get("sender") instanceof Map){ else if(!(map.get("sender") instanceof Map)) {
throw new InCompleteMessageException("sender 엘리먼트의 데이터가 객체타입이 아닙니다."); throw new InCompleteMessageException("sender 엘리먼트의 데이터가 객체타입이 아닙니다.");
} }
Map<String, Object> senderMap = (Map<String, Object>)map.get("sender"); Map<String, Object> senderMap = (Map<String, Object>)map.get("sender");
@ -53,7 +53,7 @@ public class MessageUtils {
throw new InCompleteMessageException("sender.timestamp 값을 찾을 수 없습니다."); throw new InCompleteMessageException("sender.timestamp 값을 찾을 수 없습니다.");
} }
else { else {
String senderTimeStampString = String.valueOf(senderMap.get("host-id")); String senderTimeStampString = String.valueOf(senderMap.get("timestamp"));
try { try {
senderTimestamp = Long.parseLong(senderTimeStampString); senderTimestamp = Long.parseLong(senderTimeStampString);
} catch (NumberFormatException e) { } catch (NumberFormatException e) {
@ -80,7 +80,7 @@ public class MessageUtils {
if(map.get("recipient") == null) { if(map.get("recipient") == null) {
throw new InCompleteMessageException("recipient 엘리먼트를 찾을 수 없습니다."); throw new InCompleteMessageException("recipient 엘리먼트를 찾을 수 없습니다.");
} }
else if(map.get("recipient") instanceof Map){ else if(!(map.get("recipient") instanceof Map)) {
throw new InCompleteMessageException("recipient 엘리먼트의 데이터가 객체타입이 아닙니다."); throw new InCompleteMessageException("recipient 엘리먼트의 데이터가 객체타입이 아닙니다.");
} }
Map<String, Object> recipientMap = (Map<String, Object>)map.get("recipient"); Map<String, Object> recipientMap = (Map<String, Object>)map.get("recipient");

@ -9,7 +9,8 @@ spring:
web-allow-others: true web-allow-others: true
datasource: datasource:
driverClassName: org.h2.Driver driverClassName: org.h2.Driver
url: jdbc:h2:classpath:/storages/dfxagent #url: jdbc:h2:classpath:/storages/dfxagent
url: jdbc:h2:~/dfxagent
username: smbaek username: smbaek
password: qortpals1! password: qortpals1!
logging: logging:

Loading…
Cancel
Save