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

      * @param body
      * @param source
      * @param emailType
      * @param cc
      * @param bcc
+     * @param sourceId
      */
-    public long saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc) throws HelperServiceException, org.apache.thrift.TException;
+    public long saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, long sourceId) throws HelperServiceException, org.apache.thrift.TException;
     /**
      * Retreives all the emails pending for dispatch
      */
     public List<UserEmail> getEmailsToBeSent() throws HelperServiceException, org.apache.thrift.TException;
+  }
   public interface AsyncIface extends in.shop2020.generic.GenericService .AsyncIface {
-    public void saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.saveUserEmailForSending_call> resultHandler) throws org.apache.thrift.TException;
+    public void saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, long sourceId, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.saveUserEmailForSending_call> resultHandler) throws org.apache.thrift.TException;
     public void getEmailsToBeSent(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getEmailsToBeSent_call> resultHandler) throws org.apache.thrift.TException;
     public void markEmailAsSent(long emailId, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.markEmailAsSent_call> resultHandler) throws org.apache.thrift.TException;
     public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
       super(iprot, oprot);
+    }
-    public long saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc) throws HelperServiceException, org.apache.thrift.TException
+    public long saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, long sourceId) throws HelperServiceException, org.apache.thrift.TException
+    {
-      send_saveUserEmailForSending(emailTo, emailFrom, subject, body, source, emailType, cc, bcc);
+      send_saveUserEmailForSending(emailTo, emailFrom, subject, body, source, emailType, cc, bcc, sourceId);
       return recv_saveUserEmailForSending();
+    }
-    public void send_saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc) throws org.apache.thrift.TException
+    public void send_saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, long sourceId) throws org.apache.thrift.TException
+    {
       saveUserEmailForSending_args args = new saveUserEmailForSending_args();
       args.setEmailTo(emailTo);
       args.setEmailFrom(emailFrom);
       args.setSubject(subject);
       args.setBody(body);
       args.setSource(source);
       args.setEmailType(emailType);
       args.setCc(cc);
       args.setBcc(bcc);
+      args.setSourceId(sourceId);
       sendBase("saveUserEmailForSending", args);
+    }
     public long recv_saveUserEmailForSending() throws HelperServiceException, org.apache.thrift.TException
+    {
     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 saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, org.apache.thrift.async.AsyncMethodCallback<saveUserEmailForSending_call> resultHandler) throws org.apache.thrift.TException {
+    public void saveUserEmailForSending(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, long sourceId, org.apache.thrift.async.AsyncMethodCallback<saveUserEmailForSending_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      saveUserEmailForSending_call method_call = new saveUserEmailForSending_call(emailTo, emailFrom, subject, body, source, emailType, cc, bcc, resultHandler, this, ___protocolFactory, ___transport);
+      saveUserEmailForSending_call method_call = new saveUserEmailForSending_call(emailTo, emailFrom, subject, body, source, emailType, cc, bcc, sourceId, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
+    }
     public static class saveUserEmailForSending_call extends org.apache.thrift.async.TAsyncMethodCall {
       private String body;
       private String source;
       private String emailType;
       private List<String> cc;
       private List<String> bcc;
+      private long sourceId;
-      public saveUserEmailForSending_call(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, org.apache.thrift.async.AsyncMethodCallback<saveUserEmailForSending_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      public saveUserEmailForSending_call(List<String> emailTo, String emailFrom, String subject, String body, String source, String emailType, List<String> cc, List<String> bcc, long sourceId, org.apache.thrift.async.AsyncMethodCallback<saveUserEmailForSending_call> 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.emailTo = emailTo;
         this.emailFrom = emailFrom;
         this.subject = subject;
         this.body = body;
         this.source = source;
         this.emailType = emailType;
         this.cc = cc;
         this.bcc = bcc;
+        this.sourceId = sourceId;
+      }
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("saveUserEmailForSending", org.apache.thrift.protocol.TMessageType.CALL, 0));
         saveUserEmailForSending_args args = new saveUserEmailForSending_args();
         args.setBody(body);
         args.setSource(source);
         args.setEmailType(emailType);
         args.setCc(cc);
         args.setBcc(bcc);
+        args.setSourceId(sourceId);
         args.write(prot);
         prot.writeMessageEnd();
+      }
       public long getResult() throws HelperServiceException, org.apache.thrift.TException {
+      }
       protected saveUserEmailForSending_result getResult(I iface, saveUserEmailForSending_args args) throws org.apache.thrift.TException {
         saveUserEmailForSending_result result = new saveUserEmailForSending_result();
         try {
-          result.success = iface.saveUserEmailForSending(args.emailTo, args.emailFrom, args.subject, args.body, args.source, args.emailType, args.cc, args.bcc);
+          result.success = iface.saveUserEmailForSending(args.emailTo, args.emailFrom, args.subject, args.body, args.source, args.emailType, args.cc, args.bcc, args.sourceId);
           result.setSuccessIsSet(true);
         } catch (HelperServiceException se) {
           result.se = se;
+        }
         return result;
     private static final org.apache.thrift.protocol.TField BODY_FIELD_DESC = new org.apache.thrift.protocol.TField("body", org.apache.thrift.protocol.TType.STRING, (short)4);
     private static final org.apache.thrift.protocol.TField SOURCE_FIELD_DESC = new org.apache.thrift.protocol.TField("source", org.apache.thrift.protocol.TType.STRING, (short)5);
     private static final org.apache.thrift.protocol.TField EMAIL_TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("emailType", org.apache.thrift.protocol.TType.STRING, (short)6);
     private static final org.apache.thrift.protocol.TField CC_FIELD_DESC = new org.apache.thrift.protocol.TField("cc", org.apache.thrift.protocol.TType.LIST, (short)7);
     private static final org.apache.thrift.protocol.TField BCC_FIELD_DESC = new org.apache.thrift.protocol.TField("bcc", org.apache.thrift.protocol.TType.LIST, (short)8);
+    private static final org.apache.thrift.protocol.TField SOURCE_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("sourceId", org.apache.thrift.protocol.TType.I64, (short)9);
     private List<String> emailTo; // required
     private String emailFrom; // required
     private String subject; // required
     private String body; // required
     private String source; // required
     private String emailType; // required
     private List<String> cc; // required
     private List<String> bcc; // required
+    private long sourceId; // 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 {
       EMAIL_TO((short)1, "emailTo"),
       EMAIL_FROM((short)2, "emailFrom"),
       SUBJECT((short)3, "subject"),
       BODY((short)4, "body"),
       SOURCE((short)5, "source"),
       EMAIL_TYPE((short)6, "emailType"),
       CC((short)7, "cc"),
-      BCC((short)8, "bcc");
+      BCC((short)8, "bcc"),
+      SOURCE_ID((short)9, "sourceId");
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
       static {
         for (_Fields field : EnumSet.allOf(_Fields.class)) {
             return EMAIL_TYPE;
           case 7: // CC
             return CC;
           case 8: // BCC
             return BCC;
+          case 9: // SOURCE_ID
+            return SOURCE_ID;
           default:
             return null;
+        }
+      }
         return _fieldName;
+      }
+    }
     // isset id assignments
+    private static final int __SOURCEID_ISSET_ID = 0;
+    private BitSet __isset_bit_vector = new BitSet(1);
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
       tmpMap.put(_Fields.EMAIL_TO, new org.apache.thrift.meta_data.FieldMetaData("emailTo", org.apache.thrift.TFieldRequirementType.DEFAULT,
           new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
               new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
       tmpMap.put(_Fields.BCC, new org.apache.thrift.meta_data.FieldMetaData("bcc", org.apache.thrift.TFieldRequirementType.DEFAULT,
           new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
               new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));
+      tmpMap.put(_Fields.SOURCE_ID, new org.apache.thrift.meta_data.FieldMetaData("sourceId", org.apache.thrift.TFieldRequirementType.DEFAULT,
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
       org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(saveUserEmailForSending_args.class, metaDataMap);
+    }
     public saveUserEmailForSending_args() {
       String subject,
       String body,
       String source,
       String emailType,
       List<String> cc,
-      List<String> bcc)
+      List<String> bcc,
+      long sourceId)
+    {
       this();
       this.emailTo = emailTo;
       this.emailFrom = emailFrom;
       this.subject = subject;
       this.body = body;
       this.source = source;
       this.emailType = emailType;
       this.cc = cc;
       this.bcc = bcc;
+      this.sourceId = sourceId;
+      setSourceIdIsSet(true);
+    }
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public saveUserEmailForSending_args(saveUserEmailForSending_args other) {
+      __isset_bit_vector.clear();
+      __isset_bit_vector.or(other.__isset_bit_vector);
       if (other.isSetEmailTo()) {
         List<String> __this__emailTo = new ArrayList<String>();
         for (String other_element : other.emailTo) {
           __this__emailTo.add(other_element);
+        }
         for (String other_element : other.bcc) {
           __this__bcc.add(other_element);
+        }
         this.bcc = __this__bcc;
+      }
+      this.sourceId = other.sourceId;
+    }
     public saveUserEmailForSending_args deepCopy() {
       return new saveUserEmailForSending_args(this);
+    }
       this.body = null;
       this.source = null;
       this.emailType = null;
       this.cc = null;
       this.bcc = null;
+      setSourceIdIsSet(false);
+      this.sourceId = 0;
+    }
     public int getEmailToSize() {
       return (this.emailTo == null) ? 0 : this.emailTo.size();
+    }
       if (!value) {
         this.bcc = null;
+      }
+    }
+    public long getSourceId() {
+      return this.sourceId;
+    }
+    public void setSourceId(long sourceId) {
+      this.sourceId = sourceId;
+      setSourceIdIsSet(true);
+    }
+    public void unsetSourceId() {
+      __isset_bit_vector.clear(__SOURCEID_ISSET_ID);
+    }
+    /** Returns true if field sourceId is set (has been assigned a value) and false otherwise */
+    public boolean isSetSourceId() {
+      return __isset_bit_vector.get(__SOURCEID_ISSET_ID);
+    }
+    public void setSourceIdIsSet(boolean value) {
+      __isset_bit_vector.set(__SOURCEID_ISSET_ID, value);
+    }
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
       case EMAIL_TO:
         if (value == null) {
           unsetEmailTo();
         } else {
           setBcc((List<String>)value);
+        }
         break;
+      case SOURCE_ID:
+        if (value == null) {
+          unsetSourceId();
+        } else {
+          setSourceId((Long)value);
+        }
+        break;
+      }
+    }
     public Object getFieldValue(_Fields field) {
       switch (field) {
         return getCc();
       case BCC:
         return getBcc();
+      case SOURCE_ID:
+        return Long.valueOf(getSourceId());
+      }
       throw new IllegalStateException();
+    }
     /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
         return isSetEmailType();
       case CC:
         return isSetCc();
       case BCC:
         return isSetBcc();
+      case SOURCE_ID:
+        return isSetSourceId();
+      }
       throw new IllegalStateException();
+    }
     @Override
           return false;
         if (!this.bcc.equals(that.bcc))
           return false;
+      }
+      boolean this_present_sourceId = true;
+      boolean that_present_sourceId = true;
+      if (this_present_sourceId || that_present_sourceId) {
+        if (!(this_present_sourceId && that_present_sourceId))
+          return false;
+        if (this.sourceId != that.sourceId)
+          return false;
+      }
       return true;
+    }
     @Override
     public int hashCode() {
         lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.bcc, typedOther.bcc);
         if (lastComparison != 0) {
           return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetSourceId()).compareTo(typedOther.isSetSourceId());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetSourceId()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.sourceId, typedOther.sourceId);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
       return 0;
+    }
     public _Fields fieldForId(int fieldId) {
       return _Fields.findByThriftId(fieldId);
+              }
             } else {
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            }
             break;
+          case 9: // SOURCE_ID
+            if (field.type == org.apache.thrift.protocol.TType.I64) {
+              this.sourceId = iprot.readI64();
+              setSourceIdIsSet(true);
+            } else {
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
           default:
             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+        }
         iprot.readFieldEnd();
+      }
+          }
           oprot.writeListEnd();
+        }
         oprot.writeFieldEnd();
+      }
+      oprot.writeFieldBegin(SOURCE_ID_FIELD_DESC);
+      oprot.writeI64(this.sourceId);
+      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
+    }
     @Override
         sb.append("null");
       } else {
         sb.append(this.bcc);
+      }
       first = false;
+      if (!first) sb.append(", ");
+      sb.append("sourceId:");
+      sb.append(this.sourceId);
+      first = false;
       sb.append(")");
       return sb.toString();
+    }
     public void validate() throws org.apache.thrift.TException {
+      }
+    }
     private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, 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_bit_vector = new BitSet(1);
         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);
+      }
+    }

Subversion Repositories SmartDukaan

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