php Thrift-Exception-TApplicationException模块，常用函数和类-面圈网

作者：RedRom 项目：aroma-thrif

public function recv_healthPoke()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\RedRoma\\Aroma\\Endpoint\\ApplicationEndpoint_healthPoke_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \RedRoma\Aroma\Endpoint\ApplicationEndpoint_healthPoke_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     if ($result->ex1 !== null) {
         throw $result->ex1;
     }
     throw new \Exception("healthPoke failed: unknown result");
 }

作者：pozypaky 项目：php-impal

public function recv_UpdateState()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\Impala\\StateStoreSubscriber_UpdateState_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \Impala\StateStoreSubscriber_UpdateState_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     throw new \Exception("UpdateState failed: unknown result");
 }

作者：munki 项目：elasticsearch-thrift-ph

public function recv_execute()
 {
     $bin_accel = $this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\Elasticsearch\\Rest_execute_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \Elasticsearch\Rest_execute_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     throw new \Exception("execute failed: unknown result");
 }

作者：lightste 项目：lightstep-tracer-ph

public function recv_Report()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\CroutonThrift\\ReportingService_Report_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \CroutonThrift\ReportingService_Report_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     throw new \Exception("Report failed: unknown result");
 }

作者：xietonglin 项目：IcansLoggingComponen

public function recv_close()
 {
     $bin_accel = $this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\ICANS\\Component\\IcansLoggingComponent\\Flume\\ThriftFlumeEventServer_close_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \ICANS\Component\IcansLoggingComponent\Flume\ThriftFlumeEventServer_close_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     return;
 }

作者：smallsnailbigdrea 项目：evernote-cloud-sdk-ph

public function recv_getNoteStoreUrl()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\EDAM\\UserStore\\UserStore_getNoteStoreUrl_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \EDAM\UserStore\UserStore_getNoteStoreUrl_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     if ($result->userException !== null) {
         throw $result->userException;
     }
     if ($result->systemException !== null) {
         throw $result->systemException;
     }
     throw new \Exception("getNoteStoreUrl failed: unknown result");
 }

作者：mol 项目：php-thrift-optimiz

/**
  * @param array $args
  * @throws \Thrift\Exception\TApplicationException
  * @throws \Exception
  * @return mixed
  */
 public function recv($args = array())
 {
     $rseqid = 0;
     $fname = null;
     $mtype = 0;
     $this->input->readMessageBegin($fname, $mtype, $rseqid);
     if ($mtype == TMessageType::EXCEPTION) {
         $x = new TApplicationException();
         $x->read($this->input);
         $this->input->readMessageEnd();
         throw $x;
     }
     $this->read($args);
     $this->input->readMessageEnd();
     foreach ($args as $arg) {
         if ($arg['type'] == TType::STRUCT && isset($arg['value']) && $arg['value'] instanceof \Exception) {
             throw $arg['value'];
         } else {
             if (isset($arg['value']) && $arg['value'] !== null) {
                 return $arg['value'];
             }
         }
     }
     return null;
 }

作者：pozypaky 项目：php_impala_pha

public function recv_ShutdownServer()
 {
     $bin_accel = $this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\ImpalaPlanService_ShutdownServer_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \ImpalaPlanService_ShutdownServer_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     return;
 }

作者：priyanshu-sekha 项目：hiv

public function recv_clean()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\ThriftHive_clean_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \ThriftHive_clean_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     return;
 }

作者：covertcodeo 项目：hypertabl

public function recv_hql_query2()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\Hypertable_ThriftGen2\\HqlService_hql_query2_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \Hypertable_ThriftGen2\HqlService_hql_query2_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     if ($result->e !== null) {
         throw $result->e;
     }
     throw new \Exception("hql_query2 failed: unknown result");
 }

作者：boxalin 项目：dataintelligence-client-ph

public function recv_GetBehaviorReport()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\com\\boxalino\\dataintelligence\\api\\thrift\\BoxalinoDataIntelligence_GetBehaviorReport_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \com\boxalino\dataintelligence\api\thrift\BoxalinoDataIntelligence_GetBehaviorReport_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     if ($result->e !== null) {
         throw $result->e;
     }
     throw new \Exception("GetBehaviorReport failed: unknown result");
 }

作者：hzshar 项目：cloudharddis

public function process($input, $output)
 {
     $rseqid = 0;
     $fname = null;
     $mtype = 0;
     $input->readMessageBegin($fname, $mtype, $rseqid);
     $methodname = 'process_' . $fname;
     if (!method_exists($this, $methodname)) {
         $input->skip(TType::STRUCT);
         $input->readMessageEnd();
         $x = new TApplicationException('Function ' . $fname . ' not implemented.', TApplicationException::UNKNOWN_METHOD);
         $output->writeMessageBegin($fname, TMessageType::EXCEPTION, $rseqid);
         $x->write($output);
         $output->writeMessageEnd();
         $output->getTransport()->flush();
         return;
     }
     $this->{$methodname}($rseqid, $input, $output);
     return true;
 }

作者：syxoasi 项目：wakfu-serve

public function recv_pac()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\net\\toruneko\\wakfu\\interfaces\\WakfuService_pac_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \net\toruneko\wakfu\interfaces\WakfuService_pac_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     throw new \Exception("pac failed: unknown result");
 }

作者：xiaoyueer9 项目：app.heimi.co

public function recv_getCardRechargeList()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\Thrift\\Server\\CardCenterService_getCardRechargeList_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \Thrift\Server\CardCenterService_getCardRechargeList_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     if ($result->dataNotFound !== null) {
         throw $result->dataNotFound;
     }
     throw new \Exception("getCardRechargeList failed: unknown result");
 }

作者：kidaa 项目：airavata-sandbo

public function recv_getAllUserSSHPubKeys()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\Airavata\\API\\Credentials\\CredentialManagementService_getAllUserSSHPubKeys_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \Airavata\API\Credentials\CredentialManagementService_getAllUserSSHPubKeys_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     throw new \Exception("getAllUserSSHPubKeys failed: unknown result");
 }

作者：priyank201 项目：airavata-php-gatewa

public function recv_isWorkflowExistWithName()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\Airavata\\API\\Workflow_isWorkflowExistWithName_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \Airavata\API\Workflow_isWorkflowExistWithName_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     if ($result->ire !== null) {
         throw $result->ire;
     }
     if ($result->ace !== null) {
         throw $result->ace;
     }
     if ($result->ase !== null) {
         throw $result->ase;
     }
     throw new \Exception("isWorkflowExistWithName failed: unknown result");
 }

作者：atomicjet 项目：phpcass

public function recv_set_cql_version()
 {
     if ($this->bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\cassandra\\Cassandra_set_cql_version_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \cassandra\Cassandra_set_cql_version_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->ire !== null) {
         throw $result->ire;
     }
     return;
 }

作者：boxalin 项目：plugin-shopwar

public function recv_updateChoice()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\com\\boxalino\\p13n\\api\\thrift\\P13nService_updateChoice_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \com\boxalino\p13n\api\thrift\P13nService_updateChoice_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     if ($result->p13nServiceException !== null) {
         throw $result->p13nServiceException;
     }
     throw new \Exception("updateChoice failed: unknown result");
 }

作者：Napa 项目：php-thrift-sq

public function recv_GetExecSummary()
 {
     $bin_accel = $this->input_ instanceof TBinaryProtocolAccelerated && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\ThriftSQL\\ImpalaService_GetExecSummary_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \ThriftSQL\ImpalaService_GetExecSummary_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->success !== null) {
         return $result->success;
     }
     if ($result->error !== null) {
         throw $result->error;
     }
     if ($result->error2 !== null) {
         throw $result->error2;
     }
     throw new \Exception("GetExecSummary failed: unknown result");
 }

作者：pozypaky 项目：php_impala_pha

public function recv_cancel_delegation_token()
 {
     $bin_accel = $this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED && function_exists('thrift_protocol_read_binary');
     if ($bin_accel) {
         $result = thrift_protocol_read_binary($this->input_, '\\metastore\\ThriftHiveMetastore_cancel_delegation_token_result', $this->input_->isStrictRead());
     } else {
         $rseqid = 0;
         $fname = null;
         $mtype = 0;
         $this->input_->readMessageBegin($fname, $mtype, $rseqid);
         if ($mtype == TMessageType::EXCEPTION) {
             $x = new TApplicationException();
             $x->read($this->input_);
             $this->input_->readMessageEnd();
             throw $x;
         }
         $result = new \metastore\ThriftHiveMetastore_cancel_delegation_token_result();
         $result->read($this->input_);
         $this->input_->readMessageEnd();
     }
     if ($result->o1 !== null) {
         throw $result->o1;
     }
     return;
 }

php Thrift-Exception-TApplicationException类(方法)实例源码