Bigdata, Hadoop ecosystem, Semantic IoT등의 프로젝트를 진행중에 습득한 내용을 정리하는 곳입니다.
필요한 분을 위해서 공개하고 있습니다.
문의사항은 gooper@gooper.com로 메일을
보내주세요.
-------------------CustomViewChangedEventListener.java----------------
package com.gooper.drool_test;
import java.util.ArrayList;
import java.util.List;
import org.kie.api.runtime.rule.Row;
import org.kie.api.runtime.rule.ViewChangedEventListener;
/*
* 쿼리 변경 이벤트를 처리하기 위한 구현체
*/
public class CustomViewChangedEventListener implements ViewChangedEventListener {
private List<ServerInfo> updatedServers;
private List<ServerInfo> deletedServers;
private List<ServerInfo> currentServers;
public CustomViewChangedEventListener() {
updatedServers = new ArrayList<ServerInfo>();
deletedServers = new ArrayList<ServerInfo>();
currentServers = new ArrayList<ServerInfo>();
}
@Override
public void rowDeleted(Row row) {
deletedServers.add((ServerInfo)row.get("$server_info"));
}
@Override
public void rowInserted(Row row) {
currentServers.add((ServerInfo)row.get("$server_info"));
}
@Override
public void rowUpdated(Row row) {
updatedServers.add((ServerInfo)row.get("$server_info"));
}
public List<ServerInfo> getUpdatedServers() {
return updatedServers;
}
public List<ServerInfo> getDeletedServers() {
return deletedServers;
}
public List<ServerInfo> getCurrentServers() {
return currentServers;
}
}