Red Hat Application Migration Toolkit
package com.acme.anvil.service.jms; import com.acme.anvil.vo.LogEvent; 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 { Object obj = om.getObject(); if (obj instanceof LogEvent) { LogEvent event = (LogEvent)obj; LOG.info("Log Event [" + SDF.format(event.getDate()) + "] : " + event.getMessage()); } } catch (JMSException var5) { LOG.error("Exception reading message.", var5); } } }