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

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

Author: estebanschifman
Date: 2006-10-15 23:12:44 -0400 (Sun, 15 Oct 2006)
New Revision: 6815

Modified:
   labs/jbossesb/workspace/eschifman/trunk/product/core/listeners/src/org/jboss/soa/esb/message/listeners/ListenerPropertyNames.java
   labs/jbossesb/workspace/eschifman/trunk/product/core/listeners/src/org/jboss/soa/esb/message/listeners/MockAction.java
Log:
Add some methods to MockExample class and illustrate with xml configuration files

Modified: labs/jbossesb/workspace/eschifman/trunk/product/core/listeners/src/org/jboss/soa/esb/message/listeners/ListenerPropertyNames.java
===================================================================
--- labs/jbossesb/workspace/eschifman/trunk/product/core/listeners/src/org/jboss/soa/esb/message/listeners/ListenerPropertyNames.java	2006-10-16 02:51:45 UTC (rev 6814)
+++ labs/jbossesb/workspace/eschifman/trunk/product/core/listeners/src/org/jboss/soa/esb/message/listeners/ListenerPropertyNames.java	2006-10-16 03:12:44 UTC (rev 6815)
@@ -3,9 +3,7 @@
 public class ListenerPropertyNames 
 {
 	public static final String EPR_NAME			= "epr-name";
-	public static final String CONSUMER_TYPE	= "consumer-type";
 	public static final String JNDI_TYPE		= "jndi-type";
     public static final String JNDI_URL 		= "jndi-URL";
     public static final String MESSAGE_SELECTOR	= "message-selector";
-    public static final String ACTION_DEFINITION_FACTORY = "action-definition-factory";
 }

Modified: labs/jbossesb/workspace/eschifman/trunk/product/core/listeners/src/org/jboss/soa/esb/message/listeners/MockAction.java
===================================================================
--- labs/jbossesb/workspace/eschifman/trunk/product/core/listeners/src/org/jboss/soa/esb/message/listeners/MockAction.java	2006-10-16 02:51:45 UTC (rev 6814)
+++ labs/jbossesb/workspace/eschifman/trunk/product/core/listeners/src/org/jboss/soa/esb/message/listeners/MockAction.java	2006-10-16 03:12:44 UTC (rev 6815)
@@ -27,7 +27,8 @@
 import org.apache.log4j.Logger;
 import org.jboss.soa.esb.actions.ActionUtils;
 import org.jboss.soa.esb.message.Message;
-import org.jboss.soa.esb.helpers.ConfigTree;
+import org.jboss.soa.esb.helpers.*;
+import org.jboss.soa.esb.notification.*;
 
 
 /**
@@ -40,11 +41,15 @@
  */
 public class MockAction
 {
-
-    public MockAction(ConfigTree config) {}
+	protected Message 		_message;
+	protected ConfigTree	_config;
+	
+    public MockAction(ConfigTree config) { _config = config; } 
+    public Message noOperation(Message message) { return message; } 
     
     public Message process(Message message) 
     {
+    	_message = message;
     	Object oCurr = ActionUtils.getTaskObject(message);
     	if (null==oCurr)
     		oCurr = "null";
@@ -52,6 +57,17 @@
         return message;
     } // ________________________________
 
+
+    public Message process222(Message message) 
+    {
+    	_message = message;
+    	Object oCurr = ActionUtils.getTaskObject(message);
+    	if (null==oCurr)
+    		oCurr = "null";
+        _logger.info(getStamp()+" process222 was called with <<" + oCurr.toString() + ">>");
+        return message;
+    } // ________________________________
+
     private static final SimpleDateFormat s_oTS 
     	= new SimpleDateFormat("yyyy/MM/dd hh:mm:ss.SSS");
 
@@ -59,5 +75,52 @@
     	{ return s_oTS.format(new java.util.Date(System.currentTimeMillis())); }
 
     private static Logger _logger = Logger.getLogger(MockAction.class);
+    
+    public void myOkMethod1()
+    {
+    	String sMsg = new StringBuilder(getStamp())
+    	.append(" MockAction.myOkMethod1 was called ")
+    	.append(_message)
+    	.toString();
+    	_logger.info(sMsg);
+    	@SuppressWarnings("unused") 
+    	NotificationList nl = ActionUtils.getNotifyList(_config,"ok");
+    	// Here you can send notifications to everybody
+    }
 
+    public void myMethod2()
+    {
+    	String sMsg = new StringBuilder(getStamp())
+    	.append(" Method2 Method2 Method2 Method2 Method2  CALLED ")
+    	.append(_message)
+    	.toString();
+    	_logger.info(sMsg);
+    	@SuppressWarnings("unused") 
+    	NotificationList nl = ActionUtils.getNotifyList(_config,"ok");
+    	// Here you can send notifications to everybody
+    }
+
+    public Message justThrow(Message message) throws Exception 
+    {
+    	throw new MockException("Mock exception thrown at "+getStamp());
+    } // ________________________________
+    
+    @SuppressWarnings("serial")
+	private class MockException extends Exception
+    {
+    	MockException(String str) { super(str); }
+    }
+
+    public void exceptionCallback1(Exception e)
+    {
+    	String sMsg = new StringBuilder(getStamp())
+    	.append(" MockExceptionTrower.exceptionCallback1  CALLED ")
+    	.append(_message)
+    	.toString();
+    	_logger.fatal(sMsg,e);
+    	@SuppressWarnings("unused") 
+    	NotificationList nl = ActionUtils.getNotifyList(_config,"err");
+    	// Here you can send notifications to everybody
+    }
+    
 } // ____________________________________________________________________________