You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by xy...@apache.org on 2022/08/05 19:02:36 UTC
[pulsar] 02/02: Fix AuthenticationProviderBasicTest
This is an automated email from the ASF dual-hosted git repository.
xyz pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit c038898608ac901e81093b38c2dc82cf5051265b
Author: Yunze Xu <xy...@163.com>
AuthorDate: Sat Aug 6 03:00:55 2022 +0800
Fix AuthenticationProviderBasicTest
---
.../authentication/AuthenticationProviderBasicTest.java | 2 +-
.../src/main/java/org/apache/pulsar/client/api/url/URL.java | 11 +++++++++++
2 files changed, 12 insertions(+), 1 deletion(-)
diff --git a/pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java b/pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java
index 69df6663bd1..e5a7f20c978 100644
--- a/pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java
+++ b/pulsar-broker-common/src/test/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasicTest.java
@@ -91,7 +91,7 @@ public class AuthenticationProviderBasicTest {
@Test
public void testReadData() throws Exception {
- byte[] data = Files.readAllBytes(Path.of(basicAuthConf));
+ byte[] data = Files.readAllBytes(FileSystems.getDefault().getPath(basicAuthConf));
String base64Data = Base64.getEncoder().encodeToString(data);
// base64 format
diff --git a/pulsar-common/src/main/java/org/apache/pulsar/client/api/url/URL.java b/pulsar-common/src/main/java/org/apache/pulsar/client/api/url/URL.java
index b2037377d2f..3286900ecb7 100644
--- a/pulsar-common/src/main/java/org/apache/pulsar/client/api/url/URL.java
+++ b/pulsar-common/src/main/java/org/apache/pulsar/client/api/url/URL.java
@@ -42,6 +42,17 @@ public class URL {
}
}
+ /**
+ * Creates java.net.URL with data protocol support.
+ *
+ * @param spec the input URL as String
+ * @return java.net.URL instance
+ */
+ public static final java.net.URL createURL(String spec)
+ throws MalformedURLException, URISyntaxException, InstantiationException, IllegalAccessException {
+ return new URL(spec).url;
+ }
+
public URLConnection openConnection() throws IOException {
return this.url.openConnection();
}