Change-Id: I8f9fd184428378e3039ac6d3ab5345f2456ccc9f
Signed-off-by: Jozef Gloncak <jgloncak@cisco.com>
final SettableFuture<RpcResult<SetConfigOutput>> settableFuture = SettableFuture.create();
final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetConfigInput setConfigInput = builder.build();
outboundQueue.commitEntry(xid.getValue(), setConfigInput, new FutureCallback<OfHeader>() {
final SettableFuture<RpcResult<SetConfigOutput>> settableFuture = SettableFuture.create();
final org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.SetConfigInput setConfigInput = builder.build();
outboundQueue.commitEntry(xid.getValue(), setConfigInput, new FutureCallback<OfHeader>() {
+
+ RpcResultBuilder<SetConfigOutput> rpcResultBuilder;
@Override
public void onSuccess(final OfHeader ofHeader) {
@Override
public void onSuccess(final OfHeader ofHeader) {
+ rpcResultBuilder = RpcResultBuilder.<SetConfigOutput>success();
+ requestContext.setResult(rpcResultBuilder.build());
RequestContextUtil.closeRequstContext(requestContext);
RequestContextUtil.closeRequstContext(requestContext);
- getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_SUCCESS);
- settableFuture.set(RpcResultBuilder.<SetConfigOutput>success().build());
+ getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_SUCCESS);
}
@Override
public void onFailure(final Throwable throwable) {
}
@Override
public void onFailure(final Throwable throwable) {
- RpcResultBuilder<SetConfigOutput> rpcResultBuilder = RpcResultBuilder.<SetConfigOutput>failed().withError(RpcError.ErrorType.APPLICATION, throwable.getMessage(), throwable);
+ rpcResultBuilder = RpcResultBuilder.<SetConfigOutput>failed().withError(RpcError.ErrorType.APPLICATION, throwable.getMessage(), throwable);
+ requestContext.setResult(rpcResultBuilder.build());
RequestContextUtil.closeRequstContext(requestContext);
RequestContextUtil.closeRequstContext(requestContext);
getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_FAILURE);
getMessageSpy().spyMessage(setConfigInput.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.TO_SWITCH_SUBMIT_FAILURE);
- settableFuture.set(rpcResultBuilder.build());
+ return requestContext.getFuture();