You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by ay...@apache.org on 2013/04/16 16:31:54 UTC
svn commit: r1468437 - in /cxf/branches/2.7.x-fixes: ./
rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java
Author: ay
Date: Tue Apr 16 14:31:54 2013
New Revision: 1468437
URL: http://svn.apache.org/r1468437
Log:
Merged revisions 1468436 via svn merge from
https://svn.apache.org/repos/asf/cxf/trunk
........
r1468436 | ay | 2013-04-16 16:29:09 +0200 (Tue, 16 Apr 2013) | 1 line
[CXF-4964] NPE is thrown when WS-RM's destination has no ackPolicy configured
........
Modified:
cxf/branches/2.7.x-fixes/ (props changed)
cxf/branches/2.7.x-fixes/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java
Propchange: cxf/branches/2.7.x-fixes/
('svn:mergeinfo' removed)
Propchange: cxf/branches/2.7.x-fixes/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: cxf/branches/2.7.x-fixes/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java
URL: http://svn.apache.org/viewvc/cxf/branches/2.7.x-fixes/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java?rev=1468437&r1=1468436&r2=1468437&view=diff
==============================================================================
--- cxf/branches/2.7.x-fixes/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java (original)
+++ cxf/branches/2.7.x-fixes/rt/ws/rm/src/main/java/org/apache/cxf/ws/rm/DestinationSequence.java Tue Apr 16 14:31:54 2013
@@ -401,7 +401,7 @@ public class DestinationSequence extends
void scheduleAcknowledgement(long acknowledgementInterval) {
AcksPolicyType ap = destination.getManager().getDestinationPolicy().getAcksPolicy();
- if (acknowledgementInterval > 0 && getMonitor().getMPM() >= ap.getIntraMessageThreshold()) {
+ if (acknowledgementInterval > 0 && getMonitor().getMPM() >= (ap == null ? 10 : ap.getIntraMessageThreshold())) {
LOG.fine("Schedule deferred acknowledgment");
scheduleDeferredAcknowledgement(acknowledgementInterval);
} else {
@@ -409,7 +409,7 @@ public class DestinationSequence extends
scheduleImmediateAcknowledgement();
destination.getManager().getTimer().schedule(
- new ImmediateFallbackAcknowledgment(), ap.getImmediaAcksTimeout());
+ new ImmediateFallbackAcknowledgment(), ap == null ? 1000L : ap.getImmediaAcksTimeout());
}
}