Merge pull request #6 from kapetacom/feature/CORE-1676-mongodb-srv-protocol

fix: use the options protocol field instead of protocol

Author: morten-holm

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.kapeta</groupId>
     <artifactId>nosql-mongodb</artifactId>
-    <version>1.0.0</version>
+    <version>1.1.0</version>
 
     <name>${project.groupId}:${project.artifactId}</name>
     <description>MongoDB support for Kapeta Spring Boot SDK</description>

src/main/java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java

@@ -62,9 +62,10 @@ public ResourceInfo mongoInfo() {
     public PropertiesMongoConnectionDetails mongoConnectionDetails(ResourceInfo mongoInfo) {
         String databaseName = String.valueOf(mongoInfo.getOptions().getOrDefault("dbName", resourceName));
         String dbAuthDB = String.valueOf(mongoInfo.getOptions().getOrDefault("authdb", "admin"));
+        String protocol = String.valueOf(mongoInfo.getOptions().getOrDefault("protocol", "mongodb"));
 
         MongoProperties properties;
-        if ("mongodb+srv".equals(mongoInfo.getProtocol())) {
+        if ("mongodb+srv".equals(protocol)) {
             properties = createMongoUriProperties(databaseName, dbAuthDB, mongoInfo);
         } else {
             properties = createMongoProperties(databaseName, dbAuthDB, mongoInfo);