X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2Forg%2Fmxchange%2Fjcoreee%2Fdatabase%2FBaseDatabaseBean.java;h=07e54ae2a5224b37b75d68c29bcfb639da4669ec;hb=9822626f10b3b2d14cc994f7af09e13ec9522fde;hp=c1c8e54cf3621c9ab9f94f6e269e18bad7ffc578;hpb=1c49ae234e12bc815f83ed0e1159e67aab7ffef1;p=jcore-utils.git diff --git a/src/org/mxchange/jcoreee/database/BaseDatabaseBean.java b/src/org/mxchange/jcoreee/database/BaseDatabaseBean.java index c1c8e54..07e54ae 100644 --- a/src/org/mxchange/jcoreee/database/BaseDatabaseBean.java +++ b/src/org/mxchange/jcoreee/database/BaseDatabaseBean.java @@ -1,5 +1,5 @@ /* - * Copyright (C) 2015 Roland Haeder + * Copyright (C) 2016 Roland Haeder * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by @@ -17,6 +17,10 @@ package org.mxchange.jcoreee.database; import java.io.Serializable; +import java.text.MessageFormat; +import javax.jms.JMSException; +import javax.jms.MessageProducer; +import javax.jms.ObjectMessage; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; @@ -61,7 +65,7 @@ public abstract class BaseDatabaseBean implements Serializable { this.loggerBeanLocal = (LoggerBeanLocal) context.lookup("java:global/jcore-logger-ejb/logger!org.mxchange.jcoreeelogger.beans.local.logger.LoggerBeanLocal"); //NOI18N } catch (final NamingException ex) { // Continue to throw - throw new RuntimeException("context.lookup() failed.", ex); //NOI18N + throw new RuntimeException(MessageFormat.format("context.lookup() failed: {0}", ex.getMessage()), ex); //NOI18N } } @@ -82,4 +86,33 @@ public abstract class BaseDatabaseBean implements Serializable { protected LoggerBeanLocal getLoggerBeanLocal () { return this.loggerBeanLocal; } + + /** + * Sends given message to configured queue + *
+ * @param message Message to send + * @param messageProducer Message producer + *
+ * @throws JMSException if something went wrong + */ + protected void sendMessage (final ObjectMessage message, final MessageProducer messageProducer) throws JMSException { + // Trace message + this.getLoggerBeanLocal().logTrace(MessageFormat.format("{0}.sendMessage: message={1},messageProducer={2} - CALLED!", this.getClass().getSimpleName(), message, messageProducer)); //NOI18N + + // The parameter should be valid + if (null == message) { + // Throw NPE + throw new NullPointerException("message is null"); //NOI18N + } else if (null == messageProducer) { + // Throw NPE again + throw new NullPointerException("messageProvider is null"); //NOI18N + } + + // Send it + messageProducer.send(message); + + // Trace message + this.getLoggerBeanLocal().logTrace(MessageFormat.format("{0}.sendMessage: EXIT!", this.getClass().getSimpleName())); //NOI18N + } + }