Merge pull request #78 from dbl-x/feat_support_schema

rename config: openmeta_url to schema_registry_url

Author: duhenglucky

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();

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();

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.
      *

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";
 
 }