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

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

Author: estebanschifman
Date: 2006-10-04 14:52:28 -0400 (Wed, 04 Oct 2006)
New Revision: 6603

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/DirectoryPoller.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java
Log:
Fix NPE bug

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/DirectoryPoller.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/DirectoryPoller.java	2006-10-04 18:42:52 UTC (rev 6602)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/DirectoryPoller.java	2006-10-04 18:52:28 UTC (rev 6603)
@@ -197,9 +197,11 @@
      */
     @Override
     protected void processingError(Object currentObject, ActionProcessor processor, Throwable error) {
-        WorkingFile workingFile = (WorkingFile) currentObject;
-        
-        workingFile.renameToError();
+
+    	if (null!=currentObject)
+    	{	WorkingFile workingFile = (WorkingFile) currentObject;
+        	workingFile.renameToError();
+    	}
     }
 
     /* (non-Javadoc)

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java	2006-10-04 18:42:52 UTC (rev 6602)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java	2006-10-04 18:52:28 UTC (rev 6603)
@@ -42,23 +42,15 @@
 public class JmsQueueListener extends AbstractListener {
 
     public static final String LISTEN_QUEUE_CONN_FACT = "queueConnFactoryClass";
-
     public static final String LISTEN_JNDI_TYPE = "listenJndiType";
-
     public static final String LISTEN_JNDI_URL = "listenJndiURL";
-
     public static final String LISTEN_QUEUE = "listenQueue";
-
     public static final String LISTEN_MSG_SELECTOR = "listenMsgSelector";
 
     protected boolean m_bError = false;
-
     protected QueueConnection m_oQconn;
-
     protected QueueSession m_oQsess;
-
     protected Queue m_oQueue;
-
     protected String m_sSelector;
 
     protected MessageConsumer jmsMessageReceiver;