svn commit: r387849 - /incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/quartz/QuartzComponent.java

[gn...@apache.org]

Author: gnodet
Date: Wed Mar 22 04:45:31 2006
New Revision: 387849

URL: http://svn.apache.org/viewcvs?rev=387849&view=rev
Log:
SM-360: Quartz component will stop sending messages after a certain amount of time

Modified:
    incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/quartz/QuartzComponent.java

Modified: incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/quartz/QuartzComponent.java
URL: http://svn.apache.org/viewcvs/incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/quartz/QuartzComponent.java?rev=387849&r1=387848&r2=387849&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/quartz/QuartzComponent.java (original)
+++ incubator/servicemix/trunk/servicemix-components/src/main/java/org/apache/servicemix/components/quartz/QuartzComponent.java Wed Mar 22 04:45:31 2006
@@ -17,6 +17,7 @@
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.servicemix.MessageExchangeListener;
 import org.apache.servicemix.components.util.ComponentSupport;
 import org.quartz.JobDetail;
 import org.quartz.JobExecutionContext;
@@ -29,6 +30,7 @@
 
 import javax.jbi.JBIException;
 import javax.jbi.messaging.InOnly;
+import javax.jbi.messaging.MessageExchange;
 import javax.jbi.messaging.MessagingException;
 import javax.jbi.messaging.NormalizedMessage;
 import java.util.Date;
@@ -40,7 +42,7 @@
  *
  * @version $Revision$
  */
-public class QuartzComponent extends ComponentSupport {
+public class QuartzComponent extends ComponentSupport implements MessageExchangeListener {
     private static final transient Log log = LogFactory.getLog(QuartzComponent.class);
 
     public static final String COMPONENT_KEY = "org.apache.servicemix.component";
@@ -199,6 +201,11 @@
                 addTrigger((Trigger) key, (JobDetail) value);
             }
         }
+    }
+
+    public void onMessageExchange(MessageExchange exchange) throws MessagingException {
+        // As we send in-only MEPS, we will only
+        // receive DONE or ERROR status
     }
 
 }