Source Report

workspace/src/main/java/com/acme/anvil/service/jms/LogEventSubscriber.java

package com.acme.anvil.service.jms;


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 com.acme.anvil.vo.LogEvent;

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;
		Object obj;
		try {
			obj = om.getObject();
			
			if(obj instanceof LogEvent) {
				LogEvent event = (LogEvent)obj;
				LOG.info("Log Event ["+SDF.format(event.getDate())+"] : "+event.getMessage());
			}
		} catch (JMSException e) {
			LOG.error("Exception reading message.", e);
		}
	}
}