WPWithin.py 文件源码

def process_beginServiceDelivery(self, seqid, iprot, oprot):
        args = beginServiceDelivery_args()
        args.read(iprot)
        iprot.readMessageEnd()
        result = beginServiceDelivery_result()
        try:
            result.success = self._handler.beginServiceDelivery(args.serviceID, args.serviceDeliveryToken, args.unitsToSupply)
            msg_type = TMessageType.REPLY
        except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
            raise
        except wpwithinpy.wpthrift_types.ttypes.Error as err:
            msg_type = TMessageType.REPLY
            result.err = err
        except Exception as ex:
            msg_type = TMessageType.EXCEPTION
            logging.exception(ex)
            result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
        oprot.writeMessageBegin("beginServiceDelivery", msg_type, seqid)
        result.write(oprot)
        oprot.writeMessageEnd()
        oprot.trans.flush()