| | |
| | | }; |
| | | //注册直接通讯的主题,包括直接和主网关通讯或者直接和从网关通讯 |
| | | registerListener(String.format(TopicConstant.NATIVE_MODBUS_UP, "+"), eventListener); |
| | | registerListener(String.format(TopicConstant.NATIVE_MODBUS_DOWN_REPLY, "+"), eventListener); |
| | | |
| | | // registerListener(String.format(TopicConstant.NATIVE_ZIGBEE_UP_SLAVE, "+", "+"), eventListener); |
| | | //registerListener(String.format(TopicConstant.NATIVE_MODBUS_DOWN_REPLY, "+"), eventListener); |
| | | //registerListener(String.format(TopicConstant.NATIVE_ZIGBEE_UP_SLAVE, "+", "+"), eventListener); |
| | | } |
| | | |
| | | /** |
| | |
| | | new HDLConnectHelper(timeout, 1, gatewayBean.getIp_address(), 8586, request, new HDLConnectHelper.HdlSocketListener() { |
| | | @Override |
| | | public void onSucceed(Object msg) { |
| | | if (msg instanceof Byte[]) { |
| | | if (msg instanceof byte[]) { |
| | | if (null != baseCallBack) { |
| | | baseCallBack.onSuccess((byte[])msg); |
| | | } |