Migrate to odlparent 2.0.0

[groupbasedpolicy.git] / sxp-integration / sxp-ep-provider / src / main / java / org / opendaylight / groupbasedpolicy / sxp / ep / provider / impl / SxpMapperReactorImpl.java

diff --git a/sxp-integration/sxp-ep-provider/src/main/java/org/opendaylight/groupbasedpolicy/sxp/ep/provider/impl/SxpMapperReactorImpl.java b/sxp-integration/sxp-ep-provider/src/main/java/org/opendaylight/groupbasedpolicy/sxp/ep/provider/impl/SxpMapperReactorImpl.java
index 17a9b4f4eb57eaa33d4ae70093a93d52e63c4071..aee5271b4c265a4359e8e62870a990d21c485cf5 100644 (file)
--- a/sxp-integration/sxp-ep-provider/src/main/java/org/opendaylight/groupbasedpolicy/sxp/ep/provider/impl/SxpMapperReactorImpl.java
+++ b/sxp-integration/sxp-ep-provider/src/main/java/org/opendaylight/groupbasedpolicy/sxp/ep/provider/impl/SxpMapperReactorImpl.java
@@ -110,7 +110,7 @@ public class SxpMapperReactorImpl implements SxpMapperReactor {
         CheckedFuture<Optional<AddressEndpoint>, ReadFailedException> existingEndpointFuture =
                 findExistingEndPoint(addressEndpoint.getContextId(), addressEndpoint.getAddress());
 
-        return Futures.transform(existingEndpointFuture, new AsyncFunction<Optional<AddressEndpoint>, RpcResult<Void>>() {
+        return Futures.transformAsync(existingEndpointFuture, new AsyncFunction<Optional<AddressEndpoint>, RpcResult<Void>>() {
             @Override
             public ListenableFuture<RpcResult<Void>> apply(final Optional<AddressEndpoint> input) throws Exception {
                 final ListenableFuture<RpcResult<Void>> nextResult;