|
|
|
@ -47,6 +47,7 @@ import static org.thingsboard.server.common.data.msg.TbMsgType.INACTIVITY_EVENT; |
|
|
|
import static org.thingsboard.server.common.data.msg.TbMsgType.POST_ATTRIBUTES_REQUEST; |
|
|
|
import static org.thingsboard.server.common.data.msg.TbMsgType.POST_TELEMETRY_REQUEST; |
|
|
|
import static org.thingsboard.server.common.data.msg.TbMsgType.TIMESERIES_UPDATED; |
|
|
|
import static org.thingsboard.server.common.data.msg.TbMsgType.TO_SERVER_RPC_REQUEST; |
|
|
|
|
|
|
|
@Slf4j |
|
|
|
public abstract class AbstractTbMsgPushNode<T extends BaseTbMsgPushNodeConfiguration, S, U> implements TbNode { |
|
|
|
@ -176,6 +177,6 @@ public abstract class AbstractTbMsgPushNode<T extends BaseTbMsgPushNodeConfigura |
|
|
|
|
|
|
|
protected boolean isSupportedMsgType(TbMsg msg) { |
|
|
|
return msg.isTypeOneOf(POST_TELEMETRY_REQUEST, POST_ATTRIBUTES_REQUEST, ATTRIBUTES_UPDATED, ATTRIBUTES_DELETED, TIMESERIES_UPDATED, |
|
|
|
ALARM, CONNECT_EVENT, DISCONNECT_EVENT, ACTIVITY_EVENT, INACTIVITY_EVENT); |
|
|
|
ALARM, CONNECT_EVENT, DISCONNECT_EVENT, ACTIVITY_EVENT, INACTIVITY_EVENT, TO_SERVER_RPC_REQUEST); |
|
|
|
} |
|
|
|
} |
|
|
|
|