Ignore:
Timestamp:
07/08/13 13:29:24 (11 years ago)
Author:
stoda
Message:

J

Location:
trunk/src/main/java/omq/common/util
Files:
8 edited

Legend:

Unmodified
Added
Removed

  • trunk/src/main/java/omq/common/util/OmqConnectionFactory.java

    r77 r83  
    1313
    1414/**
     15 * This class creates RabbitMQ connections
    1516 *
    1617 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
    … …  
    2324        private static int connectionTimeout = 2 * 1000;
    2425
     26        /**
     27         * If this class is wanted to use as a singleton class this is the init
     28         * function
     29         *
     30         * @param env
     31         *            - environment that sets the properties needed by RabbitMQ
     32         * @throws KeyManagementException
     33         * @throws NoSuchAlgorithmException
     34         * @throws IOException
     35         */
    2536        public static void init(Properties env) throws KeyManagementException, NoSuchAlgorithmException, IOException {
    2637                if (connection == null) {
    … …  
    2940        }
    3041
     42        /**
     43         * This function returns a working connection.
     44         *
     45         * @param env
     46         *            - used if it's necessary to create a new connection
     47         * @return workingConnection
     48         * @throws Exception
     49         */
    3150        public static Connection getNewWorkingConnection(Properties env) throws Exception {
    3251                Connection connection = null;
    … …  
    5069        }
    5170
     71        /**
     72         * This function creates a new rabbitmq connection using the properties set
     73         * in env
     74         *
     75         * @param env
     76         *            - Properties needed to create a new connection: username,
     77         *            password, rabbit_host, rabbit_port, enable_ssl (optional)
     78         * @return new Connection
     79         * @throws IOException
     80         * @throws KeyManagementException
     81         * @throws NoSuchAlgorithmException
     82         */
    5283        public static Connection getNewConnection(Properties env) throws IOException, KeyManagementException, NoSuchAlgorithmException {
    5384                // Get login info of rabbitmq
    … …  
    5990                int port = Integer.parseInt(env.getProperty(ParameterQueue.RABBIT_PORT));
    6091
    61                 boolean ssl = Boolean.parseBoolean(env.getProperty(ParameterQueue.ENABLE_SSL));
     92                boolean ssl = Boolean.parseBoolean(env.getProperty(ParameterQueue.ENABLE_SSL, "false"));
    6293
    6394                // Start a new connection and channel
    … …  
    78109        }
    79110
     111        /**
     112         * This method creates a new channel if the singleton pattern is used
     113         *
     114         * @return new Channel
     115         * @throws IOException
     116         */
    80117        public static Channel getNewChannel() throws IOException {
    81118                Channel channel = connection.createChannel();

  • trunk/src/main/java/omq/common/util/ParameterQueue.java

    r77 r83  
    22
    33/**
     4 * This class is used to create new environments.
    45 *
    56 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
    … …  
    78 */
    89public class ParameterQueue {
    9 
    10         /*
    11          * Properties environment
    12          */
    1310
    1411        /**
    … …  
    6966        public static String MESSAGE_TTL_IN_QUEUES = "omq.message_ttl_queue";
    7067
    71         // TODO persistent messages? the messages will be saved in the disk if this
    72         // flag is set true
    73 
    7468        /**
    7569         * Set if the system will use ssl
    … …  
    111105
    112106        /**
    113          * Time in milis
     107         * Time in milis by default is set in a minute
    114108         */
    115109        public static long DEFAULT_TIMEOUT = 1 * 1000 * 60;

  • trunk/src/main/java/omq/common/util/Serializer.java

    r77 r83  
    1515/**
    1616 *
     17 * Serializer enables to serialize the requests and the responses of the
     18 * remoteObjects. This class is used to have the same serializer object a not to
     19 * create new instances every time they are needed.
     20 *
    1721 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
    1822 *
    1923 */
    2024public class Serializer {
    21         // private static final Logger logger =
    22         // Logger.getLogger(Serializer.class.getName());
    2325        public static final String KRYO = "kryo";
    2426        public static final String JAVA = "java";

  • trunk/src/main/java/omq/common/util/Serializers/GsonImp.java

    r75 r83  
    1515import com.google.gson.JsonParser;
    1616
     17/**
     18 * Json serialize implementation. It uses the Gson libraries.
     19 *
     20 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
     21 *
     22 */
    1723public class GsonImp implements ISerializer {
    1824        private final Gson gson = new Gson();

  • trunk/src/main/java/omq/common/util/Serializers/ISerializer.java

    r72 r83  
    77
    88/**
     9 * An ISerializer object can serialize any kind of objects and deserialize
     10 * Requests and Responses.
    911 *
    1012 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
    … …  
    1214 */
    1315public interface ISerializer {
     16        /**
     17         * Serialize
     18         *
     19         * @param obj
     20         *            - object to serialize
     21         * @return objectSerialized
     22         * @throws SerializerException
     23         *             - If the serialization failed
     24         */
    1425        public byte[] serialize(Object obj) throws SerializerException;
    1526
     27        /**
     28         * Deserialize a Request
     29         *
     30         * @param bytes
     31         *            - serialized request
     32         * @param obj
     33         *            - remoteObject which is receiving requests
     34         * @return request
     35         * @throws SerializerException
     36         *             - If the serialization failed
     37         */
    1638        public Request deserializeRequest(byte[] bytes, RemoteObject obj) throws SerializerException;
    1739
     40        /**
     41         * Deserialize a Response
     42         *
     43         * @param bytes
     44         *            serialized response
     45         * @param type
     46         *            - return type expected
     47         * @return response
     48         * @throws SerializerException
     49         *             - If the serialization failed
     50         */
    1851        public Response deserializeResponse(byte[] bytes, Class<?> type) throws SerializerException;
    1952}

  • trunk/src/main/java/omq/common/util/Serializers/JavaImp.java

    r72 r83  
    1212
    1313/**
     14 * Java serialize implementation. It uses the default java serialization.
    1415 *
    1516 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>

  • trunk/src/main/java/omq/common/util/Serializers/KryoImp.java

    r72 r83  
    1313
    1414/**
     15 * Kryo serializerimplementation. It uses the Kryo libraries.
    1516 *
    1617 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>

  • trunk/src/main/java/omq/common/util/Zipper.java

    r44 r83  
    77import java.util.zip.GZIPOutputStream;
    88
     9/**
     10 * This class enables the compression of the information sent through the
     11 * rabbitmq server.
     12 *
     13 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
     14 *
     15 */
    916public class Zipper {
    1017
    … …  
    1623                        zos = new GZIPOutputStream(baos);
    1724                        zos.write(b);
    18                 } finally{
    19                         if(zos != null){
     25                } finally {
     26                        if (zos != null) {
    2027                                zos.close();
    2128                        }
    22                        
     29
    2330                        baos.close();
    2431                }
    25                
     32
    2633                return baos.toByteArray();
    2734        }
    … …  
    3441                try {
    3542                        zis = new GZIPInputStream(bais);
    36                        
     43
    3744                        byte[] tmpBuffer = new byte[256];
    3845                        int n;
    … …  
    4047                                baos.write(tmpBuffer, 0, n);
    4148                        }
    42                 } finally {             
    43                         if(zis != null){
     49                } finally {
     50                        if (zis != null) {
    4451                                zis.close();
    4552                        }
    46                        
     53
    4754                        bais.close();
    4855                        baos.close();
    49                 }               
    50                
     56                }
     57
    5158                return baos.toByteArray();
    52         }       
     59        }
    5360}
Note: See TracChangeset for help on using the changeset viewer.