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
+	 * <p>
+	 * @param message Message to send
+	 * @param messageProducer Message producer
+	 * <p>
+	 * @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
+	}
+
 }