Subversion Repositories SmartDukaan

/**

 * Autogenerated by Thrift Compiler (0.7.0)

 *

 * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING

 */

package in.shop2020.utils;

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.nio.ByteBuffer;

import java.util.Arrays;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class HelperService {

  public interface Iface extends in.shop2020.generic.GenericService.Iface {

    /**

     * Save email details, to be sent later; Also returns its identifier.

     * 

     * @param emailTo

     * @param emailFrom

     * @param subject

     * @param body

     * @param source

     * @param emailType

     */

    public long saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType) throws HelperServiceException, org.apache.thrift.TException;

    /**

     * Retreives all the emails pending for dispatch

     */

    public List<UserEmail> getEmailsToBeSent() throws HelperServiceException, org.apache.thrift.TException;

    /**

     * Marks email as sent after successful dispatch

     * 

     * @param emailId

     */

    public void markEmailAsSent(long emailId) throws HelperServiceException, org.apache.thrift.TException;

    public void sendMail(Mail mail) throws HelperServiceException, org.apache.thrift.TException;

    public void sendText(TextMessage message) throws HelperServiceException, org.apache.thrift.TException;

    public void addMessage(Message message) throws HelperServiceException, org.apache.thrift.TException;

    public void updateMessage(long id, String message) throws HelperServiceException, org.apache.thrift.TException;

    public Message getMessage(long id) throws HelperServiceException, org.apache.thrift.TException;

    public Message getSubstitutedMessage(long id, Map<String,String> params) throws HelperServiceException, org.apache.thrift.TException;

    public boolean addUser(String username, String password, long warehouseId) throws HelperServiceException, org.apache.thrift.TException;

    public boolean deleteUser(String username) throws HelperServiceException, org.apache.thrift.TException;

    /**

     * Returns the dashboard user if the supplied username and password match. Raises an exception otherwise.

     * The loggedOn timestamp for the dashboard user is updated .

     * 

     * @param username

     * @param password

     */

    public DashboardUser authenticateDashboardUser(String username, String password) throws HelperServiceException, org.apache.thrift.TException;

    /**

     * Update the password of the dashboard user. Currently, there is no place where this method is called.

     * 

     * @param username

     * @param oldPassword

     * @param newPassword

     */

    public boolean updatePassword(String username, String oldPassword, String newPassword) throws HelperServiceException, org.apache.thrift.TException;

    /**

     * Returns the LogisticsUser struct associated with the given username and password if they match.

     * Throws an exception otherwise.

     * 

     * @param username

     * @param password

     */

    public LogisticsUser authenticateLogisticsUser(String username, String password) throws HelperServiceException, org.apache.thrift.TException;

    /**

     * Returns the StatisticsUser struct associated with the given username and password if they match.

     * Throws an exception otherwise.

     * 

     * @param username

     * @param password

     */

    public StatisticsUser authenticateStatisticsUser(String username, String password) throws HelperServiceException, org.apache.thrift.TException;

    /**

     * Returns the ReportUser struct associated with the given username and password if they match.

     * Throws an exception otherwise.

     * 

     * @param username

     * @param password

     */

    public ReportUser authenticateReportUser(String username, String password) throws HelperServiceException, org.apache.thrift.TException;

    /**

     * Returns list of reports which are configured for the given role.

     * 

     * @param role

     */

    public List<Report> getReports(long role) throws org.apache.thrift.TException;

    /**

     * Returns the CatalogDashboardUser struct associated with the given username, password and role if they match.

     * Throws an exception otherwise.

     * 

     * @param username

     * @param password

     * @param role

     */

    public CatalogDashboardUser authenticateCatalogUser(String username, String password, long role) throws HelperServiceException, org.apache.thrift.TException;

  }

  public interface AsyncIface extends in.shop2020.generic.GenericService .AsyncIface {

    public void saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType, 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 void sendMail(Mail mail, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.sendMail_call> resultHandler) throws org.apache.thrift.TException;

    public void sendText(TextMessage message, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.sendText_call> resultHandler) throws org.apache.thrift.TException;

    public void addMessage(Message message, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.addMessage_call> resultHandler) throws org.apache.thrift.TException;

    public void updateMessage(long id, String message, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.updateMessage_call> resultHandler) throws org.apache.thrift.TException;

    public void getMessage(long id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getMessage_call> resultHandler) throws org.apache.thrift.TException;

    public void getSubstitutedMessage(long id, Map<String,String> params, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getSubstitutedMessage_call> resultHandler) throws org.apache.thrift.TException;

    public void addUser(String username, String password, long warehouseId, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.addUser_call> resultHandler) throws org.apache.thrift.TException;

    public void deleteUser(String username, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.deleteUser_call> resultHandler) throws org.apache.thrift.TException;

    public void authenticateDashboardUser(String username, String password, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.authenticateDashboardUser_call> resultHandler) throws org.apache.thrift.TException;

    public void updatePassword(String username, String oldPassword, String newPassword, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.updatePassword_call> resultHandler) throws org.apache.thrift.TException;

    public void authenticateLogisticsUser(String username, String password, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.authenticateLogisticsUser_call> resultHandler) throws org.apache.thrift.TException;

    public void authenticateStatisticsUser(String username, String password, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.authenticateStatisticsUser_call> resultHandler) throws org.apache.thrift.TException;

    public void authenticateReportUser(String username, String password, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.authenticateReportUser_call> resultHandler) throws org.apache.thrift.TException;

    public void getReports(long role, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getReports_call> resultHandler) throws org.apache.thrift.TException;

    public void authenticateCatalogUser(String username, String password, long role, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.authenticateCatalogUser_call> resultHandler) throws org.apache.thrift.TException;

  }

  public static class Client extends in.shop2020.generic.GenericService.Client 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 long saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType) throws HelperServiceException, org.apache.thrift.TException

    {

      send_saveUserEmailForSending(emailTo, emailFrom, subject, body, source, emailType);

      return recv_saveUserEmailForSending();

    }

    public void send_saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType) 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);

      sendBase("saveUserEmailForSending", args);

    }

    public long recv_saveUserEmailForSending() throws HelperServiceException, org.apache.thrift.TException

    {

      saveUserEmailForSending_result result = new saveUserEmailForSending_result();

      receiveBase(result, "saveUserEmailForSending");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.se != null) {

        throw result.se;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "saveUserEmailForSending failed: unknown result");

    }

    public List<UserEmail> getEmailsToBeSent() throws HelperServiceException, org.apache.thrift.TException

    {

      send_getEmailsToBeSent();

      return recv_getEmailsToBeSent();

    }

    public void send_getEmailsToBeSent() throws org.apache.thrift.TException

    {

      getEmailsToBeSent_args args = new getEmailsToBeSent_args();

      sendBase("getEmailsToBeSent", args);

    }

    public List<UserEmail> recv_getEmailsToBeSent() throws HelperServiceException, org.apache.thrift.TException

    {

      getEmailsToBeSent_result result = new getEmailsToBeSent_result();

      receiveBase(result, "getEmailsToBeSent");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.se != null) {

        throw result.se;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getEmailsToBeSent failed: unknown result");

    }

    public void markEmailAsSent(long emailId) throws HelperServiceException, org.apache.thrift.TException

    {

      send_markEmailAsSent(emailId);

      recv_markEmailAsSent();

    }

    public void send_markEmailAsSent(long emailId) throws org.apache.thrift.TException

    {

      markEmailAsSent_args args = new markEmailAsSent_args();

      args.setEmailId(emailId);

      sendBase("markEmailAsSent", args);

    }

    public void recv_markEmailAsSent() throws HelperServiceException, org.apache.thrift.TException

    {

      markEmailAsSent_result result = new markEmailAsSent_result();

      receiveBase(result, "markEmailAsSent");

      if (result.se != null) {

        throw result.se;

      }

      return;

    }

    public void sendMail(Mail mail) throws HelperServiceException, org.apache.thrift.TException

    {

      send_sendMail(mail);

      recv_sendMail();

    }

    public void send_sendMail(Mail mail) throws org.apache.thrift.TException

    {

      sendMail_args args = new sendMail_args();

      args.setMail(mail);

      sendBase("sendMail", args);

    }

    public void recv_sendMail() throws HelperServiceException, org.apache.thrift.TException

    {

      sendMail_result result = new sendMail_result();

      receiveBase(result, "sendMail");

      if (result.se != null) {

        throw result.se;

      }

      return;

    }

    public void sendText(TextMessage message) throws HelperServiceException, org.apache.thrift.TException

    {

      send_sendText(message);

      recv_sendText();

    }

    public void send_sendText(TextMessage message) throws org.apache.thrift.TException

    {

      sendText_args args = new sendText_args();

      args.setMessage(message);

      sendBase("sendText", args);

    }

    public void recv_sendText() throws HelperServiceException, org.apache.thrift.TException

    {

      sendText_result result = new sendText_result();

      receiveBase(result, "sendText");

      if (result.se != null) {

        throw result.se;

      }

      return;

    }

    public void addMessage(Message message) throws HelperServiceException, org.apache.thrift.TException

    {

      send_addMessage(message);

      recv_addMessage();

    }

    public void send_addMessage(Message message) throws org.apache.thrift.TException

    {

      addMessage_args args = new addMessage_args();

      args.setMessage(message);

      sendBase("addMessage", args);

    }

    public void recv_addMessage() throws HelperServiceException, org.apache.thrift.TException

    {

      addMessage_result result = new addMessage_result();

      receiveBase(result, "addMessage");

      if (result.se != null) {

        throw result.se;

      }

      return;

    }

    public void updateMessage(long id, String message) throws HelperServiceException, org.apache.thrift.TException

    {

      send_updateMessage(id, message);

      recv_updateMessage();

    }

    public void send_updateMessage(long id, String message) throws org.apache.thrift.TException

    {

      updateMessage_args args = new updateMessage_args();

      args.setId(id);

      args.setMessage(message);

      sendBase("updateMessage", args);

    }

    public void recv_updateMessage() throws HelperServiceException, org.apache.thrift.TException

    {

      updateMessage_result result = new updateMessage_result();

      receiveBase(result, "updateMessage");

      if (result.se != null) {

        throw result.se;

      }

      return;

    }

    public Message getMessage(long id) throws HelperServiceException, org.apache.thrift.TException

    {

      send_getMessage(id);

      return recv_getMessage();

    }

    public void send_getMessage(long id) throws org.apache.thrift.TException

    {

      getMessage_args args = new getMessage_args();

      args.setId(id);

      sendBase("getMessage", args);

    }

    public Message recv_getMessage() throws HelperServiceException, org.apache.thrift.TException

    {

      getMessage_result result = new getMessage_result();

      receiveBase(result, "getMessage");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.se != null) {

        throw result.se;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getMessage failed: unknown result");

    }

    public Message getSubstitutedMessage(long id, Map<String,String> params) throws HelperServiceException, org.apache.thrift.TException

    {

      send_getSubstitutedMessage(id, params);

      return recv_getSubstitutedMessage();

    }

    public void send_getSubstitutedMessage(long id, Map<String,String> params) throws org.apache.thrift.TException

    {

      getSubstitutedMessage_args args = new getSubstitutedMessage_args();

      args.setId(id);

      args.setParams(params);

      sendBase("getSubstitutedMessage", args);

    }

    public Message recv_getSubstitutedMessage() throws HelperServiceException, org.apache.thrift.TException

    {

      getSubstitutedMessage_result result = new getSubstitutedMessage_result();

      receiveBase(result, "getSubstitutedMessage");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.se != null) {

        throw result.se;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getSubstitutedMessage failed: unknown result");

    }

    public boolean addUser(String username, String password, long warehouseId) throws HelperServiceException, org.apache.thrift.TException

    {

      send_addUser(username, password, warehouseId);

      return recv_addUser();

    }

    public void send_addUser(String username, String password, long warehouseId) throws org.apache.thrift.TException

    {

      addUser_args args = new addUser_args();

      args.setUsername(username);

      args.setPassword(password);

      args.setWarehouseId(warehouseId);

      sendBase("addUser", args);

    }

    public boolean recv_addUser() throws HelperServiceException, org.apache.thrift.TException

    {

      addUser_result result = new addUser_result();

      receiveBase(result, "addUser");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.se != null) {

        throw result.se;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "addUser failed: unknown result");

    }

    public boolean deleteUser(String username) throws HelperServiceException, org.apache.thrift.TException

    {

      send_deleteUser(username);

      return recv_deleteUser();

    }

    public void send_deleteUser(String username) throws org.apache.thrift.TException

    {

      deleteUser_args args = new deleteUser_args();

      args.setUsername(username);

      sendBase("deleteUser", args);

    }

    public boolean recv_deleteUser() throws HelperServiceException, org.apache.thrift.TException

    {

      deleteUser_result result = new deleteUser_result();

      receiveBase(result, "deleteUser");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.se != null) {

        throw result.se;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deleteUser failed: unknown result");

    }

    public DashboardUser authenticateDashboardUser(String username, String password) throws HelperServiceException, org.apache.thrift.TException

    {

      send_authenticateDashboardUser(username, password);

      return recv_authenticateDashboardUser();

    }

    public void send_authenticateDashboardUser(String username, String password) throws org.apache.thrift.TException

    {

      authenticateDashboardUser_args args = new authenticateDashboardUser_args();

      args.setUsername(username);

      args.setPassword(password);

      sendBase("authenticateDashboardUser", args);

    }

    public DashboardUser recv_authenticateDashboardUser() throws HelperServiceException, org.apache.thrift.TException

    {

      authenticateDashboardUser_result result = new authenticateDashboardUser_result();

      receiveBase(result, "authenticateDashboardUser");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.se != null) {

        throw result.se;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "authenticateDashboardUser failed: unknown result");

    }

    public boolean updatePassword(String username, String oldPassword, String newPassword) throws HelperServiceException, org.apache.thrift.TException

    {

      send_updatePassword(username, oldPassword, newPassword);

      return recv_updatePassword();

    }

    public void send_updatePassword(String username, String oldPassword, String newPassword) throws org.apache.thrift.TException

    {

      updatePassword_args args = new updatePassword_args();

      args.setUsername(username);

      args.setOldPassword(oldPassword);

      args.setNewPassword(newPassword);

      sendBase("updatePassword", args);

    }

    public boolean recv_updatePassword() throws HelperServiceException, org.apache.thrift.TException

    {

      updatePassword_result result = new updatePassword_result();

      receiveBase(result, "updatePassword");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.se != null) {

        throw result.se;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "updatePassword failed: unknown result");

    }

    public LogisticsUser authenticateLogisticsUser(String username, String password) throws HelperServiceException, org.apache.thrift.TException

    {

      send_authenticateLogisticsUser(username, password);

      return recv_authenticateLogisticsUser();

    }

    public void send_authenticateLogisticsUser(String username, String password) throws org.apache.thrift.TException

    {

      authenticateLogisticsUser_args args = new authenticateLogisticsUser_args();

      args.setUsername(username);

      args.setPassword(password);

      sendBase("authenticateLogisticsUser", args);

    }

    public LogisticsUser recv_authenticateLogisticsUser() throws HelperServiceException, org.apache.thrift.TException

    {

      authenticateLogisticsUser_result result = new authenticateLogisticsUser_result();

      receiveBase(result, "authenticateLogisticsUser");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.hse != null) {

        throw result.hse;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "authenticateLogisticsUser failed: unknown result");

    }

    public StatisticsUser authenticateStatisticsUser(String username, String password) throws HelperServiceException, org.apache.thrift.TException

    {

      send_authenticateStatisticsUser(username, password);

      return recv_authenticateStatisticsUser();

    }

    public void send_authenticateStatisticsUser(String username, String password) throws org.apache.thrift.TException

    {

      authenticateStatisticsUser_args args = new authenticateStatisticsUser_args();

      args.setUsername(username);

      args.setPassword(password);

      sendBase("authenticateStatisticsUser", args);

    }

    public StatisticsUser recv_authenticateStatisticsUser() throws HelperServiceException, org.apache.thrift.TException

    {

      authenticateStatisticsUser_result result = new authenticateStatisticsUser_result();

      receiveBase(result, "authenticateStatisticsUser");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.hse != null) {

        throw result.hse;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "authenticateStatisticsUser failed: unknown result");

    }

    public ReportUser authenticateReportUser(String username, String password) throws HelperServiceException, org.apache.thrift.TException

    {

      send_authenticateReportUser(username, password);

      return recv_authenticateReportUser();

    }

    public void send_authenticateReportUser(String username, String password) throws org.apache.thrift.TException

    {

      authenticateReportUser_args args = new authenticateReportUser_args();

      args.setUsername(username);

      args.setPassword(password);

      sendBase("authenticateReportUser", args);

    }

    public ReportUser recv_authenticateReportUser() throws HelperServiceException, org.apache.thrift.TException

    {

      authenticateReportUser_result result = new authenticateReportUser_result();

      receiveBase(result, "authenticateReportUser");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.hse != null) {

        throw result.hse;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "authenticateReportUser failed: unknown result");

    }

    public List<Report> getReports(long role) throws org.apache.thrift.TException

    {

      send_getReports(role);

      return recv_getReports();

    }

    public void send_getReports(long role) throws org.apache.thrift.TException

    {

      getReports_args args = new getReports_args();

      args.setRole(role);

      sendBase("getReports", args);

    }

    public List<Report> recv_getReports() throws org.apache.thrift.TException

    {

      getReports_result result = new getReports_result();

      receiveBase(result, "getReports");

      if (result.isSetSuccess()) {

        return result.success;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getReports failed: unknown result");

    }

    public CatalogDashboardUser authenticateCatalogUser(String username, String password, long role) throws HelperServiceException, org.apache.thrift.TException

    {

      send_authenticateCatalogUser(username, password, role);

      return recv_authenticateCatalogUser();

    }

    public void send_authenticateCatalogUser(String username, String password, long role) throws org.apache.thrift.TException

    {

      authenticateCatalogUser_args args = new authenticateCatalogUser_args();

      args.setUsername(username);

      args.setPassword(password);

      args.setRole(role);

      sendBase("authenticateCatalogUser", args);

    }

    public CatalogDashboardUser recv_authenticateCatalogUser() throws HelperServiceException, org.apache.thrift.TException

    {

      authenticateCatalogUser_result result = new authenticateCatalogUser_result();

      receiveBase(result, "authenticateCatalogUser");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.hse != null) {

        throw result.hse;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "authenticateCatalogUser failed: unknown result");

    }

  }

  public static class AsyncClient extends in.shop2020.generic.GenericService.AsyncClient 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 saveUserEmailForSending(String emailTo, String emailFrom, String subject, String body, String source, String emailType, 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, 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 emailTo;

      private String emailFrom;

      private String subject;

      private String body;

      private String source;

      private String emailType;

      public saveUserEmailForSending_call(String emailTo, String emailFrom, String subject, String body, String source, String emailType, 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;

      }

      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.setEmailTo(emailTo);

        args.setEmailFrom(emailFrom);

        args.setSubject(subject);

        args.setBody(body);

        args.setSource(source);

        args.setEmailType(emailType);

        args.write(prot);

        prot.writeMessageEnd();

      }

      public long getResult() throws HelperServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new 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_saveUserEmailForSending();

      }

    }

    public void getEmailsToBeSent(org.apache.thrift.async.AsyncMethodCallback<getEmailsToBeSent_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      getEmailsToBeSent_call method_call = new getEmailsToBeSent_call(resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class getEmailsToBeSent_call extends org.apache.thrift.async.TAsyncMethodCall {

      public getEmailsToBeSent_call(org.apache.thrift.async.AsyncMethodCallback<getEmailsToBeSent_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);

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getEmailsToBeSent", org.apache.thrift.protocol.TMessageType.CALL, 0));

        getEmailsToBeSent_args args = new getEmailsToBeSent_args();

        args.write(prot);

        prot.writeMessageEnd();

      }

      public List<UserEmail> getResult() throws HelperServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new 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_getEmailsToBeSent();

      }

    }

    public void markEmailAsSent(long emailId, org.apache.thrift.async.AsyncMethodCallback<markEmailAsSent_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      markEmailAsSent_call method_call = new markEmailAsSent_call(emailId, resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class markEmailAsSent_call extends org.apache.thrift.async.TAsyncMethodCall {

      private long emailId;

      public markEmailAsSent_call(long emailId, org.apache.thrift.async.AsyncMethodCallback<markEmailAsSent_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.emailId = emailId;

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("markEmailAsSent", org.apache.thrift.protocol.TMessageType.CALL, 0));

        markEmailAsSent_args args = new markEmailAsSent_args();

        args.setEmailId(emailId);

        args.write(prot);

        prot.writeMessageEnd();

      }

      public void getResult() throws HelperServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new 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);

        (new Client(prot)).recv_markEmailAsSent();

      }

    }

    public void sendMail(Mail mail, org.apache.thrift.async.AsyncMethodCallback<sendMail_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      sendMail_call method_call = new sendMail_call(mail, resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class sendMail_call extends org.apache.thrift.async.TAsyncMethodCall {

      private Mail mail;

      public sendMail_call(Mail mail, org.apache.thrift.async.AsyncMethodCallback<sendMail_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.mail = mail;

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("sendMail", org.apache.thrift.protocol.TMessageType.CALL, 0));

        sendMail_args args = new sendMail_args();

        args.setMail(mail);

        args.write(prot);

        prot.writeMessageEnd();

      }

      public void getResult() throws HelperServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new 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);

        (new Client(prot)).recv_sendMail();

      }

    }

    public void sendText(TextMessage message, org.apache.thrift.async.AsyncMethodCallback<sendText_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      sendText_call method_call = new sendText_call(message, resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class sendText_call extends org.apache.thrift.async.TAsyncMethodCall {

      private TextMessage message;

      public sendText_call(TextMessage message, org.apache.thrift.async.AsyncMethodCallback<sendText_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.message = message;

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("sendText", org.apache.thrift.protocol.TMessageType.CALL, 0));

        sendText_args args = new sendText_args();

        args.setMessage(message);

        args.write(prot);

        prot.writeMessageEnd();

      }

      public void getResult() throws HelperServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new 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);

        (new Client(prot)).recv_sendText();

      }

    }

    public void addMessage(Message message, org.apache.thrift.async.AsyncMethodCallback<addMessage_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      addMessage_call method_call = new addMessage_call(message, resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class addMessage_call extends org.apache.thrift.async.TAsyncMethodCall {

      private Message message;

      public addMessage_call(Message message, org.apache.thrift.async.AsyncMethodCallback<addMessage_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.message = message;

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("addMessage", org.apache.thrift.protocol.TMessageType.CALL, 0));

        addMessage_args args = new addMessage_args();

        args.setMessage(message);

        args.write(prot);

        prot.writeMessageEnd();

      }

      public void getResult() throws HelperServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new 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);

        (new Client(prot)).recv_addMessage();

      }

    }

    public void updateMessage(long id, String message, org.apache.thrift.async.AsyncMethodCallback<updateMessage_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      updateMessage_call method_call = new updateMessage_call(id, message, resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class updateMessage_call extends org.apache.thrift.async.TAsyncMethodCall {

      private long id;

      private String message;

      public updateMessage_call(long id, String message, org.apache.thrift.async.AsyncMethodCallback<updateMessage_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.id = id;

        this.message = message;

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("updateMessage", org.apache.thrift.protocol.TMessageType.CALL, 0));

        updateMessage_args args = new updateMessage_args();

        args.setId(id);

        args.setMessage(message);

        args.write(prot);

        prot.writeMessageEnd();

      }

      public void getResult() throws HelperServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new 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);

        (new Client(prot)).recv_updateMessage();

      }

    }

    public void getMessage(long id, org.apache.thrift.async.AsyncMethodCallback<getMessage_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      getMessage_call method_call = new getMessage_call(id, resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class getMessage_call extends org.apache.thrift.async.TAsyncMethodCall {

      private long id;

      public getMessage_call(long id, org.apache.thrift.async.AsyncMethodCallback<getMessage_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.id = id;

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getMessage", org.apache.thrift.protocol.TMessageType.CALL, 0));

        getMessage_args args = new getMessage_args();

        args.setId(id);

        args.write(prot);

        prot.writeMessageEnd();

      }

      public Message getResult() throws HelperServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new 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_getMessage();

      }

    }

    public void getSubstitutedMessage(long id, Map<String,String> params, org.apache.thrift.async.AsyncMethodCallback<getSubstitutedMessage_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      getSubstitutedMessage_call method_call = new getSubstitutedMessage_call(id, params, resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class getSubstitutedMessage_call extends org.apache.thrift.async.TAsyncMethodCall {

      private long id;

      private Map<String,String> params;

      public getSubstitutedMessage_call(long id, Map<String,String> params, org.apache.thrift.async.AsyncMethodCallback<getSubstitutedMessage_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.id = id;

        this.params = params;

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getSubstitutedMessage", org.apache.thrift.protocol.TMessageType.CALL, 0));

        getSubstitutedMessage_args args = new getSubstitutedMessage_args();

        args.setId(id);

        args.setParams(params);

        args.write(prot);