[servicemix-scm] [813] trunk/core/src/main/java/org/servicemix: Add a creation dateStamp on message exchanges

[scm]

Title: [813] trunk/core/src/main/java/org/servicemix: Add a creation dateStamp on message exchanges

Revision

813

Author

gnt

Date

2005-11-13 15:03:21 -0500 (Sun, 13 Nov 2005)

Log Message

Add a creation dateStamp on message exchanges

Modified Paths

• trunk/core/src/main/java/org/servicemix/JbiConstants.java
• trunk/core/src/main/java/org/servicemix/jbi/container/JBIContainer.java
• trunk/core/src/main/java/org/servicemix/jbi/messaging/MessageExchangeFactoryImpl.java

Diff

Modified: trunk/core/src/main/java/org/servicemix/JbiConstants.java (812 => 813)

--- trunk/core/src/main/java/org/servicemix/JbiConstants.java	2005-11-13 11:33:12 UTC (rev 812)
+++ trunk/core/src/main/java/org/servicemix/JbiConstants.java	2005-11-13 20:03:21 UTC (rev 813)
@@ -25,8 +25,10 @@
     
     String PROTOCOL_HEADERS = "javax.jbi.protocol.headers";
     
-    String SECUTIRY_SUBJECT = "javax.jbi.security.subject";
+    String SECURITY_SUBJECT = "javax.jbi.security.subject";
     
 	String PERSISTENT_PROPERTY_NAME = "org.servicemix.persistent";
+    
+    String DATESTAMP_PROPERTY_NAME = "org.servicemix.datestamp";
 	
 }

Modified: trunk/core/src/main/java/org/servicemix/jbi/container/JBIContainer.java (812 => 813)

--- trunk/core/src/main/java/org/servicemix/jbi/container/JBIContainer.java	2005-11-13 11:33:12 UTC (rev 812)
+++ trunk/core/src/main/java/org/servicemix/jbi/container/JBIContainer.java	2005-11-13 20:03:21 UTC (rev 813)
@@ -27,6 +27,7 @@
 import org.apache.commons.logging.LogFactory;
 import org.apache.geronimo.connector.work.GeronimoWorkManager;
 import org.jencks.factory.WorkManagerFactoryBean;
+import org.servicemix.JbiConstants;
 import org.servicemix.MessageExchangeListener;
 import org.servicemix.components.util.ComponentAdaptor;
 import org.servicemix.components.util.ComponentAdaptorMEListener;
@@ -70,6 +71,7 @@
 import javax.xml.namespace.QName;
 
 import java.io.File;
+import java.util.Calendar;
 import java.util.Collection;
 import java.util.Iterator;
 import java.util.List;
@@ -1047,6 +1049,7 @@
         me.getPacket().setFault(null);
         me.getPacket().setError(null);
         me.getPacket().setStatus(ExchangeStatus.ACTIVE);
+        me.getPacket().setProperty(JbiConstants.DATESTAMP_PROPERTY_NAME, Calendar.getInstance());
         callListeners(me);
         me.handleSend(false);
         sendExchange(me.getMirror());

Modified: trunk/core/src/main/java/org/servicemix/jbi/messaging/MessageExchangeFactoryImpl.java (812 => 813)

--- trunk/core/src/main/java/org/servicemix/jbi/messaging/MessageExchangeFactoryImpl.java	2005-11-13 11:33:12 UTC (rev 812)
+++ trunk/core/src/main/java/org/servicemix/jbi/messaging/MessageExchangeFactoryImpl.java	2005-11-13 20:03:21 UTC (rev 813)
@@ -22,6 +22,7 @@
 import edu.emory.mathcs.backport.java.util.concurrent.atomic.AtomicBoolean;
 
 import org.activemq.util.IdGenerator;
+import org.servicemix.JbiConstants;
 import org.servicemix.jbi.framework.ComponentContextImpl;
 
 import javax.jbi.messaging.InOnly;
@@ -35,6 +36,7 @@
 import javax.xml.namespace.QName;
 
 import java.net.URI;
+import java.util.Calendar;
 
 /**
  * Resolver for URI patterns
@@ -261,5 +263,6 @@
         if (marshaler != null) {
             exchange.setMarshaler(marshaler);
         }
+        exchange.setProperty(JbiConstants.DATESTAMP_PROPERTY_NAME, Calendar.getInstance());
     }
 }
\ No newline at end of file