resume the account from standard message
        这个是从数据库恢复账户时需要的
15084
def from_message(self, message):
        """"""
        self.account_cookie = message.get('account_cookie', None)
        self.portfolio_cookie = message.get('portfolio_cookie', None)
        self.user_cookie = message.get('user_cookie', None)
        self.broker = message.get('broker', None)
        self.market_type = message.get('market_type', None)
        self.strategy_name = message.get('strategy_name', None)
        self._currenttime = message.get('current_time', None)
        self.allow_sellopen = message.get('allow_sellopen', False)
        self.allow_margin = message.get('allow_margin', False)
        self.allow_t0 = message.get('allow_t0', False)
        self.margin_level = message.get('margin_level', False)
        self.frequence = message.get('frequence', FREQUENCE.FIFTEEN_MIN) #默认15min
        self.init_cash = message.get(
            'init_cash',
            message.get('init_assets',
                        1000000)
        )                                       # 兼容修改
        self.init_hold = pd.Series(message.get('init_hold', {}), name='amount')
        self.init_hold.index.name = 'code'
        self.commission_coeff = message.get('commission_coeff', 0.00015)
        self.tax_coeff = message.get('tax_coeff', 0.0015)
        self.history = message['history']
        self.cash = message['cash']
        self.time_index_max = message['trade_index']
        self.running_time = message.get('running_time', None)
        self.quantaxis_version = message.get('quantaxis_version', None)
        self.running_environment = message.get(
            'running_environment',
            RUNNING_ENVIRONMENT.BACKETEST
        )
        self.frozen = message.get('frozen', {})
        self.finishedOrderid = message.get('finished_id', [])
        self.settle()
        return self
383758
def methodReturnReceived(self, mret):
        
        d, timeout = self._pendingCalls.get(mret.reply_serial, (None, None))
        if timeout:
            timeout.cancel()
        if d:
            del self._pendingCalls[mret.reply_serial]
            d.callback(mret)
816047
def cancel(self):
        """"""
        d = self.request('post', self.instance_url() + '/cancel')
        return d.addCallback(self.refresh_from)
740683
def exit(self, status=0, message=None):
        
        if message:
            raise HelpBanner(message.strip(), code=status)
1229076
def resume(self):
        ""

        if '_saved' not in vars(self):
            return

        type, exc = map(pickle.loads, self._saved)
        six.reraise(type, exc, self._tb)
1047393
def resume(instance_id, profile=None, **kwargs):
    '''
    

    '''
    conn = _auth(profile, **kwargs)
    return conn.resume(instance_id)
169856
def resume(self):
        """"""
        with self._wake:
            self._paused = False
            self._wake.notifyAll()
142814
def resume(self, trigger_duration=0):
        """"""
        if trigger_duration != 0:
            self._mq.send("t%d" % trigger_duration, True, type=1)
        else:
            self._mq.send("r", True, type=1)
        self._paused = False
101488
private void reset()
  {
    if (tc.isEntryEnabled())
      SibTr.entry(tc, "reset");

    if (iInitialised)
    {
      // Reset the ArrayLists associated with this message        
      iTopics.clear();
      iTopicSpaces.clear();
      iTopicSpaceMappings.clear();

      // Create a new message to send to this Neighbour.
      iSubscriptionMessage = createSubscriptionMessage();
    }
    else
    {
      iInitialised = true;
    }

    if (tc.isEntryEnabled())
      SibTr.exit(tc, "reset");
  }
478014
def quit(self, message=None):
        """"""
        if message is None:
            message = 'Quit'

        if self.connected:
            self.send('QUIT', params=[message])
249386
def erase(self, message=None):
        """"""
        if not message:
            message = self.last_message
        # Move cursor to the beginning of line
        super(Animation, self).write("\033[G")
        # Erase in line from cursor
        super(Animation, self).write("\033[K")
329027
public function resumeRecv()
    {
        if ($this->_isPaused === true) {
            Worker::$globalEvent->add($this->_socket, EventInterface::EV_READ, array($this, 'baseRead'));
            $this->_isPaused = false;
            $this->baseRead($this->_socket, false);
        }
    }
471673
def process_account(self, message):
        
        self.on_account(AccountUpdate(message, blockchain_instance=self.blockchain))
952717
def pause(self):
        """"""
        self._mq.send("p", True, type=1)
        self._paused = True
1257773
function resumeSubscriptionDispatcher (
    topic, data, options, subscriptions, resolver, fulfill, reject
  ) {
    var
      promise = resolver.promise,

      subscription;

    for (
      ;
      resolver.i >= 0 && promise.pending < options.semaphor;
      resolver.i -= 1
    ) {
      subscription = subscriptions[resolver.i];
      if (!subscription.suspended) {
        promise.pending += 1;
        subscriptionInvoker(subscription, data, topic).then(fulfill, reject);
      }
    }
  }
1030283
def pause
      msg = pause_message
      $pause_output_out.write(msg)

      MiniTerm.raw do |term|
        result = term.get_raw_char
        term.flush
        result
      end

    ensure
      $pause_output_out.write("\r" + " " * msg.length + "\r")
    end
1225201
private function resetMessage()
    {
        $this->subject = '';
        $this->from = [];
        $this->sender = [];
        $this->to = [];
        $this->cc = [];
        $this->bcc = [];
        $this->reply_to = [];
        $this->attachments = [];
        $this->message_layout->setViewLayout('');
        $this->message_layout->setViewTemplate('');
        $this->message_layout->clearVariables();
    }