diff --git a/amqp-client-auth/pom.xml b/amqp-client-auth/pom.xml
index 62f62c0c..302ac091 100644
--- a/amqp-client-auth/pom.xml
+++ b/amqp-client-auth/pom.xml
@@ -20,7 +20,7 @@
pulsar-protocol-handler-amqp-parent
io.streamnative.pulsar.handlers
- 3.3.0-SNAPSHOT
+ 4.0.0-SNAPSHOT.ursa
4.0.0
diff --git a/amqp-impl/pom.xml b/amqp-impl/pom.xml
index 59372f15..8a81ff09 100644
--- a/amqp-impl/pom.xml
+++ b/amqp-impl/pom.xml
@@ -22,7 +22,7 @@
io.streamnative.pulsar.handlers
pulsar-protocol-handler-amqp-parent
- 3.3.0-SNAPSHOT
+ 4.0.0-SNAPSHOT.ursa
pulsar-protocol-handler-amqp
diff --git a/amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AopProtocolHandlerTestBase.java b/amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AopProtocolHandlerTestBase.java
index a915fba7..3814fed8 100644
--- a/amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AopProtocolHandlerTestBase.java
+++ b/amqp-impl/src/test/java/io/streamnative/pulsar/handlers/amqp/test/AopProtocolHandlerTestBase.java
@@ -153,8 +153,8 @@ protected void setupBrokerMocks(PulsarService pulsar) throws Exception {
doReturn(mockBookKeeperClientFactory).when(pulsar).newBookKeeperClientFactory();
MockZooKeeperSession mockZooKeeperSession = MockZooKeeperSession.newInstance(mockZooKeeper);
- doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createLocalMetadataStore(any());
- doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createConfigurationMetadataStore(any());
+ doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createLocalMetadataStore(any(), any());
+ doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createConfigurationMetadataStore(any(), any());
Supplier namespaceServiceSupplier = () -> spy(new NamespaceService(pulsar));
doReturn(namespaceServiceSupplier).when(pulsar).getNamespaceServiceProvider();
diff --git a/pom.xml b/pom.xml
index a60853bd..2d920fb5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,4 +1,4 @@
-
+
-
-
+
org.apache
apache
18
4.0.0
-
pom
-
io.streamnative.pulsar.handlers
pulsar-protocol-handler-amqp-parent
- 3.3.0-SNAPSHOT
+ 4.0.0-SNAPSHOT.ursa
StreamNative :: Pulsar Protocol Handler :: AoP Parent
Parent for AMQP on Pulsar implemented using Pulsar Protocol Handler.
-
true
17
17
${maven.compiler.target}
-
- 3.4.0-SNAPSHOT
+ 4.0.0-SNAPSHOT.ursa
8.0.0
5.8.0
-
6.4.0
1.1.1
@@ -51,7 +43,6 @@
6.14.3
4.2.0
3.15.0
-
3.1.8
1.4.9
@@ -63,7 +54,6 @@
8.37
4.2.2
-
Apache License, Version 2.0
@@ -71,18 +61,15 @@
repo
-
amqp-impl
tests
tests-qpid-jms-client
amqp-client-auth
-
-
io.streamnative
pulsar
@@ -90,59 +77,49 @@
pom
import
-
io.streamnative
pulsar-broker
${pulsar.version}
-
io.streamnative
pulsar-broker
${pulsar.version}
test-jar
-
io.streamnative
testmocks
${pulsar.version}
-
com.rabbitmq
amqp-client
${rabbitmq.version}
-
org.apache.qpid
qpid-client
${qpid-client-version}
-
org.apache.geronimo.specs
geronimo-jms_1.1_spec
${geronimo-jms-version}
-
org.apache.qpid
qpid-test-utils
${qpid-protocol-plugin.version}
-
com.github.spotbugs
spotbugs-annotations
${spotbugs-annotations.version}
-
-
@@ -151,19 +128,16 @@
pulsar-broker
provided
-
org.projectlombok
lombok
provided
-
com.github.spotbugs
spotbugs-annotations
provided
-
io.streamnative
@@ -171,37 +145,31 @@
test-jar
test
-
io.streamnative
testmocks
test
-
org.testng
testng
test
-
org.mockito
mockito-core
test
-
org.awaitility
awaitility
test
-
org.assertj
assertj-core
test
-
junit
@@ -209,9 +177,7 @@
4.13.2
test
-
-
@@ -260,7 +226,6 @@
resources/findbugsExclude.xml
-
maven-compiler-plugin
${maven-compiler-plugin.version}
@@ -277,7 +242,6 @@
-
maven-surefire-plugin
${maven-surefire-plugin.version}
@@ -293,14 +257,12 @@
false
-
com.mycila
license-maven-plugin
${license-maven-plugin.version}
resources/license.template
-
LICENSE
NOTICE
@@ -330,7 +292,6 @@
-
org.codehaus.mojo
templating-maven-plugin
@@ -344,7 +305,6 @@
-
pl.project13.maven
git-commit-id-plugin
@@ -370,10 +330,8 @@
full
-
-
central
@@ -384,6 +342,23 @@
nexus-snapshot-repo
https://s01.oss.sonatype.org/content/repositories/snapshots
+
+ ossrh
+ https://s01.oss.sonatype.org/service/local/repositories/0/content
+
+
+ nexus-snapshot
+ https://s01.oss.sonatype.org/content/repositories/snapshots
+
-
+
+
+ ossrh
+ https://s01.oss.sonatype.org/content/repositories/snapshots
+
+
+ ossrh
+ https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/
+
+
diff --git a/tests-qpid-jms-client/pom.xml b/tests-qpid-jms-client/pom.xml
index 171dd72f..12eb9863 100644
--- a/tests-qpid-jms-client/pom.xml
+++ b/tests-qpid-jms-client/pom.xml
@@ -20,7 +20,7 @@
io.streamnative.pulsar.handlers
pulsar-protocol-handler-amqp-parent
- 3.3.0-SNAPSHOT
+ 4.0.0-SNAPSHOT.ursa
4.0.0
diff --git a/tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java b/tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java
index 4592a2ce..3dc79570 100644
--- a/tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java
+++ b/tests-qpid-jms-client/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java
@@ -280,8 +280,8 @@ protected void setupBrokerMocks(PulsarService pulsar) throws Exception {
doReturn(mockBookKeeperClientFactory).when(pulsar).newBookKeeperClientFactory();
MockZooKeeperSession mockZooKeeperSession = MockZooKeeperSession.newInstance(mockZooKeeper);
- doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createLocalMetadataStore(any());
- doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createConfigurationMetadataStore(any());
+ doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createLocalMetadataStore(any(), any());
+ doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createConfigurationMetadataStore(any(), any());
Supplier namespaceServiceSupplier = () -> spy(new NamespaceService(pulsar));
doReturn(namespaceServiceSupplier).when(pulsar).getNamespaceServiceProvider();
diff --git a/tests/pom.xml b/tests/pom.xml
index 7c65723a..183dbde2 100644
--- a/tests/pom.xml
+++ b/tests/pom.xml
@@ -22,7 +22,7 @@
io.streamnative.pulsar.handlers
pulsar-protocol-handler-amqp-parent
- 3.3.0-SNAPSHOT
+ 4.0.0-SNAPSHOT.ursa
io.streamnative.pulsar.handlers
diff --git a/tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java b/tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java
index f5fa1d85..55da5403 100644
--- a/tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java
+++ b/tests/src/test/java/io/streamnative/pulsar/handlers/amqp/AmqpProtocolHandlerTestBase.java
@@ -307,8 +307,8 @@ protected void setupBrokerMocks(PulsarService pulsar) throws Exception {
doReturn(mockBookKeeperClientFactory).when(pulsar).newBookKeeperClientFactory();
MockZooKeeperSession mockZooKeeperSession = MockZooKeeperSession.newInstance(mockZooKeeper);
- doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createLocalMetadataStore(any());
- doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createConfigurationMetadataStore(any());
+ doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createLocalMetadataStore(any(), any());
+ doReturn(new ZKMetadataStore(mockZooKeeperSession)).when(pulsar).createConfigurationMetadataStore(any(), any());
Supplier namespaceServiceSupplier = () -> spy(new NamespaceService(pulsar));
doReturn(namespaceServiceSupplier).when(pulsar).getNamespaceServiceProvider();