source: trunk/src/main/java/omq/common/message/Request.java

package omq.common.message;

import java.io.Serializable;

/**
 * Serializable request information. This class is used to send the information
 * to the server. It has information about which method is wanted to invoke, its
 * parameters, its correlation id and if a response is needed -asynchronous
 * method-.
 * 
 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
 * 
 */
public class Request implements Serializable {

        /**
         * 
         */
        private static final long serialVersionUID = 6366255840200365083L;

        private String method;
        private Object[] params;
        private String id;
        private boolean async = false;

        private transient boolean multi;
        private transient int wait;
        private transient long timeout;
        private transient int retries;

        // This constructor is used by kryo
        public Request() {
        }

        public Request(String id, String method, boolean async, Object[] params) {
                this.id = id;
                this.method = method;
                this.async = async;
                this.params = params;
        }

        public Request(String id, String method, boolean async, Object[] params, boolean multi) {
                this.id = id;
                this.method = method;
                this.async = async;
                this.params = params;
                this.multi = multi;
        }

        /**
         * This method creates a new synchronous request
         * 
         * @param id
         *            - correlation id of this invocation
         * @param method
         *            - method name wanted to call
         * @param params
         *            - parameters of this method
         * @return - new SyncRequest
         */
        public static Request newSyncRequest(String id, String method, Object[] params) {
                return new Request(id, method, false, params);
        }

        /**
         * This method creates a new synchronous request
         * 
         * @param id
         *            - correlation id of this invocation
         * @param method
         *            - method name wanted to call
         * @param params
         *            - parameters of this method
         * @param retries
         *            - How many retries will be done
         * @param timeout
         *            - Timeout for every retry
         * @param multi
         *            - If the method is multi
         * @param wait
         *            - If the method is multi how many responses will be listened
         * @return - new SyncRequest
         */
        public static Request newSyncRequest(String id, String method, Object[] params, int retries, long timeout, boolean multi, int wait) {
                Request req = new Request(id, method, false, params, multi);
                req.setRetries(retries);
                req.setTimeout(timeout);
                req.setWait(wait);
                return req;
        }

        /**
         * This method creates a new asynchronous request
         * 
         * @param id
         *            - correlation id of this invocation
         * @param method
         *            - method name wanted to call
         * @param params
         *            - parameters of this method
         * @param multi
         *            - If the method is multi
         * @return new AsyncRequest
         */
        public static Request newAsyncRequest(String id, String method, Object[] params, boolean multi) {
                return new Request(id, method, true, params, multi);
        }

        public String getId() {
                return id;
        }

        public void setId(String id) {
                this.id = id;
        }

        public String getMethod() {
                return method;
        }

        public void setMethod(String method) {
                this.method = method;
        }

        public Object[] getParams() {
                return params;
        }

        public void setParams(Object[] params) {
                this.params = params;
        }

        public boolean isAsync() {
                return async;
        }

        public void setAsync(boolean async) {
                this.async = async;
        }

        public long getTimeout() {
                return timeout;
        }

        public void setTimeout(long timeout) {
                this.timeout = timeout;
        }

        public int getRetries() {
                return retries;
        }

        public void setRetries(int retries) {
                this.retries = retries;
        }

        public boolean isMulti() {
                return multi;
        }

        public void setMulti(boolean multi) {
                this.multi = multi;
        }

        public int getWait() {
                return wait;
        }

        public void setWait(int wait) {
                this.wait = wait;
        }
}