WebSVN – SmartDukaan – Diff – /trunk/ThriftConfig/src/main/java/in/shop2020/utils/HelperService.java

      * For closing the open session in sqlalchemy
      */
     public void closeSession() throws TException;
     /**
-     * Save email details, to be sent later
+     * Save email details, to be sent later; Also returns its identifier.
+     *
      * @param emailTo
      * @param emailFrom
      * @param subject
      * @param body
      * @param source
      * @param emailType
      */
-    public void saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType) throws HelperServiceException, TException;
+    public long saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType) throws HelperServiceException, TException;
     /**
      * Retreives all the emails pending for dispatch
      */
     public List<UserEmail> getEmailsToBeSent() throws HelperServiceException, TException;
       result.read(iprot_);
       iprot_.readMessageEnd();
       return;
+    }
-    public void saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType) throws HelperServiceException, TException
+    public long saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType) throws HelperServiceException, TException
+    {
       send_saveUserEmailForSending(emailTo, emailFrom, subject, body, source, emailType);
-      recv_saveUserEmailForSending();
+      return recv_saveUserEmailForSending();
+    }
     public void send_saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType) throws TException
+    {
       oprot_.writeMessageBegin(new TMessage("saveUserEmailForSending", TMessageType.CALL, seqid_));
       args.write(oprot_);
       oprot_.writeMessageEnd();
       oprot_.getTransport().flush();
+    }
-    public void recv_saveUserEmailForSending() throws HelperServiceException, TException
+    public long recv_saveUserEmailForSending() throws HelperServiceException, TException
+    {
       TMessage msg = iprot_.readMessageBegin();
       if (msg.type == TMessageType.EXCEPTION) {
         TApplicationException x = TApplicationException.read(iprot_);
         iprot_.readMessageEnd();
         throw x;
+      }
       saveUserEmailForSending_result result = new saveUserEmailForSending_result();
       result.read(iprot_);
       iprot_.readMessageEnd();
+      if (result.isSetSuccess()) {
+        return result.success;
+      }
       if (result.se != null) {
         throw result.se;
+      }
-      return;
+      throw new TApplicationException(TApplicationException.MISSING_RESULT, "saveUserEmailForSending failed: unknown result");
+    }
     public List<UserEmail> getEmailsToBeSent() throws HelperServiceException, TException
+    {
       send_getEmailsToBeSent();
         saveUserEmailForSending_args args = new saveUserEmailForSending_args();
         args.read(iprot);
         iprot.readMessageEnd();
         saveUserEmailForSending_result result = new saveUserEmailForSending_result();
         try {
-          iface_.saveUserEmailForSending(args.emailTo, args.emailFrom, args.subject, args.body, args.source, args.emailType);
+          result.success = iface_.saveUserEmailForSending(args.emailTo, args.emailFrom, args.subject, args.body, args.source, args.emailType);
+          result.setSuccessIsSet(true);
         } catch (HelperServiceException se) {
           result.se = se;
         } catch (Throwable th) {
           LOGGER.error("Internal error processing saveUserEmailForSending", th);
           TApplicationException x = new TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error processing saveUserEmailForSending");
+  }
   public static class saveUserEmailForSending_result implements TBase<saveUserEmailForSending_result._Fields>, java.io.Serializable, Cloneable, Comparable<saveUserEmailForSending_result>   {
     private static final TStruct STRUCT_DESC = new TStruct("saveUserEmailForSending_result");
+    private static final TField SUCCESS_FIELD_DESC = new TField("success", TType.I64, (short)0);
     private static final TField SE_FIELD_DESC = new TField("se", TType.STRUCT, (short)1);
+    private long success;
     private HelperServiceException se;
     /** 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"),
       SE((short)1, "se");
       private static final Map<Integer, _Fields> byId = new HashMap<Integer, _Fields>();
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
         return _fieldName;
+      }
+    }
     // isset id assignments
+    private 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.I64)));
       put(_Fields.SE, new FieldMetaData("se", TFieldRequirementType.DEFAULT,
           new FieldValueMetaData(TType.STRUCT)));
     }});
     static {
     public saveUserEmailForSending_result() {
+    }
     public saveUserEmailForSending_result(
+      long success,
       HelperServiceException se)
+    {
       this();
+      this.success = success;
+      setSuccessIsSet(true);
       this.se = se;
+    }
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public saveUserEmailForSending_result(saveUserEmailForSending_result other) {
+      __isset_bit_vector.clear();
+      __isset_bit_vector.or(other.__isset_bit_vector);
+      this.success = other.success;
       if (other.isSetSe()) {
         this.se = new HelperServiceException(other.se);
+      }
+    }
     @Deprecated
     public saveUserEmailForSending_result clone() {
       return new saveUserEmailForSending_result(this);
+    }
+    public long getSuccess() {
+      return this.success;
+    }
+    public saveUserEmailForSending_result setSuccess(long 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 HelperServiceException getSe() {
       return this.se;
+    }
     public saveUserEmailForSending_result setSe(HelperServiceException se) {
+      }
+    }
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
+      case SUCCESS:
+        if (value == null) {
+          unsetSuccess();
+        } else {
+          setSuccess((Long)value);
+        }
+        break;
       case SE:
         if (value == null) {
           unsetSe();
         } else {
           setSe((HelperServiceException)value);
       setFieldValue(_Fields.findByThriftIdOrThrow(fieldID), value);
+    }
     public Object getFieldValue(_Fields field) {
       switch (field) {
+      case SUCCESS:
+        return new Long(getSuccess());
       case SE:
         return getSe();
+      }
       throw new IllegalStateException();
+    }
     /** 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();
       case SE:
         return isSetSe();
+      }
       throw new IllegalStateException();
+    }
     public boolean equals(saveUserEmailForSending_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;
+      }
       boolean this_present_se = true && this.isSetSe();
       boolean that_present_se = true && that.isSetSe();
       if (this_present_se || that_present_se) {
         if (!(this_present_se && that_present_se))
           return false;
+      }
       int lastComparison = 0;
       saveUserEmailForSending_result typedOther = (saveUserEmailForSending_result)other;
+      lastComparison = Boolean.valueOf(isSetSuccess()).compareTo(isSetSuccess());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      lastComparison = TBaseHelper.compareTo(success, typedOther.success);
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
       lastComparison = Boolean.valueOf(isSetSe()).compareTo(isSetSe());
       if (lastComparison != 0) {
         return lastComparison;
+      }
       lastComparison = TBaseHelper.compareTo(se, typedOther.se);
         _Fields fieldId = _Fields.findByThriftId(field.id);
         if (fieldId == null) {
           TProtocolUtil.skip(iprot, field.type);
         } else {
           switch (fieldId) {
+            case SUCCESS:
+              if (field.type == TType.I64) {
+                this.success = iprot.readI64();
+                setSuccessIsSet(true);
+              } else {
+                TProtocolUtil.skip(iprot, field.type);
+              }
+              break;
             case SE:
               if (field.type == TType.STRUCT) {
                 this.se = new HelperServiceException();
                 this.se.read(iprot);
               } else {
+    }
     public void write(TProtocol oprot) throws TException {
       oprot.writeStructBegin(STRUCT_DESC);
-      if (this.isSetSe()) {
+      if (this.isSetSuccess()) {
+        oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+        oprot.writeI64(this.success);
+        oprot.writeFieldEnd();
+      } else if (this.isSetSe()) {
         oprot.writeFieldBegin(SE_FIELD_DESC);
         this.se.write(oprot);
         oprot.writeFieldEnd();
+      }
       oprot.writeFieldStop();
     @Override
     public String toString() {
       StringBuilder sb = new StringBuilder("saveUserEmailForSending_result(");
       boolean first = true;
+      sb.append("success:");
+      sb.append(this.success);
+      first = false;
+      if (!first) sb.append(", ");
       sb.append("se:");
       if (this.se == null) {
         sb.append("null");
       } else {
         sb.append(this.se);

Subversion Repositories SmartDukaan

(root)/trunk/ThriftConfig/src/main/java/in/shop2020/utils/HelperService.java – Rev 3086 → 3206