Author: coheigea
Date: Fri Oct 12 13:06:40 2012
New Revision: 1397553
URL: http://svn.apache.org/viewvc?rev=1397553&view=rev
Log:
Backporting specific fix
Modified:
cxf/branches/2.6.x-fixes/services/wsn/wsn-core/src/main/java/org/apache/cxf/wsn/AbstractNotificationBroker.java
Modified:
cxf/branches/2.6.x-fixes/services/wsn/wsn-core/src/main/java/org/apache/cxf/wsn/AbstractNotificationBroker.java
URL:
http://svn.apache.org/viewvc/cxf/branches/2.6.x-fixes/services/wsn/wsn-core/src/main/java/org/apache/cxf/wsn/AbstractNotificationBroker.java?rev=1397553&r1=1397552&r2=1397553&view=diff
==============================================================================
---
cxf/branches/2.6.x-fixes/services/wsn/wsn-core/src/main/java/org/apache/cxf/wsn/AbstractNotificationBroker.java
(original)
+++
cxf/branches/2.6.x-fixes/services/wsn/wsn-core/src/main/java/org/apache/cxf/wsn/AbstractNotificationBroker.java
Fri Oct 12 13:06:40 2012
@@ -251,7 +251,9 @@ public abstract class AbstractNotificati
throw new SubscribeCreationFailedFault("Unable to register new
endpoint", fault, e);
} finally {
if (!success && subscription != null) {
- subscriptions.remove(subscription);
+ if (subscription.getAddress() != null) {
+ subscriptions.remove(subscription.getAddress());
+ }
try {
subscription.unsubscribe();
} catch (UnableToDestroySubscriptionFault e) {
