*/\r
package org.opendaylight.nemo.user;\r
\r
-import com.google.common.util.concurrent.Futures;\r
+import static org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.nemo.intent.rev151010.CommonRpcResult.ResultCode.Error; \r
+import static org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.nemo.intent.rev151010.CommonRpcResult.ResultCode.Ok; \r
+\r
import org.opendaylight.controller.md.sal.binding.api.DataBroker;\r
import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.RpcRegistration;\r
import org.opendaylight.controller.sal.binding.api.RpcProviderRegistry;\r
\r
rpcRegistration = rpcProviderRegistry.addRpcImplementation(NemoIntentService.class, this);\r
}\r
+\r
@Override\r
public Future<RpcResult<AdvancedNemoQueryOutput>> advancedNemoQuery(AdvancedNemoQueryInput input) {\r
- RpcResult<AdvancedNemoQueryOutput> advancedNemoQueryOutputRpcResult = null;\r
- AdvancedNemoQueryOutputBuilder advancedNemoQueryOutputBuilder = new AdvancedNemoQueryOutputBuilder();\r
+ final AdvancedNemoQueryOutputBuilder outputBuilder = new AdvancedNemoQueryOutputBuilder();\r
\r
String errorInfo = advancedQuery.advancedQuery(aaa, input);\r
if (errorInfo != null)\r
{\r
- advancedNemoQueryOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage(errorInfo);\r
+ outputBuilder.setResultCode(Error).setMessage(errorInfo);\r
}\r
else\r
{\r
- advancedNemoQueryOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Ok).setMessage(advancedQuery.getAdvancedQueryReuslt(input));\r
+ outputBuilder.setResultCode(Ok).setMessage(advancedQuery.getAdvancedQueryReuslt(input));\r
}\r
- advancedNemoQueryOutputRpcResult = RpcResultBuilder.<AdvancedNemoQueryOutput>success(advancedNemoQueryOutputBuilder.build()).build();\r
\r
- return Futures.immediateFuture(advancedNemoQueryOutputRpcResult);\r
+ return RpcResultBuilder.success(outputBuilder).buildFuture();\r
}\r
\r
@Override\r
public Future<RpcResult<BeginTransactionOutput>> beginTransaction(BeginTransactionInput input) {\r
- RpcResult<BeginTransactionOutput> beginTransactionOutputResult = null;\r
- BeginTransactionOutputBuilder beginTransactionOutputBuilder = new BeginTransactionOutputBuilder();\r
+ final BeginTransactionOutputBuilder outputBuilder = new BeginTransactionOutputBuilder();\r
\r
if (transaction)\r
{\r
- beginTransactionOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage("The previous transaction has not been finished.");\r
+ outputBuilder.setResultCode(Error).setMessage("The previous transaction has not been finished.");\r
}\r
else\r
{\r
String errorInfo = transactionBegin.transactionbegin(aaa,input);\r
if (errorInfo != null)\r
{\r
- beginTransactionOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage(errorInfo);\r
+ outputBuilder.setResultCode(Error).setMessage(errorInfo);\r
}\r
else\r
{\r
transaction = true;\r
- beginTransactionOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Ok).setMessage("Transaction Begin.");\r
+ outputBuilder.setResultCode(Ok).setMessage("Transaction Begin.");\r
}\r
}\r
- beginTransactionOutputResult = RpcResultBuilder.<BeginTransactionOutput>success(beginTransactionOutputBuilder.build()).build();\r
- return Futures.immediateFuture(beginTransactionOutputResult);\r
+\r
+ return RpcResultBuilder.success(outputBuilder).buildFuture();\r
}\r
\r
@Override\r
public Future<RpcResult<EndTransactionOutput>> endTransaction(EndTransactionInput input) {\r
- RpcResult<EndTransactionOutput> endTransactionOutputResult = null;\r
- EndTransactionOutputBuilder endTransactionOutputBuilder = new EndTransactionOutputBuilder();\r
+ final EndTransactionOutputBuilder outputBuilder = new EndTransactionOutputBuilder();\r
\r
if (!transaction)\r
{\r
- endTransactionOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage("The transaction has not started.");\r
+ outputBuilder.setResultCode(Error).setMessage("The transaction has not started.");\r
}\r
else\r
{\r
String errorInfo = transactionEnd.transactionend(aaa,input);\r
if (errorInfo != null)\r
{\r
- endTransactionOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage(errorInfo);\r
+ outputBuilder.setResultCode(Error).setMessage(errorInfo);\r
}\r
else\r
{\r
try\r
{\r
intentResolver.resolveIntent(input.getUserId());\r
- endTransactionOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Ok).setMessage("The transaction ends.");\r
+ outputBuilder.setResultCode(Ok).setMessage("The transaction ends.");\r
}\r
catch (IntentResolutionException | VNMappingException e)\r
{\r
e.printStackTrace();\r
- endTransactionOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage(e.getMessage());\r
+ outputBuilder.setResultCode(Error).setMessage(e.getMessage());\r
}\r
catch (Exception e)\r
{\r
}\r
else\r
{\r
- endTransactionOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Ok).setMessage("The transaction ends.");\r
+ outputBuilder.setResultCode(Ok).setMessage("The transaction ends.");\r
}\r
\r
}\r
}\r
- endTransactionOutputResult = RpcResultBuilder.<EndTransactionOutput>success(endTransactionOutputBuilder.build()).build();\r
- return Futures.immediateFuture(endTransactionOutputResult);\r
+\r
+ return RpcResultBuilder.success(outputBuilder).buildFuture();\r
}\r
\r
@Override\r
public Future<RpcResult<LanguageStyleNemoRequestOutput>> languageStyleNemoRequest(LanguageStyleNemoRequestInput input) {\r
- RpcResult<LanguageStyleNemoRequestOutput> styleNemoRequestOutputRpcResult = null;\r
- LanguageStyleNemoRequestOutputBuilder languageStyleNemoRequestOutputBuilder = new LanguageStyleNemoRequestOutputBuilder();\r
+ final LanguageStyleNemoRequestOutputBuilder outputBuilder = new LanguageStyleNemoRequestOutputBuilder();\r
\r
String errorInfo = languageIntent.LanIntentHandler(aaa,input);\r
\r
if (errorInfo != null)\r
{\r
- languageStyleNemoRequestOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage(errorInfo);\r
+ outputBuilder.setResultCode(Error).setMessage(errorInfo);\r
}\r
else\r
{\r
- languageStyleNemoRequestOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Ok).setMessage("The intent has been stored in this transaction.");\r
+ outputBuilder.setResultCode(Ok).setMessage("The intent has been stored in this transaction.");\r
informresolver = true;\r
}\r
- styleNemoRequestOutputRpcResult = RpcResultBuilder.<LanguageStyleNemoRequestOutput>success(languageStyleNemoRequestOutputBuilder.build()).build();\r
\r
- return Futures.immediateFuture(styleNemoRequestOutputRpcResult);\r
+ return RpcResultBuilder.success(outputBuilder).buildFuture();\r
}\r
\r
@Override\r
public Future<RpcResult<RegisterUserOutput>> registerUser(RegisterUserInput input) {\r
- RpcResult<RegisterUserOutput> registerUserOutputRpcResult = null;\r
- RegisterUserOutputBuilder registerUserOutputBuilder = new RegisterUserOutputBuilder();\r
+ final RegisterUserOutputBuilder registerUserOutputBuilder = new RegisterUserOutputBuilder();\r
+\r
String errorInfo = registerUser.registerUser(input);\r
\r
if (errorInfo != null)\r
{\r
- registerUserOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage(errorInfo);\r
+ registerUserOutputBuilder.setResultCode(Error).setMessage(errorInfo);\r
}\r
else\r
{\r
- registerUserOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Ok).setMessage("Register user successfully.");\r
+ registerUserOutputBuilder.setResultCode(Ok).setMessage("Register user successfully.");\r
}\r
\r
- registerUserOutputRpcResult = RpcResultBuilder.<RegisterUserOutput>success(registerUserOutputBuilder.build()).build();\r
-\r
- return Futures.immediateFuture(registerUserOutputRpcResult);\r
+ return RpcResultBuilder.success(registerUserOutputBuilder).buildFuture();\r
}\r
\r
@Override\r
public Future<RpcResult<StructureStyleNemoDeleteOutput>> structureStyleNemoDelete(StructureStyleNemoDeleteInput input) {\r
- RpcResult<StructureStyleNemoDeleteOutput> styleNemoDeleteOutputRpcResult = null;\r
- StructureStyleNemoDeleteOutputBuilder styleNemoDeleteOutputBuilder = new StructureStyleNemoDeleteOutputBuilder();\r
+ final StructureStyleNemoDeleteOutputBuilder outputBuilder = new StructureStyleNemoDeleteOutputBuilder();\r
\r
String errorInfo = deleteIntent.styleNemoDeleteOutput(aaa,input);\r
\r
if (errorInfo != null)\r
{\r
- styleNemoDeleteOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage(errorInfo);\r
+ outputBuilder.setResultCode(Error).setMessage(errorInfo);\r
}\r
else\r
{\r
- styleNemoDeleteOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Ok).setMessage("The intent has been handled by user manager successfully.");\r
+ outputBuilder.setResultCode(Ok).setMessage("The intent has been handled by user manager successfully.");\r
informresolver = true;\r
}\r
\r
-\r
- styleNemoDeleteOutputRpcResult = RpcResultBuilder.<StructureStyleNemoDeleteOutput>success(styleNemoDeleteOutputBuilder.build()).build();\r
-\r
- return Futures.immediateFuture(styleNemoDeleteOutputRpcResult);\r
+ return RpcResultBuilder.success(outputBuilder).buildFuture();\r
}\r
\r
@Override\r
public Future<RpcResult<StructureStyleNemoUpdateOutput>> structureStyleNemoUpdate(StructureStyleNemoUpdateInput input) {\r
- RpcResult<StructureStyleNemoUpdateOutput> styleNemoUpdateOutputRpcResult = null;\r
- StructureStyleNemoUpdateOutputBuilder styleNemoUpdateOutputBuilder = new StructureStyleNemoUpdateOutputBuilder();\r
+ final StructureStyleNemoUpdateOutputBuilder outputBuilder = new StructureStyleNemoUpdateOutputBuilder();\r
\r
String erroInfo = updateIntent.updateIntent(aaa,input);\r
\r
if (erroInfo != null)\r
{\r
- styleNemoUpdateOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Error).setMessage(erroInfo);\r
+ outputBuilder.setResultCode(Error).setMessage(erroInfo);\r
}\r
else\r
{\r
- styleNemoUpdateOutputBuilder.setResultCode(CommonRpcResult.ResultCode.Ok).setMessage("The intent has been handled by user manager successfully.");\r
+ outputBuilder.setResultCode(Ok).setMessage("The intent has been handled by user manager successfully.");\r
informresolver = true;\r
}\r
\r
- styleNemoUpdateOutputRpcResult = RpcResultBuilder.<StructureStyleNemoUpdateOutput>success(styleNemoUpdateOutputBuilder.build()).build();\r
-\r
- return Futures.immediateFuture(styleNemoUpdateOutputRpcResult);\r
+ return RpcResultBuilder.success(outputBuilder).buildFuture();\r
}\r
\r
@Override\r
Code Review / nemo.git / blobdiff