|
public void onMessage(javax.jms.Message message) {
try {
if(message instanceof ObjectMessage) {
ObjectMessage objectMessage = (ObjectMessage)message;
if(objectMessage.getObject() instanceof RunResultInfo) {
//JMSメッセージをジョブ実行結果へキャストします。
RunResultInfo info = (RunResultInfo)objectMessage.getObject();
//ジョブを制御するSessionBeanを取得します。
JobRunManagemantLocal jobRunManagemant = JobRunManagemantUtil.getLocalHome().create();
try {
//SessionBeanの終了処理メソッドを呼びだします。
jobRunManagemant.endNode(info);
} catch (Exception e) {
m_log.debug("onMessage() : endNode() : " + e.getMessage());
}
}
}
} catch (Exception e) {
}
}
|
|