[servicemix-scm] Generate new exchanges ids for messages dispatched to subscribers

[gnt]

Commit in servicemix/base/src/main/java/org/servicemix/jbi/nmr on MAIN
SubscriptionManager.java	+3		1.3 -> 1.4

Generate new exchanges ids for messages dispatched to subscribers

---

servicemix/base/src/main/java/org/servicemix/jbi/nmr

SubscriptionManager.java 1.3 -> 1.4

diff -u -r1.3 -r1.4
--- SubscriptionManager.java	22 Sep 2005 18:17:58 -0000	1.3
+++ SubscriptionManager.java	5 Oct 2005 16:51:44 -0000	1.4
@@ -17,6 +17,7 @@

  **/
 package org.servicemix.jbi.nmr;
 

+import org.activemq.util.IdGenerator;

 import org.servicemix.jbi.framework.Registry;
 import org.servicemix.jbi.messaging.ExchangePacket;
 import org.servicemix.jbi.messaging.MessageExchangeImpl;

@@ -39,6 +40,7 @@

     private Registry registry;
     private String flowName = "seda";
     private Flow flow;

+    private IdGenerator idGenerator = new IdGenerator();

 
     /**
      * Initialize the SubscriptionManager

@@ -79,6 +81,7 @@

      */
     protected void dispatchToSubscriber(MessageExchangeImpl exchange, ServiceEndpointImpl endpoint) throws JBIException {
         ExchangePacket packet = exchange.getPacket().copy();

+        packet.setExchangeId(idGenerator.generateId());

         packet.setEndpoint(endpoint);
         packet.setDestinationId(endpoint.getComponentNameSpace());
         flow.send(packet);

CVSspam 0.2.8