WebSVN – SmartDukaan – Diff – /trunk/ThriftConfig/src/main/java/in/shop2020/payments/PaymentService.java

 import org.apache.thrift.meta_data.*;
 import org.apache.thrift.protocol.*;
 public class PaymentService {
-  public interface Iface {
-    /**
-     * For closing the open session in sqlalchemy
-     */
-    public void closeSession() throws TException;
+  public interface Iface extends in.shop2020.generic.GenericService.Iface {
     /**
      * create a new payment and return payment id, throws an exception if gateway is not active
+     *
+     *
      */
     public boolean capturePayment(long merchantTxnId) throws PaymentException, TException;
+  }
-  public static class Client implements Iface {
+  public static class Client extends in.shop2020.generic.GenericService.Client implements Iface {
     public Client(TProtocol prot)
+    {
       this(prot, prot);
+    }
     public Client(TProtocol iprot, TProtocol oprot)
+    {
-      iprot_ = iprot;
-      oprot_ = oprot;
+      super(iprot, oprot);
-    }
-    protected TProtocol iprot_;
-    protected TProtocol oprot_;
-    protected int seqid_;
-    public TProtocol getInputProtocol()
-    {
-      return this.iprot_;
-    }
-    public TProtocol getOutputProtocol()
-    {
-      return this.oprot_;
-    }
-    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 long createPayment(long userId, double amount, long gatewayId, long txnId) throws PaymentException, TException
+    {
       send_createPayment(userId, amount, gatewayId, txnId);
+      }
       throw new TApplicationException(TApplicationException.MISSING_RESULT, "capturePayment failed: unknown result");
+    }
+  }
-  public static class Processor implements TProcessor {
+  public static class Processor extends in.shop2020.generic.GenericService.Processor implements TProcessor {
     private static final Logger LOGGER = LoggerFactory.getLogger(Processor.class.getName());
     public Processor(Iface iface)
+    {
+      super(iface);
       iface_ = iface;
-      processMap_.put("closeSession", new closeSession());
       processMap_.put("createPayment", new createPayment());
       processMap_.put("getPaymentsForUser", new getPaymentsForUser());
       processMap_.put("getPayments", new getPayments());
       processMap_.put("getPaymentGateway", new getPaymentGateway());
       processMap_.put("getPayment", new getPayment());
       processMap_.put("initializeHdfcPayment", new initializeHdfcPayment());
       processMap_.put("createRefund", new createRefund());
       processMap_.put("capturePayment", new capturePayment());
+    }
-    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);
+      }
       fn.process(msg.seqid, iprot, oprot);
       return true;
+    }
-    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();
-      }
-    }
     private class createPayment implements ProcessFunction {
       public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException
+      {
         createPayment_args args = new createPayment_args();
         args.read(iprot);
+    }
+  }
-  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);
-    }
-    @Deprecated
-    public 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));
-    }
-    @Override
-    public 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;
-    }
-    @Override
-    public 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();
-    }
-    @Override
-    public 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);
-    }
-    @Deprecated
-    public 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));
-    }
-    @Override
-    public 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;
-    }
-    @Override
-    public 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();
-    }
-    @Override
-    public 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
-    }
-  }
   public static class createPayment_args implements TBase<createPayment_args._Fields>, java.io.Serializable, Cloneable, Comparable<createPayment_args>   {
     private static final TStruct STRUCT_DESC = new TStruct("createPayment_args");
     private static final TField USER_ID_FIELD_DESC = new TField("userId", TType.I64, (short)1);
     private static final TField AMOUNT_FIELD_DESC = new TField("amount", TType.DOUBLE, (short)2);

Subversion Repositories SmartDukaan

(root)/trunk/ThriftConfig/src/main/java/in/shop2020/payments/PaymentService.java – Rev 3010 → 3374