[abdera-transport-dev] [69] trunk/src/main/java/org/mule/transport/abdera/filters/FeedLastUpdatedFilter.java: tweek

[ross-32]

Some parts of this message have been removed. Learn more about Nabble's security policy.

Revision

69

Author

ross

Date

2009-11-05 18:02:46 -0600 (Thu, 05 Nov 2009)

Log Message

tweek

Modified Paths

• trunk/src/main/java/org/mule/transport/abdera/filters/FeedLastUpdatedFilter.java

Diff

Modified: trunk/src/main/java/org/mule/transport/abdera/filters/FeedLastUpdatedFilter.java (68 => 69)

--- trunk/src/main/java/org/mule/transport/abdera/filters/FeedLastUpdatedFilter.java	2009-11-05 17:53:42 UTC (rev 68)
+++ trunk/src/main/java/org/mule/transport/abdera/filters/FeedLastUpdatedFilter.java	2009-11-06 00:02:46 UTC (rev 69)
@@ -10,7 +10,10 @@
 package org.mule.transport.abdera.filters;
 
 import org.mule.api.MuleMessage;
+import org.mule.api.MuleRuntimeException;
+import org.mule.api.transformer.TransformerException;
 import org.mule.api.routing.filter.Filter;
+import org.mule.config.i18n.CoreMessages;
 
 import java.util.Date;
 
@@ -21,7 +24,7 @@
 
 /**
  * Will filter a feed who's update date has changed since the last time it was read.  Some feeds to no update
- * this value so {@link #setAcceptWithoutUpdateDate(boolean)} can be set to always consume the feed 
+ * this value so {@link #setAcceptWithoutUpdateDate(boolean)} can be set to always consume the feed
  */
 public class FeedLastUpdatedFilter implements Filter
 {
@@ -45,11 +48,20 @@
 
     public boolean accept(MuleMessage message)
     {
-        Feed feed = (Feed) message.getPayload();
+        Feed feed;
+        try
+        {
+            feed = message.getPayload(Feed.class);
+        }
+        catch (TransformerException e)
+        {
+            throw new MuleRuntimeException(CoreMessages.failedToReadPayload(), e);
+        }
+        
         Date updated = feed.getUpdated();
         if (updated == null)
         {
-            if(isAcceptWithoutUpdateDate())
+            if (isAcceptWithoutUpdateDate())
             {
                 if (logger.isDebugEnabled())
                 {
@@ -80,6 +92,7 @@
         }
         lastUpdate = updated;
         return true;
+
     }
 
     public boolean isAcceptWithoutUpdateDate()

--~--~---------~--~----~------------~-------~--~----~
You received this message because you are subscribed to the Google Groups "MuleForge Dev" group.
To post to this group, send email to muleforgedev@...
To unsubscribe from this group, send email to muleforgedev+unsubscribe@...
For more options, visit this group at http://groups.google.com/group/muleforgedev?hl=en
-~----------~----~----~----~------~----~------~--~---
--------------------------------------------------------------------- To unsubscribe from this list, please visit: http://admin.muleforge.org/manage_email