diff --git a/lib/index.js b/lib/index.js
index 81d959e..115302f 100644
--- a/lib/index.js
+++ b/lib/index.js
@@ -5,9 +5,9 @@ var uuid = require('uuid');
 var Logger = function Logger(service, options) {
 
     var _options = options || {},
-        _service =  service || 'mrs';
+        _service = service || 'mrs';
 
-    this.init = function(options, service){
+    this.init = function (options, service) {
         require('winston-logstash');
         var _options = options || {};
         this._service = options.service || 'mrs';
@@ -19,7 +19,7 @@ var Logger = function Logger(service, options) {
                     host: _options.host || 'localhost',
                     localhost: _options.host || 'localhost',
                     level: _options.level || 'silly',
-                    max_connect_retries:-1
+                    max_connect_retries: -1
                 }),
                 new (winston.transports.Console)({
                     colorize: true,
@@ -29,7 +29,7 @@ var Logger = function Logger(service, options) {
         });
     };
 
-    this.log = function(title, message, source, method, level){
+    this.log = function (title, message, source, method, level) {
         var _this = this;
         var msg = {
             title: title,
@@ -37,32 +37,32 @@ var Logger = function Logger(service, options) {
         };
         var src = source || '';
         var mtd = method || '';
-        _this.logger.log(level, {message: msg, service: _service, source: src, method: mtd}, function(){
+        _this.logger.log(level, {message: msg, service: _service, source: src, method: mtd}, function () {
 
-        } );
+        });
     };
 
-    this.debug = function(title, message, source, method) {
+    this.debug = function (title, message, source, method) {
         this.log(title, message, source, method, 'debug');
     };
 
-    this.verbose = function(title, message, source, method) {
+    this.verbose = function (title, message, source, method) {
         this.log(title, message, source, method, 'verbose');
     };
 
-    this.info = function(title, message, source, method) {
+    this.info = function (title, message, source, method) {
         this.log(title, message, source, method, 'info');
     };
 
-    this.warn = function(title, message, source, method) {
+    this.warn = function (title, message, source, method) {
         this.log(title, message, source, method, 'warn');
     };
 
-    this.error = function(title, message, source, method) {
+    this.error = function (title, message, source, method) {
         this.log(title, message, source, method, 'error');
     };
 
-    this.errorcallback = function(message, callback, source, method) {
+    this.errorcallback = function (message, callback, source, method) {
         var _this = this;
         _this.logger.log('error', {message: message, service: _service, source: source, method: method}, callback);
     };
@@ -71,8 +71,8 @@ var Logger = function Logger(service, options) {
 
 Logger.instance = null;
 
-Logger.getInstance = function(){
-    if(this.instance === null)
+Logger.getInstance = function () {
+    if (this.instance === null)
         this.instance = new Logger();
     return this.instance;
 };
@@ -92,26 +92,26 @@ var Metric = function Metric() {
     expressWinston.requestWhitelist.push('stack');
 
 
-    this.set = function(status, url, duration, callback) {
+    this.set = function (status, url, duration, callback) {
         var _this = this;
-        var message = {status: status, url: url, duration:duration};
-        _this.metric.log('info',{message: message}, callback);
+        var message = {status: status, url: url, duration: duration};
+        _this.metric.log('info', {message: message}, callback);
     };
 
-    this.getRequestId = function(){
+    this.getRequestId = function () {
         return uuid.v4();
     };
-    this.init = function(options, service){
+    this.init = function (options, service) {
         require('winston-logstash');
         var _options = options || {};
         this._service = service || 'mrs';
-        this.transports= [
+        this.transports = [
             new (winston.transports.Logstash)({
                 port: _options.port || 28778,
                 node_name: _options.node_name || 'mrs-metric',
                 host: _options.host || 'localhost',
                 localhost: _options.host || 'localhost',
-                max_connect_retries:-1
+                max_connect_retries: -1
             }),
             new (winston.transports.Console)({
                 colorize: true,
@@ -122,7 +122,7 @@ var Metric = function Metric() {
             transports: this.transports
         });
 
-        this.specialMdd = function(req, res, next){
+        this.specialMdd = function (req, res, next) {
             var info = winston.exception.getAllInfo("");
             req.date = info.date;
             req.process = info.process;
@@ -146,11 +146,115 @@ var Metric = function Metric() {
 
 Metric.instance = null;
 
-Metric.getInstance = function(){
-    if(this.instance === null)
+Metric.getInstance = function () {
+    if (this.instance === null)
         this.instance = new Metric();
     return this.instance;
 };
 
+
+var ServiceLogger = function ServiceLogger(options, service, host) {
+
+    var _options = options || {},
+        _service = service || 'mrs',
+        _host = host || 'localhost',
+        _client = '',
+        _protocol = '';
+
+    this.init = function (options, service, host) {
+        var Elasticsearch = require('winston-elasticsearch');
+
+        this._options = options || {};
+        this._service = service || 'mrs';
+        this._host = host || 'localhost';
+
+        this.logger = new (winston.Logger)({
+            transports: [
+                new Elasticsearch({
+                    index: this._options.index || '',
+                    clientOpts: {
+                        host: this._options.host || ''
+                    },
+                    messageType: this._options.type || '',
+                    transformer: function (logData) {
+                        const transformed = {};
+                        transformed.uuid = logData.meta.uuid;
+                        transformed.message = logData.meta.message;
+                        transformed['time'] = new Date().toISOString();
+                        transformed.host = logData.meta.host || '';
+                        transformed.client = logData.meta.client || '';
+                        transformed.service = logData.meta.service || 'mrs';
+                        transformed.orgCode = logData.meta.orgCode;
+                        transformed.appCode = logData.meta.appCode;
+                        transformed.method = logData.meta.method;
+                        transformed.protocol = logData.meta.protocol || '';
+                        transformed.url = logData.meta.url || '';
+                        transformed.request = logData.meta.request || '';
+                        transformed.request_header = logData.meta.request_header || '';
+                        transformed.request_body = logData.meta.request_body || '';
+                        transformed.request_time = logData.meta.request_time || undefined;
+                        transformed.response_body = logData.meta.response_body || '';
+                        transformed.response_time = logData.meta.response_time || undefined;
+                        transformed.status = logData.meta.status || '';
+                        transformed.elapsed_time = logData.meta.elapsed_time || '';
+                        //transformed.fields = logData.meta;
+                        return transformed;
+                    }
+                })
+            ]
+        });
+    };
+
+    this.logRequest = function (uuid, options) {
+
+        this.logger.info({
+            uuid: uuid,
+            message: "req",
+            host: this._host,
+            client: this._client,
+            protocol: this._protocol,
+            service: this._service,
+            orgCode: options.orgCode,
+            appCode: options.appCode,
+            method: options.method,
+            url: options.url,
+            request: JSON.stringify(options),
+            request_time: new Date().toISOString()
+        });
+    };
+
+    this.logResponse = function (uuid, request, response, status, elapsed_time) {
+
+        this.logger.info({
+            uuid: uuid,
+            message: "resp",
+            host: this._host,
+            client: this._client,
+            protocol: request.uri.protocol,
+            service: this._service,
+            orgCode: request.orgCode,
+            appCode: request.appCode,
+            method: request.method,
+            url: request.href || '',
+            request_header: JSON.stringify(request.headers),
+            request_body: JSON.stringify(request.body),
+            response_body: JSON.stringify(response),
+            response_time: new Date().toISOString(),
+            status: status,
+            elapsed_time: elapsed_time
+        });
+    }
+}
+
+ServiceLogger.instance = null;
+
+ServiceLogger.getInstance = function () {
+    if (this.instance === null)
+        this.instance = new ServiceLogger();
+    return this.instance;
+};
+
+
+module.exports.ServiceLogger = ServiceLogger.getInstance();
 module.exports.Logger = Logger.getInstance();
 module.exports.Metric = Metric.getInstance();
diff --git a/package.json b/package.json
index 15146ef..8cd7fb5 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "mrs-node-logger",
-  "version": "1.0.2",
+  "version": "1.1.0",
   "description": "nodejs logging logstash",
   "main": "index.js",
   "scripts": {
@@ -11,9 +11,10 @@
   },
   "license": "ISC",
   "dependencies": {
-   "winston": "^1.0.0",
-   "winston-logstash": "^0.2.11",
-   "express-winston":"0.3.1",
+    "winston": "^1.0.0",
+    "winston-elasticsearch": "^0.4.0",
+    "winston-logstash": "^0.2.11",
+    "express-winston":"0.3.1",
     "uuid":"^2.0.1"
   }
 }