WuXianChaoPin
7 years ago
parent
bd22c80270
commit
e73354701b
@ -0,0 +1,496 @@ |
|||||||
|
/** |
||||||
|
* Autogenerated by Thrift Compiler (0.11.0) |
||||||
|
* |
||||||
|
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING |
||||||
|
* @generated |
||||||
|
*/ |
||||||
|
package org.pqh.thrift; |
||||||
|
|
||||||
|
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
||||||
|
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)", date = "2018-04-28") |
||||||
|
public class QryResult implements org.apache.thrift.TBase<QryResult, QryResult._Fields>, java.io.Serializable, Cloneable, Comparable<QryResult> { |
||||||
|
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("QryResult"); |
||||||
|
|
||||||
|
private static final org.apache.thrift.protocol.TField CODE_FIELD_DESC = new org.apache.thrift.protocol.TField("code", org.apache.thrift.protocol.TType.I32, (short)1); |
||||||
|
private static final org.apache.thrift.protocol.TField MSG_FIELD_DESC = new org.apache.thrift.protocol.TField("msg", org.apache.thrift.protocol.TType.STRING, (short)2); |
||||||
|
|
||||||
|
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new QryResultStandardSchemeFactory(); |
||||||
|
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new QryResultTupleSchemeFactory(); |
||||||
|
|
||||||
|
/** |
||||||
|
* 返回码, 1成功，0失败 |
||||||
|
*/ |
||||||
|
public int code; // required
|
||||||
|
/** |
||||||
|
* 响应信息 |
||||||
|
*/ |
||||||
|
public java.lang.String msg; // required
|
||||||
|
|
||||||
|
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ |
||||||
|
public enum _Fields implements org.apache.thrift.TFieldIdEnum { |
||||||
|
/** |
||||||
|
* 返回码, 1成功，0失败 |
||||||
|
*/ |
||||||
|
CODE((short)1, "code"), |
||||||
|
/** |
||||||
|
* 响应信息 |
||||||
|
*/ |
||||||
|
MSG((short)2, "msg"); |
||||||
|
|
||||||
|
private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
||||||
|
|
||||||
|
static { |
||||||
|
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
||||||
|
byName.put(field.getFieldName(), field); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches fieldId, or null if its not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByThriftId(int fieldId) { |
||||||
|
switch(fieldId) { |
||||||
|
case 1: // CODE
|
||||||
|
return CODE; |
||||||
|
case 2: // MSG
|
||||||
|
return MSG; |
||||||
|
default: |
||||||
|
return null; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches fieldId, throwing an exception |
||||||
|
* if it is not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByThriftIdOrThrow(int fieldId) { |
||||||
|
_Fields fields = findByThriftId(fieldId); |
||||||
|
if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
||||||
|
return fields; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches name, or null if its not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByName(java.lang.String name) { |
||||||
|
return byName.get(name); |
||||||
|
} |
||||||
|
|
||||||
|
private final short _thriftId; |
||||||
|
private final java.lang.String _fieldName; |
||||||
|
|
||||||
|
_Fields(short thriftId, java.lang.String fieldName) { |
||||||
|
_thriftId = thriftId; |
||||||
|
_fieldName = fieldName; |
||||||
|
} |
||||||
|
|
||||||
|
public short getThriftFieldId() { |
||||||
|
return _thriftId; |
||||||
|
} |
||||||
|
|
||||||
|
public java.lang.String getFieldName() { |
||||||
|
return _fieldName; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
// isset id assignments
|
||||||
|
private static final int __CODE_ISSET_ID = 0; |
||||||
|
private byte __isset_bitfield = 0; |
||||||
|
public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
||||||
|
static { |
||||||
|
java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); |
||||||
|
tmpMap.put(_Fields.CODE, new org.apache.thrift.meta_data.FieldMetaData("code", org.apache.thrift.TFieldRequirementType.DEFAULT, |
||||||
|
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); |
||||||
|
tmpMap.put(_Fields.MSG, new org.apache.thrift.meta_data.FieldMetaData("msg", org.apache.thrift.TFieldRequirementType.DEFAULT, |
||||||
|
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); |
||||||
|
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
||||||
|
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(QryResult.class, metaDataMap); |
||||||
|
} |
||||||
|
|
||||||
|
public QryResult() { |
||||||
|
} |
||||||
|
|
||||||
|
public QryResult( |
||||||
|
int code, |
||||||
|
java.lang.String msg) |
||||||
|
{ |
||||||
|
this(); |
||||||
|
this.code = code; |
||||||
|
setCodeIsSet(true); |
||||||
|
this.msg = msg; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Performs a deep copy on <i>other</i>. |
||||||
|
*/ |
||||||
|
public QryResult(QryResult other) { |
||||||
|
__isset_bitfield = other.__isset_bitfield; |
||||||
|
this.code = other.code; |
||||||
|
if (other.isSetMsg()) { |
||||||
|
this.msg = other.msg; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public QryResult deepCopy() { |
||||||
|
return new QryResult(this); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void clear() { |
||||||
|
setCodeIsSet(false); |
||||||
|
this.code = 0; |
||||||
|
this.msg = null; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 返回码, 1成功，0失败 |
||||||
|
*/ |
||||||
|
public int getCode() { |
||||||
|
return this.code; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 返回码, 1成功，0失败 |
||||||
|
*/ |
||||||
|
public QryResult setCode(int code) { |
||||||
|
this.code = code; |
||||||
|
setCodeIsSet(true); |
||||||
|
return this; |
||||||
|
} |
||||||
|
|
||||||
|
public void unsetCode() { |
||||||
|
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __CODE_ISSET_ID); |
||||||
|
} |
||||||
|
|
||||||
|
/** Returns true if field code is set (has been assigned a value) and false otherwise */ |
||||||
|
public boolean isSetCode() { |
||||||
|
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __CODE_ISSET_ID); |
||||||
|
} |
||||||
|
|
||||||
|
public void setCodeIsSet(boolean value) { |
||||||
|
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __CODE_ISSET_ID, value); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 响应信息 |
||||||
|
*/ |
||||||
|
public java.lang.String getMsg() { |
||||||
|
return this.msg; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 响应信息 |
||||||
|
*/ |
||||||
|
public QryResult setMsg(java.lang.String msg) { |
||||||
|
this.msg = msg; |
||||||
|
return this; |
||||||
|
} |
||||||
|
|
||||||
|
public void unsetMsg() { |
||||||
|
this.msg = null; |
||||||
|
} |
||||||
|
|
||||||
|
/** Returns true if field msg is set (has been assigned a value) and false otherwise */ |
||||||
|
public boolean isSetMsg() { |
||||||
|
return this.msg != null; |
||||||
|
} |
||||||
|
|
||||||
|
public void setMsgIsSet(boolean value) { |
||||||
|
if (!value) { |
||||||
|
this.msg = null; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public void setFieldValue(_Fields field, java.lang.Object value) { |
||||||
|
switch (field) { |
||||||
|
case CODE: |
||||||
|
if (value == null) { |
||||||
|
unsetCode(); |
||||||
|
} else { |
||||||
|
setCode((java.lang.Integer)value); |
||||||
|
} |
||||||
|
break; |
||||||
|
|
||||||
|
case MSG: |
||||||
|
if (value == null) { |
||||||
|
unsetMsg(); |
||||||
|
} else { |
||||||
|
setMsg((java.lang.String)value); |
||||||
|
} |
||||||
|
break; |
||||||
|
|
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public java.lang.Object getFieldValue(_Fields field) { |
||||||
|
switch (field) { |
||||||
|
case CODE: |
||||||
|
return getCode(); |
||||||
|
|
||||||
|
case MSG: |
||||||
|
return getMsg(); |
||||||
|
|
||||||
|
} |
||||||
|
throw new java.lang.IllegalStateException(); |
||||||
|
} |
||||||
|
|
||||||
|
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
||||||
|
public boolean isSet(_Fields field) { |
||||||
|
if (field == null) { |
||||||
|
throw new java.lang.IllegalArgumentException(); |
||||||
|
} |
||||||
|
|
||||||
|
switch (field) { |
||||||
|
case CODE: |
||||||
|
return isSetCode(); |
||||||
|
case MSG: |
||||||
|
return isSetMsg(); |
||||||
|
} |
||||||
|
throw new java.lang.IllegalStateException(); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public boolean equals(java.lang.Object that) { |
||||||
|
if (that == null) |
||||||
|
return false; |
||||||
|
if (that instanceof QryResult) |
||||||
|
return this.equals((QryResult)that); |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
public boolean equals(QryResult that) { |
||||||
|
if (that == null) |
||||||
|
return false; |
||||||
|
if (this == that) |
||||||
|
return true; |
||||||
|
|
||||||
|
boolean this_present_code = true; |
||||||
|
boolean that_present_code = true; |
||||||
|
if (this_present_code || that_present_code) { |
||||||
|
if (!(this_present_code && that_present_code)) |
||||||
|
return false; |
||||||
|
if (this.code != that.code) |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
boolean this_present_msg = true && this.isSetMsg(); |
||||||
|
boolean that_present_msg = true && that.isSetMsg(); |
||||||
|
if (this_present_msg || that_present_msg) { |
||||||
|
if (!(this_present_msg && that_present_msg)) |
||||||
|
return false; |
||||||
|
if (!this.msg.equals(that.msg)) |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
return true; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public int hashCode() { |
||||||
|
int hashCode = 1; |
||||||
|
|
||||||
|
hashCode = hashCode * 8191 + code; |
||||||
|
|
||||||
|
hashCode = hashCode * 8191 + ((isSetMsg()) ? 131071 : 524287); |
||||||
|
if (isSetMsg()) |
||||||
|
hashCode = hashCode * 8191 + msg.hashCode(); |
||||||
|
|
||||||
|
return hashCode; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public int compareTo(QryResult other) { |
||||||
|
if (!getClass().equals(other.getClass())) { |
||||||
|
return getClass().getName().compareTo(other.getClass().getName()); |
||||||
|
} |
||||||
|
|
||||||
|
int lastComparison = 0; |
||||||
|
|
||||||
|
lastComparison = java.lang.Boolean.valueOf(isSetCode()).compareTo(other.isSetCode()); |
||||||
|
if (lastComparison != 0) { |
||||||
|
return lastComparison; |
||||||
|
} |
||||||
|
if (isSetCode()) { |
||||||
|
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.code, other.code); |
||||||
|
if (lastComparison != 0) { |
||||||
|
return lastComparison; |
||||||
|
} |
||||||
|
} |
||||||
|
lastComparison = java.lang.Boolean.valueOf(isSetMsg()).compareTo(other.isSetMsg()); |
||||||
|
if (lastComparison != 0) { |
||||||
|
return lastComparison; |
||||||
|
} |
||||||
|
if (isSetMsg()) { |
||||||
|
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.msg, other.msg); |
||||||
|
if (lastComparison != 0) { |
||||||
|
return lastComparison; |
||||||
|
} |
||||||
|
} |
||||||
|
return 0; |
||||||
|
} |
||||||
|
|
||||||
|
public _Fields fieldForId(int fieldId) { |
||||||
|
return _Fields.findByThriftId(fieldId); |
||||||
|
} |
||||||
|
|
||||||
|
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
||||||
|
scheme(iprot).read(iprot, this); |
||||||
|
} |
||||||
|
|
||||||
|
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
||||||
|
scheme(oprot).write(oprot, this); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public java.lang.String toString() { |
||||||
|
java.lang.StringBuilder sb = new java.lang.StringBuilder("QryResult("); |
||||||
|
boolean first = true; |
||||||
|
|
||||||
|
sb.append("code:"); |
||||||
|
sb.append(this.code); |
||||||
|
first = false; |
||||||
|
if (!first) sb.append(", "); |
||||||
|
sb.append("msg:"); |
||||||
|
if (this.msg == null) { |
||||||
|
sb.append("null"); |
||||||
|
} else { |
||||||
|
sb.append(this.msg); |
||||||
|
} |
||||||
|
first = false; |
||||||
|
sb.append(")"); |
||||||
|
return sb.toString(); |
||||||
|
} |
||||||
|
|
||||||
|
public void validate() throws org.apache.thrift.TException { |
||||||
|
// check for required fields
|
||||||
|
// check for sub-struct validity
|
||||||
|
} |
||||||
|
|
||||||
|
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { |
||||||
|
try { |
||||||
|
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); |
||||||
|
} catch (org.apache.thrift.TException te) { |
||||||
|
throw new java.io.IOException(te); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException { |
||||||
|
try { |
||||||
|
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
|
||||||
|
__isset_bitfield = 0; |
||||||
|
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); |
||||||
|
} catch (org.apache.thrift.TException te) { |
||||||
|
throw new java.io.IOException(te); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class QryResultStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
||||||
|
public QryResultStandardScheme getScheme() { |
||||||
|
return new QryResultStandardScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class QryResultStandardScheme extends org.apache.thrift.scheme.StandardScheme<QryResult> { |
||||||
|
|
||||||
|
public void read(org.apache.thrift.protocol.TProtocol iprot, QryResult struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TField schemeField; |
||||||
|
iprot.readStructBegin(); |
||||||
|
while (true) |
||||||
|
{ |
||||||
|
schemeField = iprot.readFieldBegin(); |
||||||
|
if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { |
||||||
|
break; |
||||||
|
} |
||||||
|
switch (schemeField.id) { |
||||||
|
case 1: // CODE
|
||||||
|
if (schemeField.type == org.apache.thrift.protocol.TType.I32) { |
||||||
|
struct.code = iprot.readI32(); |
||||||
|
struct.setCodeIsSet(true); |
||||||
|
} else { |
||||||
|
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
||||||
|
} |
||||||
|
break; |
||||||
|
case 2: // MSG
|
||||||
|
if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { |
||||||
|
struct.msg = iprot.readString(); |
||||||
|
struct.setMsgIsSet(true); |
||||||
|
} else { |
||||||
|
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
||||||
|
} |
||||||
|
break; |
||||||
|
default: |
||||||
|
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
||||||
|
} |
||||||
|
iprot.readFieldEnd(); |
||||||
|
} |
||||||
|
iprot.readStructEnd(); |
||||||
|
|
||||||
|
// check for required fields of primitive type, which can't be checked in the validate method
|
||||||
|
struct.validate(); |
||||||
|
} |
||||||
|
|
||||||
|
public void write(org.apache.thrift.protocol.TProtocol oprot, QryResult struct) throws org.apache.thrift.TException { |
||||||
|
struct.validate(); |
||||||
|
|
||||||
|
oprot.writeStructBegin(STRUCT_DESC); |
||||||
|
oprot.writeFieldBegin(CODE_FIELD_DESC); |
||||||
|
oprot.writeI32(struct.code); |
||||||
|
oprot.writeFieldEnd(); |
||||||
|
if (struct.msg != null) { |
||||||
|
oprot.writeFieldBegin(MSG_FIELD_DESC); |
||||||
|
oprot.writeString(struct.msg); |
||||||
|
oprot.writeFieldEnd(); |
||||||
|
} |
||||||
|
oprot.writeFieldStop(); |
||||||
|
oprot.writeStructEnd(); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private static class QryResultTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
||||||
|
public QryResultTupleScheme getScheme() { |
||||||
|
return new QryResultTupleScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class QryResultTupleScheme extends org.apache.thrift.scheme.TupleScheme<QryResult> { |
||||||
|
|
||||||
|
@Override |
||||||
|
public void write(org.apache.thrift.protocol.TProtocol prot, QryResult struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
||||||
|
java.util.BitSet optionals = new java.util.BitSet(); |
||||||
|
if (struct.isSetCode()) { |
||||||
|
optionals.set(0); |
||||||
|
} |
||||||
|
if (struct.isSetMsg()) { |
||||||
|
optionals.set(1); |
||||||
|
} |
||||||
|
oprot.writeBitSet(optionals, 2); |
||||||
|
if (struct.isSetCode()) { |
||||||
|
oprot.writeI32(struct.code); |
||||||
|
} |
||||||
|
if (struct.isSetMsg()) { |
||||||
|
oprot.writeString(struct.msg); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void read(org.apache.thrift.protocol.TProtocol prot, QryResult struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
||||||
|
java.util.BitSet incoming = iprot.readBitSet(2); |
||||||
|
if (incoming.get(0)) { |
||||||
|
struct.code = iprot.readI32(); |
||||||
|
struct.setCodeIsSet(true); |
||||||
|
} |
||||||
|
if (incoming.get(1)) { |
||||||
|
struct.msg = iprot.readString(); |
||||||
|
struct.setMsgIsSet(true); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
||||||
|
return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
@ -0,0 +1,971 @@ |
|||||||
|
/** |
||||||
|
* Autogenerated by Thrift Compiler (0.11.0) |
||||||
|
* |
||||||
|
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING |
||||||
|
* @generated |
||||||
|
*/ |
||||||
|
package org.pqh.thrift; |
||||||
|
|
||||||
|
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked", "unused"}) |
||||||
|
@javax.annotation.Generated(value = "Autogenerated by Thrift Compiler (0.11.0)", date = "2018-04-28") |
||||||
|
public class TestQry { |
||||||
|
|
||||||
|
public interface Iface { |
||||||
|
|
||||||
|
/** |
||||||
|
* 测试查询接口，当qryCode值为1时返回"成功"的响应信息，qryCode值为其他值时返回"失败"的响应信息 |
||||||
|
* @param qryCode测试参数 |
||||||
|
* |
||||||
|
* @param qryCode |
||||||
|
*/ |
||||||
|
public QryResult qryTest(int qryCode) throws org.apache.thrift.TException; |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
public interface AsyncIface { |
||||||
|
|
||||||
|
public void qryTest(int qryCode, org.apache.thrift.async.AsyncMethodCallback<QryResult> resultHandler) throws org.apache.thrift.TException; |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
public static class Client extends org.apache.thrift.TServiceClient implements Iface { |
||||||
|
public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> { |
||||||
|
public Factory() {} |
||||||
|
public Client getClient(org.apache.thrift.protocol.TProtocol prot) { |
||||||
|
return new Client(prot); |
||||||
|
} |
||||||
|
public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { |
||||||
|
return new Client(iprot, oprot); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public Client(org.apache.thrift.protocol.TProtocol prot) |
||||||
|
{ |
||||||
|
super(prot, prot); |
||||||
|
} |
||||||
|
|
||||||
|
public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) { |
||||||
|
super(iprot, oprot); |
||||||
|
} |
||||||
|
|
||||||
|
public QryResult qryTest(int qryCode) throws org.apache.thrift.TException |
||||||
|
{ |
||||||
|
send_qryTest(qryCode); |
||||||
|
return recv_qryTest(); |
||||||
|
} |
||||||
|
|
||||||
|
public void send_qryTest(int qryCode) throws org.apache.thrift.TException |
||||||
|
{ |
||||||
|
qryTest_args args = new qryTest_args(); |
||||||
|
args.setQryCode(qryCode); |
||||||
|
sendBase("qryTest", args); |
||||||
|
} |
||||||
|
|
||||||
|
public QryResult recv_qryTest() throws org.apache.thrift.TException |
||||||
|
{ |
||||||
|
qryTest_result result = new qryTest_result(); |
||||||
|
receiveBase(result, "qryTest"); |
||||||
|
if (result.isSetSuccess()) { |
||||||
|
return result.success; |
||||||
|
} |
||||||
|
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "qryTest failed: unknown result"); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
public static class AsyncClient extends org.apache.thrift.async.TAsyncClient implements AsyncIface { |
||||||
|
public static class Factory implements org.apache.thrift.async.TAsyncClientFactory<AsyncClient> { |
||||||
|
private org.apache.thrift.async.TAsyncClientManager clientManager; |
||||||
|
private org.apache.thrift.protocol.TProtocolFactory protocolFactory; |
||||||
|
public Factory(org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.protocol.TProtocolFactory protocolFactory) { |
||||||
|
this.clientManager = clientManager; |
||||||
|
this.protocolFactory = protocolFactory; |
||||||
|
} |
||||||
|
public AsyncClient getAsyncClient(org.apache.thrift.transport.TNonblockingTransport transport) { |
||||||
|
return new AsyncClient(protocolFactory, clientManager, transport); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public AsyncClient(org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.async.TAsyncClientManager clientManager, org.apache.thrift.transport.TNonblockingTransport transport) { |
||||||
|
super(protocolFactory, clientManager, transport); |
||||||
|
} |
||||||
|
|
||||||
|
public void qryTest(int qryCode, org.apache.thrift.async.AsyncMethodCallback<QryResult> resultHandler) throws org.apache.thrift.TException { |
||||||
|
checkReady(); |
||||||
|
qryTest_call method_call = new qryTest_call(qryCode, resultHandler, this, ___protocolFactory, ___transport); |
||||||
|
this.___currentMethod = method_call; |
||||||
|
___manager.call(method_call); |
||||||
|
} |
||||||
|
|
||||||
|
public static class qryTest_call extends org.apache.thrift.async.TAsyncMethodCall<QryResult> { |
||||||
|
private int qryCode; |
||||||
|
public qryTest_call(int qryCode, org.apache.thrift.async.AsyncMethodCallback<QryResult> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException { |
||||||
|
super(client, protocolFactory, transport, resultHandler, false); |
||||||
|
this.qryCode = qryCode; |
||||||
|
} |
||||||
|
|
||||||
|
public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException { |
||||||
|
prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("qryTest", org.apache.thrift.protocol.TMessageType.CALL, 0)); |
||||||
|
qryTest_args args = new qryTest_args(); |
||||||
|
args.setQryCode(qryCode); |
||||||
|
args.write(prot); |
||||||
|
prot.writeMessageEnd(); |
||||||
|
} |
||||||
|
|
||||||
|
public QryResult getResult() throws org.apache.thrift.TException { |
||||||
|
if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) { |
||||||
|
throw new java.lang.IllegalStateException("Method call not finished!"); |
||||||
|
} |
||||||
|
org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array()); |
||||||
|
org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport); |
||||||
|
return (new Client(prot)).recv_qryTest(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
public static class Processor<I extends Iface> extends org.apache.thrift.TBaseProcessor<I> implements org.apache.thrift.TProcessor { |
||||||
|
private static final org.slf4j.Logger _LOGGER = org.slf4j.LoggerFactory.getLogger(Processor.class.getName()); |
||||||
|
public Processor(I iface) { |
||||||
|
super(iface, getProcessMap(new java.util.HashMap<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>>())); |
||||||
|
} |
||||||
|
|
||||||
|
protected Processor(I iface, java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { |
||||||
|
super(iface, getProcessMap(processMap)); |
||||||
|
} |
||||||
|
|
||||||
|
private static <I extends Iface> java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> getProcessMap(java.util.Map<java.lang.String, org.apache.thrift.ProcessFunction<I, ? extends org.apache.thrift.TBase>> processMap) { |
||||||
|
processMap.put("qryTest", new qryTest()); |
||||||
|
return processMap; |
||||||
|
} |
||||||
|
|
||||||
|
public static class qryTest<I extends Iface> extends org.apache.thrift.ProcessFunction<I, qryTest_args> { |
||||||
|
public qryTest() { |
||||||
|
super("qryTest"); |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_args getEmptyArgsInstance() { |
||||||
|
return new qryTest_args(); |
||||||
|
} |
||||||
|
|
||||||
|
protected boolean isOneway() { |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
protected boolean handleRuntimeExceptions() { |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_result getResult(I iface, qryTest_args args) throws org.apache.thrift.TException { |
||||||
|
qryTest_result result = new qryTest_result(); |
||||||
|
result.success = iface.qryTest(args.qryCode); |
||||||
|
return result; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
public static class AsyncProcessor<I extends AsyncIface> extends org.apache.thrift.TBaseAsyncProcessor<I> { |
||||||
|
private static final org.slf4j.Logger _LOGGER = org.slf4j.LoggerFactory.getLogger(AsyncProcessor.class.getName()); |
||||||
|
public AsyncProcessor(I iface) { |
||||||
|
super(iface, getProcessMap(new java.util.HashMap<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>>())); |
||||||
|
} |
||||||
|
|
||||||
|
protected AsyncProcessor(I iface, java.util.Map<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { |
||||||
|
super(iface, getProcessMap(processMap)); |
||||||
|
} |
||||||
|
|
||||||
|
private static <I extends AsyncIface> java.util.Map<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase,?>> getProcessMap(java.util.Map<java.lang.String, org.apache.thrift.AsyncProcessFunction<I, ? extends org.apache.thrift.TBase, ?>> processMap) { |
||||||
|
processMap.put("qryTest", new qryTest()); |
||||||
|
return processMap; |
||||||
|
} |
||||||
|
|
||||||
|
public static class qryTest<I extends AsyncIface> extends org.apache.thrift.AsyncProcessFunction<I, qryTest_args, QryResult> { |
||||||
|
public qryTest() { |
||||||
|
super("qryTest"); |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_args getEmptyArgsInstance() { |
||||||
|
return new qryTest_args(); |
||||||
|
} |
||||||
|
|
||||||
|
public org.apache.thrift.async.AsyncMethodCallback<QryResult> getResultHandler(final org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, final int seqid) { |
||||||
|
final org.apache.thrift.AsyncProcessFunction fcall = this; |
||||||
|
return new org.apache.thrift.async.AsyncMethodCallback<QryResult>() { |
||||||
|
public void onComplete(QryResult o) { |
||||||
|
qryTest_result result = new qryTest_result(); |
||||||
|
result.success = o; |
||||||
|
try { |
||||||
|
fcall.sendResponse(fb, result, org.apache.thrift.protocol.TMessageType.REPLY,seqid); |
||||||
|
} catch (org.apache.thrift.transport.TTransportException e) { |
||||||
|
_LOGGER.error("TTransportException writing to internal frame buffer", e); |
||||||
|
fb.close(); |
||||||
|
} catch (java.lang.Exception e) { |
||||||
|
_LOGGER.error("Exception writing to internal frame buffer", e); |
||||||
|
onError(e); |
||||||
|
} |
||||||
|
} |
||||||
|
public void onError(java.lang.Exception e) { |
||||||
|
byte msgType = org.apache.thrift.protocol.TMessageType.REPLY; |
||||||
|
org.apache.thrift.TSerializable msg; |
||||||
|
qryTest_result result = new qryTest_result(); |
||||||
|
if (e instanceof org.apache.thrift.transport.TTransportException) { |
||||||
|
_LOGGER.error("TTransportException inside handler", e); |
||||||
|
fb.close(); |
||||||
|
return; |
||||||
|
} else if (e instanceof org.apache.thrift.TApplicationException) { |
||||||
|
_LOGGER.error("TApplicationException inside handler", e); |
||||||
|
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
||||||
|
msg = (org.apache.thrift.TApplicationException)e; |
||||||
|
} else { |
||||||
|
_LOGGER.error("Exception inside handler", e); |
||||||
|
msgType = org.apache.thrift.protocol.TMessageType.EXCEPTION; |
||||||
|
msg = new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR, e.getMessage()); |
||||||
|
} |
||||||
|
try { |
||||||
|
fcall.sendResponse(fb,msg,msgType,seqid); |
||||||
|
} catch (java.lang.Exception ex) { |
||||||
|
_LOGGER.error("Exception writing to internal frame buffer", ex); |
||||||
|
fb.close(); |
||||||
|
} |
||||||
|
} |
||||||
|
}; |
||||||
|
} |
||||||
|
|
||||||
|
protected boolean isOneway() { |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
public void start(I iface, qryTest_args args, org.apache.thrift.async.AsyncMethodCallback<QryResult> resultHandler) throws org.apache.thrift.TException { |
||||||
|
iface.qryTest(args.qryCode,resultHandler); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
public static class qryTest_args implements org.apache.thrift.TBase<qryTest_args, qryTest_args._Fields>, java.io.Serializable, Cloneable, Comparable<qryTest_args> { |
||||||
|
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("qryTest_args"); |
||||||
|
|
||||||
|
private static final org.apache.thrift.protocol.TField QRY_CODE_FIELD_DESC = new org.apache.thrift.protocol.TField("qryCode", org.apache.thrift.protocol.TType.I32, (short)1); |
||||||
|
|
||||||
|
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new qryTest_argsStandardSchemeFactory(); |
||||||
|
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new qryTest_argsTupleSchemeFactory(); |
||||||
|
|
||||||
|
public int qryCode; // required
|
||||||
|
|
||||||
|
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ |
||||||
|
public enum _Fields implements org.apache.thrift.TFieldIdEnum { |
||||||
|
QRY_CODE((short)1, "qryCode"); |
||||||
|
|
||||||
|
private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
||||||
|
|
||||||
|
static { |
||||||
|
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
||||||
|
byName.put(field.getFieldName(), field); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches fieldId, or null if its not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByThriftId(int fieldId) { |
||||||
|
switch(fieldId) { |
||||||
|
case 1: // QRY_CODE
|
||||||
|
return QRY_CODE; |
||||||
|
default: |
||||||
|
return null; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches fieldId, throwing an exception |
||||||
|
* if it is not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByThriftIdOrThrow(int fieldId) { |
||||||
|
_Fields fields = findByThriftId(fieldId); |
||||||
|
if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
||||||
|
return fields; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches name, or null if its not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByName(java.lang.String name) { |
||||||
|
return byName.get(name); |
||||||
|
} |
||||||
|
|
||||||
|
private final short _thriftId; |
||||||
|
private final java.lang.String _fieldName; |
||||||
|
|
||||||
|
_Fields(short thriftId, java.lang.String fieldName) { |
||||||
|
_thriftId = thriftId; |
||||||
|
_fieldName = fieldName; |
||||||
|
} |
||||||
|
|
||||||
|
public short getThriftFieldId() { |
||||||
|
return _thriftId; |
||||||
|
} |
||||||
|
|
||||||
|
public java.lang.String getFieldName() { |
||||||
|
return _fieldName; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
// isset id assignments
|
||||||
|
private static final int __QRYCODE_ISSET_ID = 0; |
||||||
|
private byte __isset_bitfield = 0; |
||||||
|
public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
||||||
|
static { |
||||||
|
java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); |
||||||
|
tmpMap.put(_Fields.QRY_CODE, new org.apache.thrift.meta_data.FieldMetaData("qryCode", org.apache.thrift.TFieldRequirementType.DEFAULT, |
||||||
|
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I32))); |
||||||
|
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
||||||
|
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(qryTest_args.class, metaDataMap); |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_args() { |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_args( |
||||||
|
int qryCode) |
||||||
|
{ |
||||||
|
this(); |
||||||
|
this.qryCode = qryCode; |
||||||
|
setQryCodeIsSet(true); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Performs a deep copy on <i>other</i>. |
||||||
|
*/ |
||||||
|
public qryTest_args(qryTest_args other) { |
||||||
|
__isset_bitfield = other.__isset_bitfield; |
||||||
|
this.qryCode = other.qryCode; |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_args deepCopy() { |
||||||
|
return new qryTest_args(this); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void clear() { |
||||||
|
setQryCodeIsSet(false); |
||||||
|
this.qryCode = 0; |
||||||
|
} |
||||||
|
|
||||||
|
public int getQryCode() { |
||||||
|
return this.qryCode; |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_args setQryCode(int qryCode) { |
||||||
|
this.qryCode = qryCode; |
||||||
|
setQryCodeIsSet(true); |
||||||
|
return this; |
||||||
|
} |
||||||
|
|
||||||
|
public void unsetQryCode() { |
||||||
|
__isset_bitfield = org.apache.thrift.EncodingUtils.clearBit(__isset_bitfield, __QRYCODE_ISSET_ID); |
||||||
|
} |
||||||
|
|
||||||
|
/** Returns true if field qryCode is set (has been assigned a value) and false otherwise */ |
||||||
|
public boolean isSetQryCode() { |
||||||
|
return org.apache.thrift.EncodingUtils.testBit(__isset_bitfield, __QRYCODE_ISSET_ID); |
||||||
|
} |
||||||
|
|
||||||
|
public void setQryCodeIsSet(boolean value) { |
||||||
|
__isset_bitfield = org.apache.thrift.EncodingUtils.setBit(__isset_bitfield, __QRYCODE_ISSET_ID, value); |
||||||
|
} |
||||||
|
|
||||||
|
public void setFieldValue(_Fields field, java.lang.Object value) { |
||||||
|
switch (field) { |
||||||
|
case QRY_CODE: |
||||||
|
if (value == null) { |
||||||
|
unsetQryCode(); |
||||||
|
} else { |
||||||
|
setQryCode((java.lang.Integer)value); |
||||||
|
} |
||||||
|
break; |
||||||
|
|
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public java.lang.Object getFieldValue(_Fields field) { |
||||||
|
switch (field) { |
||||||
|
case QRY_CODE: |
||||||
|
return getQryCode(); |
||||||
|
|
||||||
|
} |
||||||
|
throw new java.lang.IllegalStateException(); |
||||||
|
} |
||||||
|
|
||||||
|
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
||||||
|
public boolean isSet(_Fields field) { |
||||||
|
if (field == null) { |
||||||
|
throw new java.lang.IllegalArgumentException(); |
||||||
|
} |
||||||
|
|
||||||
|
switch (field) { |
||||||
|
case QRY_CODE: |
||||||
|
return isSetQryCode(); |
||||||
|
} |
||||||
|
throw new java.lang.IllegalStateException(); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public boolean equals(java.lang.Object that) { |
||||||
|
if (that == null) |
||||||
|
return false; |
||||||
|
if (that instanceof qryTest_args) |
||||||
|
return this.equals((qryTest_args)that); |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
public boolean equals(qryTest_args that) { |
||||||
|
if (that == null) |
||||||
|
return false; |
||||||
|
if (this == that) |
||||||
|
return true; |
||||||
|
|
||||||
|
boolean this_present_qryCode = true; |
||||||
|
boolean that_present_qryCode = true; |
||||||
|
if (this_present_qryCode || that_present_qryCode) { |
||||||
|
if (!(this_present_qryCode && that_present_qryCode)) |
||||||
|
return false; |
||||||
|
if (this.qryCode != that.qryCode) |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
return true; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public int hashCode() { |
||||||
|
int hashCode = 1; |
||||||
|
|
||||||
|
hashCode = hashCode * 8191 + qryCode; |
||||||
|
|
||||||
|
return hashCode; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public int compareTo(qryTest_args other) { |
||||||
|
if (!getClass().equals(other.getClass())) { |
||||||
|
return getClass().getName().compareTo(other.getClass().getName()); |
||||||
|
} |
||||||
|
|
||||||
|
int lastComparison = 0; |
||||||
|
|
||||||
|
lastComparison = java.lang.Boolean.valueOf(isSetQryCode()).compareTo(other.isSetQryCode()); |
||||||
|
if (lastComparison != 0) { |
||||||
|
return lastComparison; |
||||||
|
} |
||||||
|
if (isSetQryCode()) { |
||||||
|
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.qryCode, other.qryCode); |
||||||
|
if (lastComparison != 0) { |
||||||
|
return lastComparison; |
||||||
|
} |
||||||
|
} |
||||||
|
return 0; |
||||||
|
} |
||||||
|
|
||||||
|
public _Fields fieldForId(int fieldId) { |
||||||
|
return _Fields.findByThriftId(fieldId); |
||||||
|
} |
||||||
|
|
||||||
|
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
||||||
|
scheme(iprot).read(iprot, this); |
||||||
|
} |
||||||
|
|
||||||
|
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
||||||
|
scheme(oprot).write(oprot, this); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public java.lang.String toString() { |
||||||
|
java.lang.StringBuilder sb = new java.lang.StringBuilder("qryTest_args("); |
||||||
|
boolean first = true; |
||||||
|
|
||||||
|
sb.append("qryCode:"); |
||||||
|
sb.append(this.qryCode); |
||||||
|
first = false; |
||||||
|
sb.append(")"); |
||||||
|
return sb.toString(); |
||||||
|
} |
||||||
|
|
||||||
|
public void validate() throws org.apache.thrift.TException { |
||||||
|
// check for required fields
|
||||||
|
// check for sub-struct validity
|
||||||
|
} |
||||||
|
|
||||||
|
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { |
||||||
|
try { |
||||||
|
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); |
||||||
|
} catch (org.apache.thrift.TException te) { |
||||||
|
throw new java.io.IOException(te); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException { |
||||||
|
try { |
||||||
|
// it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
|
||||||
|
__isset_bitfield = 0; |
||||||
|
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); |
||||||
|
} catch (org.apache.thrift.TException te) { |
||||||
|
throw new java.io.IOException(te); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class qryTest_argsStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
||||||
|
public qryTest_argsStandardScheme getScheme() { |
||||||
|
return new qryTest_argsStandardScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class qryTest_argsStandardScheme extends org.apache.thrift.scheme.StandardScheme<qryTest_args> { |
||||||
|
|
||||||
|
public void read(org.apache.thrift.protocol.TProtocol iprot, qryTest_args struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TField schemeField; |
||||||
|
iprot.readStructBegin(); |
||||||
|
while (true) |
||||||
|
{ |
||||||
|
schemeField = iprot.readFieldBegin(); |
||||||
|
if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { |
||||||
|
break; |
||||||
|
} |
||||||
|
switch (schemeField.id) { |
||||||
|
case 1: // QRY_CODE
|
||||||
|
if (schemeField.type == org.apache.thrift.protocol.TType.I32) { |
||||||
|
struct.qryCode = iprot.readI32(); |
||||||
|
struct.setQryCodeIsSet(true); |
||||||
|
} else { |
||||||
|
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
||||||
|
} |
||||||
|
break; |
||||||
|
default: |
||||||
|
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
||||||
|
} |
||||||
|
iprot.readFieldEnd(); |
||||||
|
} |
||||||
|
iprot.readStructEnd(); |
||||||
|
|
||||||
|
// check for required fields of primitive type, which can't be checked in the validate method
|
||||||
|
struct.validate(); |
||||||
|
} |
||||||
|
|
||||||
|
public void write(org.apache.thrift.protocol.TProtocol oprot, qryTest_args struct) throws org.apache.thrift.TException { |
||||||
|
struct.validate(); |
||||||
|
|
||||||
|
oprot.writeStructBegin(STRUCT_DESC); |
||||||
|
oprot.writeFieldBegin(QRY_CODE_FIELD_DESC); |
||||||
|
oprot.writeI32(struct.qryCode); |
||||||
|
oprot.writeFieldEnd(); |
||||||
|
oprot.writeFieldStop(); |
||||||
|
oprot.writeStructEnd(); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private static class qryTest_argsTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
||||||
|
public qryTest_argsTupleScheme getScheme() { |
||||||
|
return new qryTest_argsTupleScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class qryTest_argsTupleScheme extends org.apache.thrift.scheme.TupleScheme<qryTest_args> { |
||||||
|
|
||||||
|
@Override |
||||||
|
public void write(org.apache.thrift.protocol.TProtocol prot, qryTest_args struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
||||||
|
java.util.BitSet optionals = new java.util.BitSet(); |
||||||
|
if (struct.isSetQryCode()) { |
||||||
|
optionals.set(0); |
||||||
|
} |
||||||
|
oprot.writeBitSet(optionals, 1); |
||||||
|
if (struct.isSetQryCode()) { |
||||||
|
oprot.writeI32(struct.qryCode); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void read(org.apache.thrift.protocol.TProtocol prot, qryTest_args struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
||||||
|
java.util.BitSet incoming = iprot.readBitSet(1); |
||||||
|
if (incoming.get(0)) { |
||||||
|
struct.qryCode = iprot.readI32(); |
||||||
|
struct.setQryCodeIsSet(true); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
||||||
|
return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public static class qryTest_result implements org.apache.thrift.TBase<qryTest_result, qryTest_result._Fields>, java.io.Serializable, Cloneable, Comparable<qryTest_result> { |
||||||
|
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("qryTest_result"); |
||||||
|
|
||||||
|
private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.STRUCT, (short)0); |
||||||
|
|
||||||
|
private static final org.apache.thrift.scheme.SchemeFactory STANDARD_SCHEME_FACTORY = new qryTest_resultStandardSchemeFactory(); |
||||||
|
private static final org.apache.thrift.scheme.SchemeFactory TUPLE_SCHEME_FACTORY = new qryTest_resultTupleSchemeFactory(); |
||||||
|
|
||||||
|
public QryResult success; // required
|
||||||
|
|
||||||
|
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ |
||||||
|
public enum _Fields implements org.apache.thrift.TFieldIdEnum { |
||||||
|
SUCCESS((short)0, "success"); |
||||||
|
|
||||||
|
private static final java.util.Map<java.lang.String, _Fields> byName = new java.util.HashMap<java.lang.String, _Fields>(); |
||||||
|
|
||||||
|
static { |
||||||
|
for (_Fields field : java.util.EnumSet.allOf(_Fields.class)) { |
||||||
|
byName.put(field.getFieldName(), field); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches fieldId, or null if its not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByThriftId(int fieldId) { |
||||||
|
switch(fieldId) { |
||||||
|
case 0: // SUCCESS
|
||||||
|
return SUCCESS; |
||||||
|
default: |
||||||
|
return null; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches fieldId, throwing an exception |
||||||
|
* if it is not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByThriftIdOrThrow(int fieldId) { |
||||||
|
_Fields fields = findByThriftId(fieldId); |
||||||
|
if (fields == null) throw new java.lang.IllegalArgumentException("Field " + fieldId + " doesn't exist!"); |
||||||
|
return fields; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Find the _Fields constant that matches name, or null if its not found. |
||||||
|
*/ |
||||||
|
public static _Fields findByName(java.lang.String name) { |
||||||
|
return byName.get(name); |
||||||
|
} |
||||||
|
|
||||||
|
private final short _thriftId; |
||||||
|
private final java.lang.String _fieldName; |
||||||
|
|
||||||
|
_Fields(short thriftId, java.lang.String fieldName) { |
||||||
|
_thriftId = thriftId; |
||||||
|
_fieldName = fieldName; |
||||||
|
} |
||||||
|
|
||||||
|
public short getThriftFieldId() { |
||||||
|
return _thriftId; |
||||||
|
} |
||||||
|
|
||||||
|
public java.lang.String getFieldName() { |
||||||
|
return _fieldName; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
// isset id assignments
|
||||||
|
public static final java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; |
||||||
|
static { |
||||||
|
java.util.Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new java.util.EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); |
||||||
|
tmpMap.put(_Fields.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, |
||||||
|
new org.apache.thrift.meta_data.StructMetaData(org.apache.thrift.protocol.TType.STRUCT, QryResult.class))); |
||||||
|
metaDataMap = java.util.Collections.unmodifiableMap(tmpMap); |
||||||
|
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(qryTest_result.class, metaDataMap); |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_result() { |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_result( |
||||||
|
QryResult success) |
||||||
|
{ |
||||||
|
this(); |
||||||
|
this.success = success; |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* Performs a deep copy on <i>other</i>. |
||||||
|
*/ |
||||||
|
public qryTest_result(qryTest_result other) { |
||||||
|
if (other.isSetSuccess()) { |
||||||
|
this.success = new QryResult(other.success); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_result deepCopy() { |
||||||
|
return new qryTest_result(this); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void clear() { |
||||||
|
this.success = null; |
||||||
|
} |
||||||
|
|
||||||
|
public QryResult getSuccess() { |
||||||
|
return this.success; |
||||||
|
} |
||||||
|
|
||||||
|
public qryTest_result setSuccess(QryResult success) { |
||||||
|
this.success = success; |
||||||
|
return this; |
||||||
|
} |
||||||
|
|
||||||
|
public void unsetSuccess() { |
||||||
|
this.success = null; |
||||||
|
} |
||||||
|
|
||||||
|
/** Returns true if field success is set (has been assigned a value) and false otherwise */ |
||||||
|
public boolean isSetSuccess() { |
||||||
|
return this.success != null; |
||||||
|
} |
||||||
|
|
||||||
|
public void setSuccessIsSet(boolean value) { |
||||||
|
if (!value) { |
||||||
|
this.success = null; |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public void setFieldValue(_Fields field, java.lang.Object value) { |
||||||
|
switch (field) { |
||||||
|
case SUCCESS: |
||||||
|
if (value == null) { |
||||||
|
unsetSuccess(); |
||||||
|
} else { |
||||||
|
setSuccess((QryResult)value); |
||||||
|
} |
||||||
|
break; |
||||||
|
|
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
public java.lang.Object getFieldValue(_Fields field) { |
||||||
|
switch (field) { |
||||||
|
case SUCCESS: |
||||||
|
return getSuccess(); |
||||||
|
|
||||||
|
} |
||||||
|
throw new java.lang.IllegalStateException(); |
||||||
|
} |
||||||
|
|
||||||
|
/** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ |
||||||
|
public boolean isSet(_Fields field) { |
||||||
|
if (field == null) { |
||||||
|
throw new java.lang.IllegalArgumentException(); |
||||||
|
} |
||||||
|
|
||||||
|
switch (field) { |
||||||
|
case SUCCESS: |
||||||
|
return isSetSuccess(); |
||||||
|
} |
||||||
|
throw new java.lang.IllegalStateException(); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public boolean equals(java.lang.Object that) { |
||||||
|
if (that == null) |
||||||
|
return false; |
||||||
|
if (that instanceof qryTest_result) |
||||||
|
return this.equals((qryTest_result)that); |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
public boolean equals(qryTest_result that) { |
||||||
|
if (that == null) |
||||||
|
return false; |
||||||
|
if (this == that) |
||||||
|
return true; |
||||||
|
|
||||||
|
boolean this_present_success = true && this.isSetSuccess(); |
||||||
|
boolean that_present_success = true && that.isSetSuccess(); |
||||||
|
if (this_present_success || that_present_success) { |
||||||
|
if (!(this_present_success && that_present_success)) |
||||||
|
return false; |
||||||
|
if (!this.success.equals(that.success)) |
||||||
|
return false; |
||||||
|
} |
||||||
|
|
||||||
|
return true; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public int hashCode() { |
||||||
|
int hashCode = 1; |
||||||
|
|
||||||
|
hashCode = hashCode * 8191 + ((isSetSuccess()) ? 131071 : 524287); |
||||||
|
if (isSetSuccess()) |
||||||
|
hashCode = hashCode * 8191 + success.hashCode(); |
||||||
|
|
||||||
|
return hashCode; |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public int compareTo(qryTest_result other) { |
||||||
|
if (!getClass().equals(other.getClass())) { |
||||||
|
return getClass().getName().compareTo(other.getClass().getName()); |
||||||
|
} |
||||||
|
|
||||||
|
int lastComparison = 0; |
||||||
|
|
||||||
|
lastComparison = java.lang.Boolean.valueOf(isSetSuccess()).compareTo(other.isSetSuccess()); |
||||||
|
if (lastComparison != 0) { |
||||||
|
return lastComparison; |
||||||
|
} |
||||||
|
if (isSetSuccess()) { |
||||||
|
lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.success, other.success); |
||||||
|
if (lastComparison != 0) { |
||||||
|
return lastComparison; |
||||||
|
} |
||||||
|
} |
||||||
|
return 0; |
||||||
|
} |
||||||
|
|
||||||
|
public _Fields fieldForId(int fieldId) { |
||||||
|
return _Fields.findByThriftId(fieldId); |
||||||
|
} |
||||||
|
|
||||||
|
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { |
||||||
|
scheme(iprot).read(iprot, this); |
||||||
|
} |
||||||
|
|
||||||
|
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { |
||||||
|
scheme(oprot).write(oprot, this); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public java.lang.String toString() { |
||||||
|
java.lang.StringBuilder sb = new java.lang.StringBuilder("qryTest_result("); |
||||||
|
boolean first = true; |
||||||
|
|
||||||
|
sb.append("success:"); |
||||||
|
if (this.success == null) { |
||||||
|
sb.append("null"); |
||||||
|
} else { |
||||||
|
sb.append(this.success); |
||||||
|
} |
||||||
|
first = false; |
||||||
|
sb.append(")"); |
||||||
|
return sb.toString(); |
||||||
|
} |
||||||
|
|
||||||
|
public void validate() throws org.apache.thrift.TException { |
||||||
|
// check for required fields
|
||||||
|
// check for sub-struct validity
|
||||||
|
if (success != null) { |
||||||
|
success.validate(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { |
||||||
|
try { |
||||||
|
write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); |
||||||
|
} catch (org.apache.thrift.TException te) { |
||||||
|
throw new java.io.IOException(te); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException { |
||||||
|
try { |
||||||
|
read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); |
||||||
|
} catch (org.apache.thrift.TException te) { |
||||||
|
throw new java.io.IOException(te); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class qryTest_resultStandardSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
||||||
|
public qryTest_resultStandardScheme getScheme() { |
||||||
|
return new qryTest_resultStandardScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class qryTest_resultStandardScheme extends org.apache.thrift.scheme.StandardScheme<qryTest_result> { |
||||||
|
|
||||||
|
public void read(org.apache.thrift.protocol.TProtocol iprot, qryTest_result struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TField schemeField; |
||||||
|
iprot.readStructBegin(); |
||||||
|
while (true) |
||||||
|
{ |
||||||
|
schemeField = iprot.readFieldBegin(); |
||||||
|
if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { |
||||||
|
break; |
||||||
|
} |
||||||
|
switch (schemeField.id) { |
||||||
|
case 0: // SUCCESS
|
||||||
|
if (schemeField.type == org.apache.thrift.protocol.TType.STRUCT) { |
||||||
|
struct.success = new QryResult(); |
||||||
|
struct.success.read(iprot); |
||||||
|
struct.setSuccessIsSet(true); |
||||||
|
} else { |
||||||
|
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
||||||
|
} |
||||||
|
break; |
||||||
|
default: |
||||||
|
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); |
||||||
|
} |
||||||
|
iprot.readFieldEnd(); |
||||||
|
} |
||||||
|
iprot.readStructEnd(); |
||||||
|
|
||||||
|
// check for required fields of primitive type, which can't be checked in the validate method
|
||||||
|
struct.validate(); |
||||||
|
} |
||||||
|
|
||||||
|
public void write(org.apache.thrift.protocol.TProtocol oprot, qryTest_result struct) throws org.apache.thrift.TException { |
||||||
|
struct.validate(); |
||||||
|
|
||||||
|
oprot.writeStructBegin(STRUCT_DESC); |
||||||
|
if (struct.success != null) { |
||||||
|
oprot.writeFieldBegin(SUCCESS_FIELD_DESC); |
||||||
|
struct.success.write(oprot); |
||||||
|
oprot.writeFieldEnd(); |
||||||
|
} |
||||||
|
oprot.writeFieldStop(); |
||||||
|
oprot.writeStructEnd(); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
|
||||||
|
private static class qryTest_resultTupleSchemeFactory implements org.apache.thrift.scheme.SchemeFactory { |
||||||
|
public qryTest_resultTupleScheme getScheme() { |
||||||
|
return new qryTest_resultTupleScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static class qryTest_resultTupleScheme extends org.apache.thrift.scheme.TupleScheme<qryTest_result> { |
||||||
|
|
||||||
|
@Override |
||||||
|
public void write(org.apache.thrift.protocol.TProtocol prot, qryTest_result struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TTupleProtocol oprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
||||||
|
java.util.BitSet optionals = new java.util.BitSet(); |
||||||
|
if (struct.isSetSuccess()) { |
||||||
|
optionals.set(0); |
||||||
|
} |
||||||
|
oprot.writeBitSet(optionals, 1); |
||||||
|
if (struct.isSetSuccess()) { |
||||||
|
struct.success.write(oprot); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public void read(org.apache.thrift.protocol.TProtocol prot, qryTest_result struct) throws org.apache.thrift.TException { |
||||||
|
org.apache.thrift.protocol.TTupleProtocol iprot = (org.apache.thrift.protocol.TTupleProtocol) prot; |
||||||
|
java.util.BitSet incoming = iprot.readBitSet(1); |
||||||
|
if (incoming.get(0)) { |
||||||
|
struct.success = new QryResult(); |
||||||
|
struct.success.read(iprot); |
||||||
|
struct.setSuccessIsSet(true); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
private static <S extends org.apache.thrift.scheme.IScheme> S scheme(org.apache.thrift.protocol.TProtocol proto) { |
||||||
|
return (org.apache.thrift.scheme.StandardScheme.class.equals(proto.getScheme()) ? STANDARD_SCHEME_FACTORY : TUPLE_SCHEME_FACTORY).getScheme(); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
Loading…
Reference in new issue