Changeset 77 for trunk/src/test


Ignore:
Timestamp:
07/04/13 16:45:14 (11 years ago)
Author:
stoda
Message:

ParameterQueues? changed, added some properties to modify the queues

Location:
trunk/src/test/java/omq/test
Files:
1 deleted
11 edited

Legend:

Unmodified
Added
Removed

  • trunk/src/test/java/omq/test/calculator/CalculatorTest.java

    r73 r77  
    3131
    3232                // Set host info of rabbimq (where it is)
    33                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    34                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     33                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     34                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    3535                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    36                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    37                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     36                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     37                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3838
    3939                // Set info about where the message will be sent
    … …  
    6262
    6363                // Get host info of rabbimq (where it is)
    64                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    65                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     64                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     65                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    6666                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    67                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     67                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    6868
    6969                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/event/MessageTest.java

    r73 r77  
    3333
    3434                // Set host info of rabbimq (where it is)
    35                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    36                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     35                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     36                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    3737                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    38                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    39                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     38                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     39                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    4040
    4141                // Set info about where the message will be sent
    … …  
    6363
    6464                // Get host info of rabbimq (where it is)
    65                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    66                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     65                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     66                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    6767                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    68                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     68                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    6969
    7070                // Set info about where the message will be sent
    … …  
    8989        public void test() throws Exception {
    9090                String expected = "Hello";
    91 
    9291                serverProxy.setMessage(expected);
    9392                Thread.sleep(200);

  • trunk/src/test/java/omq/test/exception/ExceptionTest.java

    r73 r77  
    3030
    3131                // Set host info of rabbimq (where it is)
    32                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    33                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     32                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     33                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    3434                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    35                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    36                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     35                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     36                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3737
    3838                // Set info about where the message will be sent
    … …  
    6060
    6161                // Get host info of rabbimq (where it is)
    62                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    63                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     62                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     63                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    6464                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    65                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     65                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    6666
    6767                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/faultTolerance/FaultToleranceTest.java

    r73 r77  
    3131
    3232                // Set host info of rabbimq (where it is)
    33                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    34                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     33                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     34                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    3535                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    36                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    37                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     36                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     37                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3838
    3939                // Set info about where the message will be sent
    … …  
    6868
    6969                // Get host info of rabbimq (where it is)
    70                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    71                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     70                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     71                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    7272                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    73                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     73                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7474
    7575                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java

    r73 r77  
    2929
    3030                // Set host info of rabbimq (where it is)
    31                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    32                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     31                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     32                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    3333                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    34                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    35                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     34                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     35                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3636
    3737                // Set info about where the message will be sent
    … …  
    5959
    6060                // Get host info of rabbimq (where it is)
    61                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    62                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     61                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     62                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    6363                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    64                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     64                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    6565
    6666                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/observer/ObserverTest.java

    r73 r77  
    3232
    3333                // Set host info of rabbimq (where it is)
    34                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    35                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     34                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     35                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    3636                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    37                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    38                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     37                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     38                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3939
    4040                // Set info about where the message will be sent
    … …  
    6262
    6363                // Get host info of rabbimq (where it is)
    64                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    65                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     64                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     65                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    6666                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    67                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     67                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    6868
    6969                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/serializer/CalculatorTest.java

    r73 r77  
    2424
    2525                // Set host info of rabbimq (where it is)
    26                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    27                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     26                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     27                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    2828                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    29                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     29                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3030
    3131                // Set info about where the message will be sent
    … …  
    4848
    4949                // Get host info of rabbimq (where it is)
    50                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    51                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     50                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     51                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    5252                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    53                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     53                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    5454
    5555                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/stopBroker/StopBrokerTest.java

    r73 r77  
    2828
    2929                // Set host info of rabbimq (where it is)
    30                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    31                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     30                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     31                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    3232                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    33                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    34                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     33                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     34                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3535
    3636                // Set info about where the message will be sent
    … …  
    6060
    6161                // Get host info of rabbimq (where it is)
    62                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    63                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     62                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     63                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    6464                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    65                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     65                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    6666
    6767                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/stopBroker/UnbindTest.java

    r54 r77  
    1818
    1919                // Get host info of rabbimq (where it is)
    20                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    21                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     20                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     21                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    2222                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    23                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     23                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    2424
    2525                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/temporal/ProvaTest.java

    r73 r77  
    3030
    3131                // Get host info of rabbimq (where it is)
    32                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    33                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     32                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     33                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    3434                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    35                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     35                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3636
    3737                // Set info about where the message will be sent
    … …  
    5656
    5757                // Set host info of rabbimq (where it is)
    58                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    59                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     58                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     59                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    6060                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    61                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    62                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     61                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     62                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    6363
    6464                // Set info about where the message will be sent

  • trunk/src/test/java/omq/test/workspace/WorkspaceTest.java

    r75 r77  
    3939
    4040                // Set host info of rabbimq (where it is)
    41                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    42                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     41                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     42                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    4343                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    44                 env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    45                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     44                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
     45                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    4646
    4747                // Set info about where the message will be sent
    … …  
    6969
    7070                // Get host info of rabbimq (where it is)
    71                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    72                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     71                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
     72                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    7373                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    74                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     74                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7575
    7676                // Set info about where the message will be sent
Note: See TracChangeset for help on using the changeset viewer.