Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
/*** Autogenerated by Thrift** DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING*/package in.shop2020.generic;import java.util.List;import java.util.ArrayList;import java.util.Map;import java.util.HashMap;import java.util.EnumMap;import java.util.Set;import java.util.HashSet;import java.util.EnumSet;import java.util.Collections;import java.util.BitSet;import java.util.Arrays;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.apache.thrift.*;import org.apache.thrift.meta_data.*;import org.apache.thrift.protocol.*;public class GenericService {public interface Iface {/*** For checking weather service is active alive or not. It also checks connectivity with database*/public boolean isAlive() throws TException;/*** For closing the open session in sqlalchemy*/public void closeSession() throws TException;}public static class Client implements Iface {public Client(TProtocol prot){this(prot, prot);}public Client(TProtocol iprot, TProtocol oprot){iprot_ = iprot;oprot_ = oprot;}protected TProtocol iprot_;protected TProtocol oprot_;protected int seqid_;public TProtocol getInputProtocol(){return this.iprot_;}public TProtocol getOutputProtocol(){return this.oprot_;}public boolean isAlive() throws TException{send_isAlive();return recv_isAlive();}public void send_isAlive() throws TException{oprot_.writeMessageBegin(new TMessage("isAlive", TMessageType.CALL, seqid_));isAlive_args args = new isAlive_args();args.write(oprot_);oprot_.writeMessageEnd();oprot_.getTransport().flush();}public boolean recv_isAlive() throws TException{TMessage msg = iprot_.readMessageBegin();if (msg.type == TMessageType.EXCEPTION) {TApplicationException x = TApplicationException.read(iprot_);iprot_.readMessageEnd();throw x;}isAlive_result result = new isAlive_result();result.read(iprot_);iprot_.readMessageEnd();if (result.isSetSuccess()) {return result.success;}throw new TApplicationException(TApplicationException.MISSING_RESULT, "isAlive failed: unknown result");}public void closeSession() throws TException{send_closeSession();recv_closeSession();}public void send_closeSession() throws TException{oprot_.writeMessageBegin(new TMessage("closeSession", TMessageType.CALL, seqid_));closeSession_args args = new closeSession_args();args.write(oprot_);oprot_.writeMessageEnd();oprot_.getTransport().flush();}public void recv_closeSession() throws TException{TMessage msg = iprot_.readMessageBegin();if (msg.type == TMessageType.EXCEPTION) {TApplicationException x = TApplicationException.read(iprot_);iprot_.readMessageEnd();throw x;}closeSession_result result = new closeSession_result();result.read(iprot_);iprot_.readMessageEnd();return;}}public static class Processor implements TProcessor {private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());public Processor(Iface iface){iface_ = iface;processMap_.put("isAlive", new isAlive());processMap_.put("closeSession", new closeSession());}protected static interface ProcessFunction {public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException;}private Iface iface_;protected final HashMap<String,ProcessFunction> processMap_ = new HashMap<String,ProcessFunction>();public boolean process(TProtocol iprot, TProtocol oprot) throws TException{TMessage msg = iprot.readMessageBegin();ProcessFunction fn = processMap_.get(msg.name);if (fn == null) {TProtocolUtil.skip(iprot, TType.STRUCT);iprot.readMessageEnd();TApplicationException x = new TApplicationException(TApplicationException.UNKNOWN_METHOD, "Invalid method name: '"+msg.name+"'");oprot.writeMessageBegin(new TMessage(msg.name, TMessageType.EXCEPTION, msg.seqid));x.write(oprot);oprot.writeMessageEnd();oprot.getTransport().flush();return true;}fn.process(msg.seqid, iprot, oprot);return true;}private class isAlive implements ProcessFunction {public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException{isAlive_args args = new isAlive_args();args.read(iprot);iprot.readMessageEnd();isAlive_result result = new isAlive_result();result.success = iface_.isAlive();result.setSuccessIsSet(true);oprot.writeMessageBegin(new TMessage("isAlive", TMessageType.REPLY, seqid));result.write(oprot);oprot.writeMessageEnd();oprot.getTransport().flush();}}private class closeSession implements ProcessFunction {public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException{closeSession_args args = new closeSession_args();args.read(iprot);iprot.readMessageEnd();closeSession_result result = new closeSession_result();iface_.closeSession();oprot.writeMessageBegin(new TMessage("closeSession", TMessageType.REPLY, seqid));result.write(oprot);oprot.writeMessageEnd();oprot.getTransport().flush();}}}public static class isAlive_args implements TBase<isAlive_args._Fields>, java.io.Serializable, Cloneable, Comparable<isAlive_args> {private static final TStruct STRUCT_DESC = new TStruct("isAlive_args");/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */public enum _Fields implements TFieldIdEnum {;private static final Map<Integer, _Fields> byId = new HashMap<Integer, _Fields>();private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();static {for (_Fields field : EnumSet.allOf(_Fields.class)) {byId.put((int)field._thriftId, field);byName.put(field.getFieldName(), field);}}/*** Find the _Fields constant that matches fieldId, or null if its not found.*/public static _Fields findByThriftId(int fieldId) {return byId.get(fieldId);}/*** 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 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(String name) {return byName.get(name);}private final short _thriftId;private final String _fieldName;_Fields(short thriftId, String fieldName) {_thriftId = thriftId;_fieldName = fieldName;}public short getThriftFieldId() {return _thriftId;}public String getFieldName() {return _fieldName;}}public static final Map<_Fields, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new EnumMap<_Fields, FieldMetaData>(_Fields.class) {{}});static {FieldMetaData.addStructMetaDataMap(isAlive_args.class, metaDataMap);}public isAlive_args() {}/*** Performs a deep copy on <i>other</i>.*/public isAlive_args(isAlive_args other) {}public isAlive_args deepCopy() {return new isAlive_args(this);}@Deprecatedpublic isAlive_args clone() {return new isAlive_args(this);}public void setFieldValue(_Fields field, Object value) {switch (field) {}}public void setFieldValue(int fieldID, Object value) {setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);}public Object getFieldValue(_Fields field) {switch (field) {}throw new IllegalStateException();}public Object getFieldValue(int fieldId) {return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));}/** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */public boolean isSet(_Fields field) {switch (field) {}throw new IllegalStateException();}public boolean isSet(int fieldID) {return isSet(_Fields.findByThriftIdOrThrow(fieldID));}@Overridepublic boolean equals(Object that) {if (that == null)return false;if (that instanceof isAlive_args)return this.equals((isAlive_args)that);return false;}public boolean equals(isAlive_args that) {if (that == null)return false;return true;}@Overridepublic int hashCode() {return 0;}public int compareTo(isAlive_args other) {if (!getClass().equals(other.getClass())) {return getClass().getName().compareTo(other.getClass().getName());}int lastComparison = 0;isAlive_args typedOther = (isAlive_args)other;return 0;}public void read(TProtocol iprot) throws TException {TField field;iprot.readStructBegin();while (true){field = iprot.readFieldBegin();if (field.type == TType.STOP) {break;}_Fields fieldId = _Fields.findByThriftId(field.id);if (fieldId == null) {TProtocolUtil.skip(iprot, field.type);} else {switch (fieldId) {}iprot.readFieldEnd();}}iprot.readStructEnd();validate();}public void write(TProtocol oprot) throws TException {validate();oprot.writeStructBegin(STRUCT_DESC);oprot.writeFieldStop();oprot.writeStructEnd();}@Overridepublic String toString() {StringBuilder sb = new StringBuilder("isAlive_args(");boolean first = true;sb.append(")");return sb.toString();}public void validate() throws TException {// check for required fields}}public static class isAlive_result implements TBase<isAlive_result._Fields>, java.io.Serializable, Cloneable, Comparable<isAlive_result> {private static final TStruct STRUCT_DESC = new TStruct("isAlive_result");private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.BOOL, (short)0);private boolean success;/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */public enum _Fields implements TFieldIdEnum {SUCCESS((short)0, "success");private static final Map<Integer, _Fields> byId = new HashMap<Integer, _Fields>();private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();static {for (_Fields field : EnumSet.allOf(_Fields.class)) {byId.put((int)field._thriftId, field);byName.put(field.getFieldName(), field);}}/*** Find the _Fields constant that matches fieldId, or null if its not found.*/public static _Fields findByThriftId(int fieldId) {return byId.get(fieldId);}/*** 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 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(String name) {return byName.get(name);}private final short _thriftId;private final String _fieldName;_Fields(short thriftId, String fieldName) {_thriftId = thriftId;_fieldName = fieldName;}public short getThriftFieldId() {return _thriftId;}public String getFieldName() {return _fieldName;}}// isset id assignmentsprivate static final int __SUCCESS_ISSET_ID = 0;private BitSet __isset_bit_vector = new BitSet(1);public static final Map<_Fields, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new EnumMap<_Fields, FieldMetaData>(_Fields.class) {{put(_Fields.SUCCESS, new FieldMetaData("success", TFieldRequirementType.DEFAULT,new FieldValueMetaData(TType.BOOL)));}});static {FieldMetaData.addStructMetaDataMap(isAlive_result.class, metaDataMap);}public isAlive_result() {}public isAlive_result(boolean success){this();this.success = success;setSuccessIsSet(true);}/*** Performs a deep copy on <i>other</i>.*/public isAlive_result(isAlive_result other) {__isset_bit_vector.clear();__isset_bit_vector.or(other.__isset_bit_vector);this.success = other.success;}public isAlive_result deepCopy() {return new isAlive_result(this);}@Deprecatedpublic isAlive_result clone() {return new isAlive_result(this);}public boolean isSuccess() {return this.success;}public isAlive_result setSuccess(boolean success) {this.success = success;setSuccessIsSet(true);return this;}public void unsetSuccess() {__isset_bit_vector.clear(__SUCCESS_ISSET_ID);}/** Returns true if field success is set (has been asigned a value) and false otherwise */public boolean isSetSuccess() {return __isset_bit_vector.get(__SUCCESS_ISSET_ID);}public void setSuccessIsSet(boolean value) {__isset_bit_vector.set(__SUCCESS_ISSET_ID, value);}public void setFieldValue(_Fields field, Object value) {switch (field) {case SUCCESS:if (value == null) {unsetSuccess();} else {setSuccess((Boolean)value);}break;}}public void setFieldValue(int fieldID, Object value) {setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);}public Object getFieldValue(_Fields field) {switch (field) {case SUCCESS:return new Boolean(isSuccess());}throw new IllegalStateException();}public Object getFieldValue(int fieldId) {return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));}/** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */public boolean isSet(_Fields field) {switch (field) {case SUCCESS:return isSetSuccess();}throw new IllegalStateException();}public boolean isSet(int fieldID) {return isSet(_Fields.findByThriftIdOrThrow(fieldID));}@Overridepublic boolean equals(Object that) {if (that == null)return false;if (that instanceof isAlive_result)return this.equals((isAlive_result)that);return false;}public boolean equals(isAlive_result that) {if (that == null)return false;boolean this_present_success = true;boolean that_present_success = true;if (this_present_success || that_present_success) {if (!(this_present_success && that_present_success))return false;if (this.success != that.success)return false;}return true;}@Overridepublic int hashCode() {return 0;}public int compareTo(isAlive_result other) {if (!getClass().equals(other.getClass())) {return getClass().getName().compareTo(other.getClass().getName());}int lastComparison = 0;isAlive_result typedOther = (isAlive_result)other;lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(isSetSuccess());if (lastComparison != 0) {return lastComparison;}lastComparison = TBaseHelper.compareTo(success, typedOther.success);if (lastComparison != 0) {return lastComparison;}return 0;}public void read(TProtocol iprot) throws TException {TField field;iprot.readStructBegin();while (true){field = iprot.readFieldBegin();if (field.type == TType.STOP) {break;}_Fields fieldId = _Fields.findByThriftId(field.id);if (fieldId == null) {TProtocolUtil.skip(iprot, field.type);} else {switch (fieldId) {case SUCCESS:if (field.type == TType.BOOL) {this.success = iprot.readBool();setSuccessIsSet(true);} else {TProtocolUtil.skip(iprot, field.type);}break;}iprot.readFieldEnd();}}iprot.readStructEnd();validate();}public void write(TProtocol oprot) throws TException {oprot.writeStructBegin(STRUCT_DESC);if (this.isSetSuccess()) {oprot.writeFieldBegin(SUCCESS_FIELD_DESC);oprot.writeBool(this.success);oprot.writeFieldEnd();}oprot.writeFieldStop();oprot.writeStructEnd();}@Overridepublic String toString() {StringBuilder sb = new StringBuilder("isAlive_result(");boolean first = true;sb.append("success:");sb.append(this.success);first = false;sb.append(")");return sb.toString();}public void validate() throws TException {// check for required fields}}public static class closeSession_args implements TBase<closeSession_args._Fields>, java.io.Serializable, Cloneable, Comparable<closeSession_args> {private static final TStruct STRUCT_DESC = new TStruct("closeSession_args");/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */public enum _Fields implements TFieldIdEnum {;private static final Map<Integer, _Fields> byId = new HashMap<Integer, _Fields>();private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();static {for (_Fields field : EnumSet.allOf(_Fields.class)) {byId.put((int)field._thriftId, field);byName.put(field.getFieldName(), field);}}/*** Find the _Fields constant that matches fieldId, or null if its not found.*/public static _Fields findByThriftId(int fieldId) {return byId.get(fieldId);}/*** 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 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(String name) {return byName.get(name);}private final short _thriftId;private final String _fieldName;_Fields(short thriftId, String fieldName) {_thriftId = thriftId;_fieldName = fieldName;}public short getThriftFieldId() {return _thriftId;}public String getFieldName() {return _fieldName;}}public static final Map<_Fields, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new EnumMap<_Fields, FieldMetaData>(_Fields.class) {{}});static {FieldMetaData.addStructMetaDataMap(closeSession_args.class, metaDataMap);}public closeSession_args() {}/*** Performs a deep copy on <i>other</i>.*/public closeSession_args(closeSession_args other) {}public closeSession_args deepCopy() {return new closeSession_args(this);}@Deprecatedpublic closeSession_args clone() {return new closeSession_args(this);}public void setFieldValue(_Fields field, Object value) {switch (field) {}}public void setFieldValue(int fieldID, Object value) {setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);}public Object getFieldValue(_Fields field) {switch (field) {}throw new IllegalStateException();}public Object getFieldValue(int fieldId) {return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));}/** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */public boolean isSet(_Fields field) {switch (field) {}throw new IllegalStateException();}public boolean isSet(int fieldID) {return isSet(_Fields.findByThriftIdOrThrow(fieldID));}@Overridepublic boolean equals(Object that) {if (that == null)return false;if (that instanceof closeSession_args)return this.equals((closeSession_args)that);return false;}public boolean equals(closeSession_args that) {if (that == null)return false;return true;}@Overridepublic int hashCode() {return 0;}public int compareTo(closeSession_args other) {if (!getClass().equals(other.getClass())) {return getClass().getName().compareTo(other.getClass().getName());}int lastComparison = 0;closeSession_args typedOther = (closeSession_args)other;return 0;}public void read(TProtocol iprot) throws TException {TField field;iprot.readStructBegin();while (true){field = iprot.readFieldBegin();if (field.type == TType.STOP) {break;}_Fields fieldId = _Fields.findByThriftId(field.id);if (fieldId == null) {TProtocolUtil.skip(iprot, field.type);} else {switch (fieldId) {}iprot.readFieldEnd();}}iprot.readStructEnd();validate();}public void write(TProtocol oprot) throws TException {validate();oprot.writeStructBegin(STRUCT_DESC);oprot.writeFieldStop();oprot.writeStructEnd();}@Overridepublic String toString() {StringBuilder sb = new StringBuilder("closeSession_args(");boolean first = true;sb.append(")");return sb.toString();}public void validate() throws TException {// check for required fields}}public static class closeSession_result implements TBase<closeSession_result._Fields>, java.io.Serializable, Cloneable, Comparable<closeSession_result> {private static final TStruct STRUCT_DESC = new TStruct("closeSession_result");/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */public enum _Fields implements TFieldIdEnum {;private static final Map<Integer, _Fields> byId = new HashMap<Integer, _Fields>();private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();static {for (_Fields field : EnumSet.allOf(_Fields.class)) {byId.put((int)field._thriftId, field);byName.put(field.getFieldName(), field);}}/*** Find the _Fields constant that matches fieldId, or null if its not found.*/public static _Fields findByThriftId(int fieldId) {return byId.get(fieldId);}/*** 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 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(String name) {return byName.get(name);}private final short _thriftId;private final String _fieldName;_Fields(short thriftId, String fieldName) {_thriftId = thriftId;_fieldName = fieldName;}public short getThriftFieldId() {return _thriftId;}public String getFieldName() {return _fieldName;}}public static final Map<_Fields, FieldMetaData> metaDataMap = Collections.unmodifiableMap(new EnumMap<_Fields, FieldMetaData>(_Fields.class) {{}});static {FieldMetaData.addStructMetaDataMap(closeSession_result.class, metaDataMap);}public closeSession_result() {}/*** Performs a deep copy on <i>other</i>.*/public closeSession_result(closeSession_result other) {}public closeSession_result deepCopy() {return new closeSession_result(this);}@Deprecatedpublic closeSession_result clone() {return new closeSession_result(this);}public void setFieldValue(_Fields field, Object value) {switch (field) {}}public void setFieldValue(int fieldID, Object value) {setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);}public Object getFieldValue(_Fields field) {switch (field) {}throw new IllegalStateException();}public Object getFieldValue(int fieldId) {return getFieldValue(_Fields.findByThriftIdOrThrow(fieldId));}/** Returns true if field corresponding to fieldID is set (has been asigned a value) and false otherwise */public boolean isSet(_Fields field) {switch (field) {}throw new IllegalStateException();}public boolean isSet(int fieldID) {return isSet(_Fields.findByThriftIdOrThrow(fieldID));}@Overridepublic boolean equals(Object that) {if (that == null)return false;if (that instanceof closeSession_result)return this.equals((closeSession_result)that);return false;}public boolean equals(closeSession_result that) {if (that == null)return false;return true;}@Overridepublic int hashCode() {return 0;}public int compareTo(closeSession_result other) {if (!getClass().equals(other.getClass())) {return getClass().getName().compareTo(other.getClass().getName());}int lastComparison = 0;closeSession_result typedOther = (closeSession_result)other;return 0;}public void read(TProtocol iprot) throws TException {TField field;iprot.readStructBegin();while (true){field = iprot.readFieldBegin();if (field.type == TType.STOP) {break;}_Fields fieldId = _Fields.findByThriftId(field.id);if (fieldId == null) {TProtocolUtil.skip(iprot, field.type);} else {switch (fieldId) {}iprot.readFieldEnd();}}iprot.readStructEnd();validate();}public void write(TProtocol oprot) throws TException {oprot.writeStructBegin(STRUCT_DESC);oprot.writeFieldStop();oprot.writeStructEnd();}@Overridepublic String toString() {StringBuilder sb = new StringBuilder("closeSession_result(");boolean first = true;sb.append(")");return sb.toString();}public void validate() throws TException {// check for required fields}}}