servicemix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ff...@apache.org
Subject svn commit: r699565 - /servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
Date Sat, 27 Sep 2008 05:58:03 GMT
Author: ffang
Date: Fri Sep 26 22:58:03 2008
New Revision: 699565

URL: http://svn.apache.org/viewvc?rev=699565&view=rev
Log:
[SM-1592]cxf-bc consumer should allow async sending of message exchanges to the NMR

Modified:
    servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java

Modified: servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
URL: http://svn.apache.org/viewvc/servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java?rev=699565&r1=699564&r2=699565&view=diff
==============================================================================
--- servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
(original)
+++ servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
Fri Sep 26 22:58:03 2008
@@ -592,8 +592,9 @@
             message.getExchange().setOneWay(CxfBcConsumer.this.isOneway);
 
             try {
-                if (CxfBcConsumer.this.isSynchronous()
-                        && !CxfBcConsumer.this.isOneway) {
+                if (CxfBcConsumer.this.isOneway) {
+                    context.getDeliveryChannel().send(exchange);
+                } else if (CxfBcConsumer.this.isSynchronous()) {
                     context.getDeliveryChannel().sendSync(exchange,
                             timeout * 1000);
                     process(exchange);



Mime
View raw message