From f9c6d23829acdef1e565babbc70a870a23308056 Mon Sep 17 00:00:00 2001
From: Thomas Risberg <trisberg@vmware.com>
Date: Wed, 16 May 2012 23:34:57 -0400
Subject: [PATCH] Add authentication of DB if username and password provided in
 config

---
 .../mongo-persistor/org/vertx/mods/MongoPersistor.java    | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/mods/mongo-persistor/org/vertx/mods/MongoPersistor.java b/src/mods/mongo-persistor/org/vertx/mods/MongoPersistor.java
index 8349af2272c..efad9d5043d 100644
--- a/src/mods/mongo-persistor/org/vertx/mods/MongoPersistor.java
+++ b/src/mods/mongo-persistor/org/vertx/mods/MongoPersistor.java
@@ -37,6 +37,7 @@
  * Please see the busmods manual for a full description<p>
  *
  * @author <a href="http://tfox.org">Tim Fox</a>
+ * @author Thomas Risberg
  */
 public class MongoPersistor extends BusModBase implements Handler<Message<JsonObject>> {
 
@@ -44,6 +45,8 @@ public class MongoPersistor extends BusModBase implements Handler<Message<JsonOb
   private String host;
   private int port;
   private String dbName;
+  private String username;
+  private String password;
 
   private Mongo mongo;
   private DB db;
@@ -55,10 +58,15 @@ public void start() {
     host = getOptionalStringConfig("host", "localhost");
     port = getOptionalIntConfig("port", 27017);
     dbName = getOptionalStringConfig("db_name", "default_db");
+    username = getOptionalStringConfig("username", null);
+    password = getOptionalStringConfig("password", null);
 
     try {
       mongo = new Mongo(host, port);
       db = mongo.getDB(dbName);
+      if (username != null && password != null) {
+        db.authenticate(username, password.toCharArray());
+      }
       eb.registerHandler(address, this);
     } catch (UnknownHostException e) {
       logger.error("Failed to connect to mongo server", e);