You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by ff...@apache.org on 2008/03/07 04:07:50 UTC
svn commit: r634509 -
/servicemix/smx3/branches/servicemix-3.2/deployables/bindingcomponents/servicemix-cxf-bc/src/main/java/org/apache/servicemix/cxfbc/CxfBcConsumer.java
Author: ffang
Date: Thu Mar 6 19:07:47 2008
New Revision: 634509
URL: http://svn.apache.org/viewvc?rev=634509&view=rev
Log:
[SM-1221]make cxf bc timeout configurable
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=634509&r1=634508&r2=634509&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 Thu Mar 6 19:07:47 2008
@@ -131,6 +131,8 @@
private boolean mtomEnabled;
private String locationURI;
+
+ private int timeout = 10;
/**
* @return the wsdl
@@ -446,7 +448,7 @@
if (CxfBcConsumer.this.synchronous
&& !CxfBcConsumer.this.isOneway) {
message.getInterceptorChain().pause();
- context.getDeliveryChannel().sendSync(exchange, 10000);
+ context.getDeliveryChannel().sendSync(exchange, timeout * 1000);
process(exchange);
} else {
context.getDeliveryChannel().send(exchange);
@@ -591,6 +593,14 @@
public boolean isMtomEnabled() {
return mtomEnabled;
+ }
+
+ public void setTimeout(int timeout) {
+ this.timeout = timeout;
+ }
+
+ public int getTimeout() {
+ return timeout;
}
}