diff --git a/lib/esConnector.js b/lib/esConnector.js
index 044181d..9417500 100644
--- a/lib/esConnector.js
+++ b/lib/esConnector.js
@@ -71,6 +71,16 @@ ESConnector.prototype.getClientConfig = function () {
         log: this.settings.log || 'error',
         suggestCompression: true
     };
+
+    if (this.settings.amazonES) {
+        config.connectionClass = require('http-aws-es');
+        config.amazonES = this.settings.amazonES || {
+            region: 'us-east-1',
+            accessKey: 'AKID',
+            secretKey: 'secret'
+        }
+    }
+
     if (this.settings.ssl) {
         config.ssl = {
             ca: (this.settings.ssl.ca) ? fs.readFileSync(path.join(__dirname, this.settings.ssl.ca)) : fs.readFileSync(path.join(__dirname, '..', 'cacert.pem')),
diff --git a/package.json b/package.json
index f9c32d6..76a8ed0 100644
--- a/package.json
+++ b/package.json
@@ -43,6 +43,7 @@
     "debug": "^2.1.3",
     "elastic-deletebyquery": "1.0.7",
     "elasticsearch": "^11.0.1",
+    "http-aws-es": "^1.1.3",
     "lodash": "^3.5.0",
     "loopback-connector": "^1.1.1"
   },