diff --git a/packages/pinus-rpc/lib/rpc-client/failureProcess.ts b/packages/pinus-rpc/lib/rpc-client/failureProcess.ts
index 25df34676..277e4dcb4 100644
--- a/packages/pinus-rpc/lib/rpc-client/failureProcess.ts
+++ b/packages/pinus-rpc/lib/rpc-client/failureProcess.ts
@@ -102,7 +102,7 @@ let failsafe = function (this: any, code: number, tracer: {[key: string]: any},
         case constants.RPC_ERROR.FAIL_CONNECT_SERVER:
             if (tracer && tracer.retryTimes <= retryTimes) {
                 setTimeout(function () {
-                    self.connect(tracer, serverId, cb);
+                    self.connect(tracer, serverId, msg, cb);
                 }, retryConnectTime * tracer.retryTimes);
             } else {
                 cb(new Error('rpc client failed to connect to remote server: ' + serverId));
diff --git a/packages/pinus-rpc/lib/rpc-client/mailstation.ts b/packages/pinus-rpc/lib/rpc-client/mailstation.ts
index 6a0e4f223..58dc93033 100644
--- a/packages/pinus-rpc/lib/rpc-client/mailstation.ts
+++ b/packages/pinus-rpc/lib/rpc-client/mailstation.ts
@@ -253,7 +253,7 @@ export class MailStation extends EventEmitter {
         if (!mailbox) {
             tracer && tracer.debug('client', __filename, 'dispatch', 'mailbox is not exist');
             // try to connect remote server if mailbox instance not exist yet
-            if (!lazyConnect(tracer, this, serverId, this.mailboxFactory, cb)) {
+            if (!lazyConnect(tracer, this, serverId, this.mailboxFactory, msg, cb)) {
                 tracer && tracer.error('client', __filename, 'dispatch', 'fail to find remote server:' + serverId);
                 logger.error('[pinus-rpc] fail to find remote server:' + serverId);
                 self.emit('error', constants.RPC_ERROR.NO_TRAGET_SERVER, tracer, serverId, msg, opts);
@@ -351,7 +351,7 @@ export class MailStation extends EventEmitter {
      * @return {String}   serverId remote server id
      * @param  {Function}   cb     callback function
      */
-    connect(tracer: Tracer, serverId: string, cb: Function) {
+    connect(tracer: Tracer, serverId: string, msg: any, cb: Function) {
         let self = this;
         let mailbox = self.mailboxes[serverId];
         mailbox.connect(tracer, function (err: Error) {
@@ -361,7 +361,7 @@ export class MailStation extends EventEmitter {
                 if (!!self.mailboxes[serverId]) {
                     delete self.mailboxes[serverId];
                 }
-                self.emit('error', constants.RPC_ERROR.FAIL_CONNECT_SERVER, tracer, serverId, null, self.opts);
+                self.emit('error', constants.RPC_ERROR.FAIL_CONNECT_SERVER, tracer, serverId, msg, self.opts);
                 return;
             }
             mailbox.on('close', function (id: string) {
@@ -416,7 +416,7 @@ let doFilter = function (tracer: Tracer, err: Error, serverId: string, msg: Mail
     doFilter(tracer, err, serverId, msg, opts, filters, index, operate, cb);
 };
 
-let lazyConnect = function (tracer: Tracer, station: MailStation, serverId: string, factory: IMailBoxFactory, cb: Function) {
+let lazyConnect = function (tracer: Tracer, station: MailStation, serverId: string, factory: IMailBoxFactory, msg: any, cb: Function) {
     tracer && tracer.info('client', __filename, 'lazyConnect', 'create mailbox and try to connect to remote server');
     let server = station.servers[serverId];
     let online = station.onlines[serverId];
@@ -431,7 +431,7 @@ let lazyConnect = function (tracer: Tracer, station: MailStation, serverId: stri
     let mailbox = factory(server, station.opts as MailBoxOpts);
     station.connecting[serverId] = true;
     station.mailboxes[serverId] = mailbox;
-    station.connect(tracer, serverId, cb);
+    station.connect(tracer, serverId, msg, cb);
     return true;
 };
 
@@ -485,4 +485,4 @@ let errorHandler = function (tracer: Tracer, station: MailStation, err: Error, s
  */
 export function createMailStation(opts?: MailStationOpts) {
     return new MailStation(opts || {});
-}
\ No newline at end of file
+}