From eda43502fadb377987c0a2b588248c59875f8f60 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=9E=E4=B8=80?= Date: Thu, 11 Jun 2020 13:14:08 +0800 Subject: [PATCH] rename config: openmeta_url to schema_registry_url --- .../samples/consumer/GenericPushConsumerApp.java | 2 +- .../java/io/openmessaging/samples/producer/ProducerApp.java | 2 +- .../src/main/java/io/openmessaging/api/OMS.java | 5 +++++ .../src/main/java/io/openmessaging/api/OMSBuiltinKeys.java | 2 +- 4 files changed, 8 insertions(+), 3 deletions(-) diff --git a/openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/GenericPushConsumerApp.java b/openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/GenericPushConsumerApp.java index 9593d08f..7eb537db 100644 --- a/openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/GenericPushConsumerApp.java +++ b/openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/GenericPushConsumerApp.java @@ -34,13 +34,13 @@ public static void main(String[] args) { OMS.builder() .region("Shanghai") .endpoint("127.0.0.1:9876") + .schemaRegistryUrl("http://localhost:1234") .driver("rocketmq") .withCredentials(new Properties()) .build(); Properties properties = new Properties(); properties.setProperty(OMSBuiltinKeys.DESERIALIZER, "io.openmessaging.openmeta.impl.Deserializer"); - properties.setProperty(OMSBuiltinKeys.OPEN_META_URL, "http://localhost:1234"); final Consumer consumer = messagingAccessPoint.createConsumer(properties); consumer.start(); diff --git a/openmessaging-api-samples/src/main/java/io/openmessaging/samples/producer/ProducerApp.java b/openmessaging-api-samples/src/main/java/io/openmessaging/samples/producer/ProducerApp.java index af6006f0..a432f8e8 100644 --- a/openmessaging-api-samples/src/main/java/io/openmessaging/samples/producer/ProducerApp.java +++ b/openmessaging-api-samples/src/main/java/io/openmessaging/samples/producer/ProducerApp.java @@ -35,13 +35,13 @@ public static void main(String[] args) { OMS.builder() .region("shanghai,shenzhen") .endpoint("127.0.0.1:9876") + .schemaRegistryUrl("http://localhost:1234") .driver("rocketmq") .withCredentials(new Properties()) .build(); Properties properties = new Properties(); properties.setProperty(OMSBuiltinKeys.SERIALIZER, "io.openmessaging.openmeta.impl.Serializer"); - properties.setProperty(OMSBuiltinKeys.OPEN_META_URL, "http://localhost:1234"); final Producer producer = messagingAccessPoint.createProducer(properties); producer.start(); diff --git a/openmessaging-api/src/main/java/io/openmessaging/api/OMS.java b/openmessaging-api/src/main/java/io/openmessaging/api/OMS.java index 908b1ed8..5afe5a22 100644 --- a/openmessaging-api/src/main/java/io/openmessaging/api/OMS.java +++ b/openmessaging-api/src/main/java/io/openmessaging/api/OMS.java @@ -57,6 +57,11 @@ public OMS endpoint(String endpoint) { return this; } + public OMS schemaRegistryUrl(String schemaRegistryUrl) { + this.properties.put(OMSBuiltinKeys.SCHEMA_REGISTRY_URL, schemaRegistryUrl); + return this; + } + /** * Set the region provided by messaging vendor. * diff --git a/openmessaging-api/src/main/java/io/openmessaging/api/OMSBuiltinKeys.java b/openmessaging-api/src/main/java/io/openmessaging/api/OMSBuiltinKeys.java index 81fc12e7..2c32875a 100644 --- a/openmessaging-api/src/main/java/io/openmessaging/api/OMSBuiltinKeys.java +++ b/openmessaging-api/src/main/java/io/openmessaging/api/OMSBuiltinKeys.java @@ -73,6 +73,6 @@ public interface OMSBuiltinKeys { /** * The {@code OPEN_META_URL} represents the OpenMeta(schema registry) server url. */ - String OPEN_META_URL = "openMetaUrl"; + String SCHEMA_REGISTRY_URL = "schemaRegistryUrl"; }