import java.util.List;
import javax.ejb.EJBException;
import javax.ejb.Stateless;
-import javax.faces.FacesException;
-import javax.jms.Connection;
import javax.jms.JMSException;
-import javax.jms.MessageProducer;
import javax.jms.ObjectMessage;
-import javax.jms.Queue;
-import javax.jms.QueueConnectionFactory;
-import javax.jms.Session;
-import javax.naming.Context;
-import javax.naming.InitialContext;
-import javax.naming.NamingException;
import javax.persistence.Query;
import org.mxchange.jcoreee.database.BaseDatabaseBean;
import org.mxchange.jusercore.model.user.User;
-import org.mxchange.pizzaaplication.database.BasePizzaDatabaseBean;
/**
* An EJB for user activity log. This class extends BaseDatabaseBean and not
*/
private static final long serialVersionUID = 219_568_677_671_054L;
- /**
- * Connection
- */
- private Connection activityConnection;
-
- /**
- * Message producer
- */
- private MessageProducer activityMessageProducer;
-
- /**
- * Mailer message queue
- */
- private Queue activityQueue;
-
- /**
- * Session instance
- */
- private Session activitySession;
-
/**
* Default constructor
*/
public PizzaUserActivitySessionBean () {
// Call super constructor
- super();
-
- try {
- // Get initial context
- Context context = new InitialContext();
-
- // Get factory from JMS resource
- QueueConnectionFactory connectionFactory = (QueueConnectionFactory) context.lookup("jms/pizzaservice-queue-factory"); //NOI18N
-
- // Lookup queue
- this.activityQueue = (Queue) context.lookup("jms/jlanding-user-activity-log"); //NOI18N
-
- // Create connection
- this.activityConnection = connectionFactory.createConnection();
-
- // Init session instance
- this.activitySession = this.activityConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-
- // And message producer
- this.activityMessageProducer = this.activitySession.createProducer(this.activityQueue);
- } catch (final NamingException | JMSException e) {
- // Continued to throw
- throw new FacesException(e);
- }
+ super("jms/pizzaservice-queue-factory", "jms/pizzaservice-user-activity-log"); //NOI18N
}
@Override
try {
// Send out email change
- ObjectMessage message = this.activitySession.createObjectMessage();
+ ObjectMessage message = this.getSession().createObjectMessage();
message.setObject(userActivity);
// Send message
- this.sendMessage(message, this.activityMessageProducer);
+ this.sendMessage(message);
} catch (final JMSException ex) {
// Throw again
throw new EJBException(ex);
@SuppressWarnings ("unchecked")
public List<LogableUserActivity> fetchAllUsersActivityLogByMultipleType (final User user, final String[] activityTypes) {
// Trace message
- this.getLoggerBeanLocal().logTrace(MessageFormat.format("{0}.fetchAllUsersActivityLogByType: user={1},activityTypes={2} - CALLED!", this.getClass().getSimpleName(), user, activityTypes)); //NOI18N
+ this.getLoggerBeanLocal().logTrace(MessageFormat.format("{0}.fetchAllUsersActivityLogByType: user={1},activityTypes={2} - CALLED!", this.getClass().getSimpleName(), user, Arrays.toString(activityTypes))); //NOI18N
// Is user valid?
if (null == user) {