Merge pull request #62 from RADAR-base/release-0.11.1

Release 0.11.1
RADAR-base · Oct 30, 2018 · 7af4735 · 7af4735
2 parents f44e594 + 776d38f
commit 7af4735
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 15 deletions.
diff --git a/README.md b/README.md
@@ -14,7 +14,7 @@ repositories {
 }
 
 dependencies {
-    implementation group: 'org.radarcns', name: 'radar-commons', version: '0.11.0'
+    implementation group: 'org.radarcns', name: 'radar-commons', version: '0.11.1'
 }
 ```
 
@@ -26,7 +26,7 @@ repositories {
 }
 
 dependencies {
-    implementation group: 'org.radarcns', name: 'radar-commons-server', version: '0.11.0'
+    implementation group: 'org.radarcns', name: 'radar-commons-server', version: '0.11.1'
 }
 ```
 
@@ -40,7 +40,7 @@ repositories {
 }
 
 dependencies {
-    testImplementation group: 'org.radarcns', name: 'radar-commons-testing', version: '0.11.0'
+    testImplementation group: 'org.radarcns', name: 'radar-commons-testing', version: '0.11.1'
 }
 ```
 
@@ -53,7 +53,7 @@ repositories {
 }
 
 dependencies {
-    runtimeOnly group: 'org.radarcns', name: 'radar-commons-unsafe', version: '0.11.0'
+    runtimeOnly group: 'org.radarcns', name: 'radar-commons-unsafe', version: '0.11.1'
 }
 ```
 
@@ -78,7 +78,7 @@ configurations.all {
 }
 
 dependencies {
-    compile group: 'org.radarcns', name: 'radar-commons', version: '0.11.1-SNAPSHOT', changing: true
+    compile group: 'org.radarcns', name: 'radar-commons', version: '0.11.2-SNAPSHOT', changing: true
 }
 ```
 

diff --git a/build.gradle b/build.gradle
@@ -36,7 +36,7 @@ subprojects {
     // Configuration                                                             //
     //---------------------------------------------------------------------------//
 
-    version = '0.11.0'
+    version = '0.11.1'
     group = 'org.radarcns'
     ext.githubRepoName = 'RADAR-CNS/RADAR-Commons'
 

diff --git a/radar-commons/src/main/java/org/radarcns/producer/rest/SchemaRetriever.java b/radar-commons/src/main/java/org/radarcns/producer/rest/SchemaRetriever.java
@@ -166,19 +166,14 @@ public void addSchemaMetadata(String topic, boolean ofValue, ParsedSchemaMetadat
      */
     public ParsedSchemaMetadata getOrSetSchemaMetadata(String topic, boolean ofValue, Schema schema,
             int version) throws IOException {
-        ParsedSchemaMetadata metadata;
         try {
-            metadata = getSchemaMetadata(topic, ofValue, version);
-            if (metadata.getSchema().equals(schema)) {
-                return metadata;
-            }
+            return getSchemaMetadata(topic, ofValue, version);
         } catch (IOException ex) {
             logger.warn("Schema for {} value was not yet added to the schema registry.", topic);
+            ParsedSchemaMetadata metadata = new ParsedSchemaMetadata(null, null, schema);
+            addSchemaMetadata(topic, ofValue, metadata);
+            return metadata;
         }
-
-        metadata = new ParsedSchemaMetadata(null, null, schema);
-        addSchemaMetadata(topic, ofValue, metadata);
-        return metadata;
     }
 
     private class SchemaRequestBody extends RequestBody {