[jboss-svn-commits] JBL Code SVN: r12422 - labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway.

[jboss-svn-commits at lists.jboss.org]

Author: tcunning
Date: 2007-06-08 13:22:29 -0400 (Fri, 08 Jun 2007)
New Revision: 12422

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/HibernateEventListener.java
Log:
bug:JBESB-434
Remove references to HibernateConn.


Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/HibernateEventListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/HibernateEventListener.java	2007-06-08 17:20:59 UTC (rev 12421)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/HibernateEventListener.java	2007-06-08 17:22:29 UTC (rev 12422)
@@ -21,7 +21,6 @@
  */
 package org.jboss.soa.esb.listeners.gateway;
 
-import java.io.Serializable;
 import java.util.Map;
 import java.util.Set;
 import java.util.concurrent.BlockingQueue;
@@ -30,19 +29,14 @@
 import org.apache.log4j.Logger;
 import org.hibernate.HibernateException;
 import org.hibernate.event.*;
-import org.jboss.soa.esb.ConfigurationException;
-import org.jboss.soa.esb.helpers.ConfigTree;
-import org.jboss.soa.esb.helpers.persist.HibernateConn;
 
-import org.jboss.soa.esb.listeners.message.AbstractMessageComposer;
-import org.jboss.soa.esb.listeners.message.MessageDeliverException;
-import org.jboss.soa.esb.message.Message;
-
 /**
  * This class is a Hibernate EventListener which implements hooks to all the available
  * hibernate events.   It's not used at the moment, but might be a way of augmenting  
  * the Hibernate Interceptor hooks which are currently implemented.
  * 
+ * Again, please note that this file is not currently used.
+ * 
  * @author <a href="mailto:tcunning at redhat.com">tcunning at redhat.com</a>
  */
 public class HibernateEventListener implements 
@@ -70,7 +64,6 @@
 								SaveOrUpdateEventListener {
 
 	private static final long serialVersionUID = 7125882028251049616L;
-	protected HibernateConn m_conn;
 	protected final static Logger m_logger = Logger.getLogger(HibernateEventListener.class);
 	
 	public HibernateEventListener() {
@@ -132,79 +125,6 @@
 		
 	}
 	
-	/// hibernate message composer
-	public static class HibernateMessageComposer extends AbstractMessageComposer {
-		
-		@Override
-		protected void populateMessage(Message message, Object obj) throws MessageDeliverException {
-			Object instanceObj = null;
-			String entityName = null;
-			Serializable entityId = null;
-			Object result = null;
-			EventSource source = null;
-			Serializable requestId = null;
-			String type = null;
-			
-			
-			if(obj instanceof DeleteEvent) {
-				DeleteEvent devent = (DeleteEvent)obj;
-				entityName =  devent.getEntityName();
-				instanceObj  = devent.getObject();
-				source = devent.getSession();
-				type = "delete";
-			} else if (obj instanceof SaveOrUpdateEvent) {
-				SaveOrUpdateEvent sevent = (SaveOrUpdateEvent) obj;
-				entityName = sevent.getEntityName();
-				instanceObj = sevent.getObject();
-				source = sevent.getSession();
-				entityId = sevent.getResultId();
-				requestId = sevent.getRequestedId();
-				type = "saveOrUpdate";
-			} else if (obj instanceof LoadEvent) {
-				LoadEvent levent = (LoadEvent)obj;
-				instanceObj = levent.getInstanceToLoad();
-				entityName = levent.getEntityClassName();
-				entityId = levent.getEntityId();
-				result = levent.getResult();
-				source = levent.getSession();
-				type = "load";
-			}
-			
-
-
-			if(source != null) 
-				message.getProperties().setProperty("eventSource",source);
-			if(instanceObj != null) 
-				message.getProperties().setProperty("objectInstance",instanceObj);
-			if(entityId != null) 
-				message.getProperties().setProperty("entityId",entityId);
-			if(requestId != null) 
-					message.getProperties().setProperty("requestId",requestId);
-			if(entityName != null) 
-				message.getProperties().setProperty("entityName",entityName);
-			if(type != null) 
-				message.getProperties().setProperty("type",type);
-		}
-
-		public void setConfiguration(ConfigTree config) {
-		}
-		
-	}
-	
-	/**
-	 * Obtain a new database connection with parameter info
-	 * 
-	 * @return A new connection
-	 * @throws ConfigurationException -
-	 *             if problems are encountered
-	 */
-	protected HibernateConn getHibernateConn()
-	{
-		if (null == m_conn) {	
-		}
-		return m_conn;
-	}
-
 	public void onDelete(DeleteEvent arg0, Set arg1) throws HibernateException {
 		System.out.println("HibernateEventLister!");
 		m_logger.error("onDelete");