[servicemix-scm] changed the default Role

[rajdavies]

Commit in servicemix/base/src/main/java/org/servicemix/jbi on MAIN
nmr/Broker.java	+6	-1	1.15 -> 1.16
messaging/MessageExchangeImpl.java	+2	-2	1.13 -> 1.14
	+8	-3

2 modified files

changed the default Role

---

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

Broker.java 1.15 -> 1.16

diff -u -r1.15 -r1.16
--- Broker.java	27 Jul 2005 07:35:20 -0000	1.15
+++ Broker.java	2 Aug 2005 16:29:59 -0000	1.16
@@ -51,7 +51,7 @@

 /**
  * The Broker handles Nomalised Message Routing within ServiceMix
  *

- * @version $Revision: 1.15 $

+ * @version $Revision: 1.16 $

  */
 public class Broker  extends BaseLifeCycle {
     private JBIContainer container;

@@ -286,7 +286,12 @@

                 throw new MessagingException("Could not find route for exchange: " + exchange
                         + " for service: " + serviceName + " and interface: " + interfaceName);
             }

+           if (log.isTraceEnabled()){
+               log.trace("routing exchange " + packet + " TO: " + theEndpoint);
+           }
+           System.out.println("routing exchange " + packet + " TO: " + theEndpoint);

         }

+        

         flow.send(packet);
     }
 

---

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

MessageExchangeImpl.java 1.13 -> 1.14

diff -u -r1.13 -r1.14
--- MessageExchangeImpl.java	27 Jul 2005 07:35:20 -0000	1.13
+++ MessageExchangeImpl.java	2 Aug 2005 16:29:59 -0000	1.14
@@ -41,7 +41,7 @@

  * A simple message exchange declaration. This is partial, just giving us enough ME function for the doodle. This
  * doesn't add anything new to the current MessageExchange definition.
  *

- * @version $Revision: 1.13 $

+ * @version $Revision: 1.14 $

  */
 public class MessageExchangeImpl implements MessageExchange, Serializable {
 

@@ -105,7 +105,7 @@

      */
     public void setPacket(ExchangePacket packet){
         this.packet = packet;

-        if (this.packet.getRole()==ExchangePacket.CONSUMER_ROLE){

+        if (this.packet.getRole()==ExchangePacket.PROVIDER_ROLE){

             this.role = Role.PROVIDER;
         }else {
             this.role = Role.CONSUMER;

CVSspam 0.2.8