public static boolean canTry(String nodeId) {
        if (TransferQueueUtil.isTransferQueue(nodeId)) {
            LOG.debug("中转节点直接发mqtt消息的");
            return false;
        }
        if (!ENABLE_RPC.get()) {
            return false;
        }
        return rpcServerStatusMap.getUnchecked(nodeId).canTry();
    }
public static boolean canTry ( String nodeId ) { if ( TransferQueueUtil . isTransferQueue ( nodeId ) ) { LOG . debug ( "中转节点直接发mqtt消息的" ) ; return false ; } if ( ! ENABLE_RPC . get ( ) ) { return false ; } return rpcServerStatusMap . getUnchecked ( nodeId ) . canTry ( ) ; }
@param nodeId 节点id/队列名