import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.MoreExecutors;
-import javax.annotation.Nonnull;
import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
import org.opendaylight.openflowplugin.impl.services.multilayer.MultiLayerMeterService;
Futures.addCallback(resultFuture, new FutureCallback<RpcResult<AddMeterOutput>>() {
@Override
- public void onSuccess(@Nonnull RpcResult<AddMeterOutput> result) {
+ public void onSuccess(RpcResult<AddMeterOutput> result) {
if (result.isSuccessful()) {
if (LOG.isDebugEnabled()) {
LOG.debug("Meter add with id={} finished without error", input.getMeterId());
@Override
public void onFailure(Throwable throwable) {
- LOG.warn("Service call for adding meter={} failed, reason: {}", input.getMeterId(), throwable);
+ LOG.warn("Service call for adding meter={} failed", input.getMeterId(), throwable);
}
}, MoreExecutors.directExecutor());
return resultFuture;
: updateMeter.handleServiceCall(input.getUpdatedMeter());
Futures.addCallback(resultFuture, new FutureCallback<RpcResult<UpdateMeterOutput>>() {
-
@Override
- public void onSuccess(@Nonnull RpcResult<UpdateMeterOutput> result) {
+ public void onSuccess(RpcResult<UpdateMeterOutput> result) {
if (result.isSuccessful()) {
if (LOG.isDebugEnabled()) {
LOG.debug("Meter update with id={} finished without error",
@Override
public void onFailure(Throwable throwable) {
- LOG.warn("Service call for updating meter={} failed, reason: {}",
+ LOG.warn("Service call for updating meter={} failed",
input.getOriginalMeter().getMeterId(), throwable);
}
}, MoreExecutors.directExecutor());
Futures.addCallback(resultFuture, new FutureCallback<RpcResult<RemoveMeterOutput>>() {
@Override
- public void onSuccess(@Nonnull RpcResult<RemoveMeterOutput> result) {
+ public void onSuccess(RpcResult<RemoveMeterOutput> result) {
if (result.isSuccessful()) {
if (LOG.isDebugEnabled()) {
LOG.debug("Meter remove with id={} finished without error", input.getMeterId());
@Override
public void onFailure(Throwable throwable) {
- LOG.warn("Service call for removing meter={} failed, reason: {}", input.getMeterId(), throwable);
+ LOG.warn("Service call for removing meter={} failed", input.getMeterId(), throwable);
}
}, MoreExecutors.directExecutor());
return resultFuture;