diff --git a/docs/changelog.rst b/docs/changelog.rst
index 4c55486d..ab30f6a0 100644
--- a/docs/changelog.rst
+++ b/docs/changelog.rst
@@ -5,6 +5,7 @@ Changelog
 Changes in dev
 ==============
 
+- Added replicaSet connection support
 - Updated deprecated imports from pymongo (safe for pymongo 2.2)
 - Added uri support for connections
 - Added scalar for efficiently returning partial data values (aliased to values_list)
diff --git a/mongoengine/connection.py b/mongoengine/connection.py
index b6b716f8..79c5b5a8 100644
--- a/mongoengine/connection.py
+++ b/mongoengine/connection.py
@@ -1,5 +1,5 @@
 import pymongo
-from pymongo import Connection, uri_parser
+from pymongo import Connection, ReplicaSetConnection, uri_parser
 
 
 __all__ = ['ConnectionError', 'connect', 'register_connection',
@@ -108,8 +108,11 @@ def get_connection(alias=DEFAULT_CONNECTION_NAME, reconnect=False):
                 conn_settings['slaves'] = slaves
                 conn_settings.pop('read_preference')
 
+        connection_class = Connection
+        if 'replicaSet' in conn_settings:
+            connection_class = ReplicaSetConnection
         try:
-            _connections[alias] = Connection(**conn_settings)
+            _connections[alias] = connection_class(**conn_settings)
         except Exception, e:
             raise ConnectionError("Cannot connect to database %s :\n%s" % (alias, e))
     return _connections[alias]