svn commit: r612805 - in /incubator/qpid/trunk/qpid: cpp/src/qpid/broker/SemanticState.cpp python/tests_0-10/message.py

[gsim]

Author: gsim
Date: Thu Jan 17 05:04:56 2008
New Revision: 612805

URL: http://svn.apache.org/viewvc?rev=612805&view=rev
Log:
Set the exchange field in delivery properties on the broker.
(required an adjustment to the size of messages in the bytes based credit test)


Modified:
    incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp
    incubator/qpid/trunk/qpid/python/tests_0-10/message.py

Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp?rev=612805&r1=612804&r2=612805&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/SemanticState.cpp Thu Jan 17 
05:04:56 2008
@@ -350,6 +350,7 @@
 
 void SemanticState::route(intrusive_ptr<Message> msg, Deliverable& strategy) {
     std::string exchangeName = msg->getExchangeName();      
+    msg->getProperties<DeliveryProperties>()->setExchange(exchangeName);
     if (!cacheExchange || cacheExchange->getName() != exchangeName){
         cacheExchange = 
session.getConnection().broker.getExchanges().get(exchangeName);
     }

Modified: incubator/qpid/trunk/qpid/python/tests_0-10/message.py
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/tests_0-10/message.py?rev=612805&r1=612804&r2=612805&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/tests_0-10/message.py (original)
+++ incubator/qpid/trunk/qpid/python/tests_0-10/message.py Thu Jan 17 05:04:56 
2008
@@ -480,7 +480,7 @@
             channel.message_transfer(content=Content(properties={'routing_key' 
: "q"}, body = "abcdefgh"))
 
         #each message is currently interpreted as requiring msg_size bytes of 
credit
-        msg_size = 34
+        msg_size = 35
 
         #set byte credit to finite amount (less than enough for all messages)
         channel.message_flow(unit = 1, value = msg_size*5, destination = "c")