Config UI for RPC Reply and Request rule nodes.

This commit is contained in:
Igor Kulikov 2018-04-27 20:26:28 +03:00
parent 0b4ec2b9b3
commit 7548b4f0b3
5 changed files with 11 additions and 5 deletions

View File

@ -103,6 +103,7 @@ public class AppActor extends RuleChainManagerActor {
case DEVICE_CREDENTIALS_UPDATE_TO_DEVICE_ACTOR_MSG:
case DEVICE_NAME_OR_TYPE_UPDATE_TO_DEVICE_ACTOR_MSG:
case DEVICE_RPC_REQUEST_TO_DEVICE_ACTOR_MSG:
case SERVER_RPC_RESPONSE_TO_DEVICE_ACTOR_MSG:
onToDeviceActorMsg((TenantAwareMsg) msg);
break;
default:

View File

@ -81,6 +81,7 @@ public class TenantActor extends RuleChainManagerActor {
case DEVICE_CREDENTIALS_UPDATE_TO_DEVICE_ACTOR_MSG:
case DEVICE_NAME_OR_TYPE_UPDATE_TO_DEVICE_ACTOR_MSG:
case DEVICE_RPC_REQUEST_TO_DEVICE_ACTOR_MSG:
case SERVER_RPC_RESPONSE_TO_DEVICE_ACTOR_MSG:
onToDeviceActorMsg((DeviceAwareMsg) msg);
break;
default:

View File

@ -34,7 +34,9 @@ import org.thingsboard.server.common.msg.TbMsg;
name = "rpc call reply",
configClazz = TbSendRpcReplyNodeConfiguration.class,
nodeDescription = "Sends reply to the RPC call from device",
nodeDetails = "Expects messages with any message type. Will forward message body to the device."
nodeDetails = "Expects messages with any message type. Will forward message body to the device.",
uiResources = {"static/rulenode/rulenode-core-config.js"},
configDirective = "tbActionNodeRpcReplyConfig"
)
public class TbSendRPCReplyNode implements TbNode {

View File

@ -39,9 +39,11 @@ import java.util.concurrent.TimeUnit;
@RuleNode(
type = ComponentType.ACTION,
name = "rpc call request",
configClazz = TbSendRpcReplyNodeConfiguration.class,
configClazz = TbSendRpcRequestNodeConfiguration.class,
nodeDescription = "Sends one-way RPC call to device",
nodeDetails = "Expects messages with \"method\" and \"params\". Will forward response from device to next nodes."
nodeDetails = "Expects messages with \"method\" and \"params\". Will forward response from device to next nodes.",
uiResources = {"static/rulenode/rulenode-core-config.js"},
configDirective = "tbActionNodeRpcRequestConfig"
)
public class TbSendRPCRequestNode implements TbNode {