<%@ page import="javax.jms.*,com.eactive.eai.flowcontrol.jms.*"%>
<%@ page language="java" contentType="text/html;charset=utf-8"%>
<%
String receiverName = request.getParameter("receiverName");
String queueName = request.getParameter("queueName");
String errorQueueName = request.getParameter("errorQueueName");
String receiverCount = request.getParameter("receiverCount");
String delayMs = request.getParameter("delayMs");
String retryCnt = request.getParameter("retryCnt");
String selector = request.getParameter("selector");
String descr = request.getParameter("descr");
String sreceiverName = request.getParameter("s_receiverName");
String actionType = request.getParameter("actionType");
String[][] monitorDataTotal = null;
String[][] monitorData = null;
FCQueueReceiverManager man = FCQueueReceiverManager.getInstance();
System.out.println("actionType = " + actionType);
System.out.println("sreceiverName = " + sreceiverName);
String errorMsg = null;
String[] receiverNames = null;
try {
if("START".equals(actionType)) {
System.out.println("START : receiverName = " + receiverName);
int ireceiverCount = Integer.parseInt(receiverCount);
int idelayMs = Integer.parseInt(delayMs);
int iretryCnt = Integer.parseInt(retryCnt);
FCQueueReceiverVO vo = new FCQueueReceiverVO();
vo.setReceiverName(receiverName);
vo.setQueueName(queueName);
vo.setErrorQueueName(errorQueueName);
vo.setReceiverCount(ireceiverCount);
vo.setErrorDelayTimeMs(idelayMs);
vo.setRetryCount(iretryCnt);
vo.setMessageSelector(selector);
vo.setDescription(descr);
man.setFCQueueReceiver(vo);
}
else if("STOP".equals(actionType)) {
System.out.println("STOP : receiverName = " + sreceiverName);
man.removeFCQueueReceiver(sreceiverName);
}
else if("STATUS".equals(actionType)) {
System.out.println("STATUS : receiverName = " + sreceiverName);
monitorDataTotal = man.getMonitorData();
monitorData = man.getMonitorData(sreceiverName);
FCQueueReceiverVO vo = man.getFCQueueReceiver(sreceiverName);
receiverName = vo.getReceiverName();
queueName = vo.getQueueName();
errorQueueName = vo.getErrorQueueName();
receiverCount = "" + vo.getReceiverCount();
delayMs = "" + vo.getErrorDelayTimeMs();
retryCnt = "" + vo.getRetryCount();
selector = vo.getMessageSelector();
descr = vo.getDescription();
}
else if("RESET".equals(actionType)) {
System.out.println("RESET : receiverName = " + sreceiverName);
man.resetCount(sreceiverName);
}
else {
System.out.println("Unhandled Action " + actionType);
}
System.out.println("receiverName = " + receiverName);
System.out.println("queueName = " + queueName);
System.out.println("errorQueueName= " + errorQueueName);
System.out.println("receiverCount = " + receiverCount);
System.out.println("delayMs = " + delayMs);
System.out.println("retryCnt = " + retryCnt);
System.out.println("selector = " + selector);
System.out.println("descr = " + descr);
} catch(Exception e) {
errorMsg = e.getMessage();
//e.printStackTrace();
}
try {
receiverNames = man.getAllReceiverNames();
} catch(Exception e) {
errorMsg = e.getMessage();
//e.printStackTrace();
}
%>
FC Queue Receiver Manager
FC Queue Receiver Manager