Information
Technologies
Decompiled Java File
package com.acme.anvil.service.jms;
import com.acme.anvil.vo.LogEvent;
import java.io.Serializable;
import java.text.SimpleDateFormat;
import javax.ejb.MessageDrivenBean;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.ObjectMessage;
import org.apache.log4j.Logger;
import weblogic.ejb.GenericMessageDrivenBean;
import weblogic.ejbgen.MessageDriven;
@MessageDriven(
ejbName = "LogEventSubscriber",
destinationJndiName = "jms/LogEventQueue",
destinationType = "javax.jms.Topic",
runAsPrincipalName = "anvil_user",
runAs = "anvil_user"
)
public class LogEventSubscriber extends GenericMessageDrivenBean implements MessageDrivenBean, MessageListener {
private static final Logger LOG = Logger.getLogger(LogEventSubscriber.class);
private static final SimpleDateFormat SDF = new SimpleDateFormat("MM/dd/yyyy \'at\' HH:mm:ss z");
public void onMessage(Message msg) {
ObjectMessage om = (ObjectMessage)msg;
try {
Serializable obj = om.getObject();
if(obj instanceof LogEvent) {
LogEvent e = (LogEvent)obj;
LOG.info("Log Event [" + SDF.format(e.getDate()) + "] : " + e.getMessage());
}
} catch (JMSException var5) {
LOG.error("Exception reading message.", var5);
}
}
}