Changeset 84 for trunk/src/test/java/omq


Ignore:
Timestamp:
07/10/13 13:14:30 (11 years ago)
Author:
stoda
Message:

Default queues added, default exchange enabled, more control in remote queues added.
Tests verified and changed Persistent test to show how to make persistent messages.

Location:
trunk/src/test/java/omq/test
Files:
13 edited

Legend:

Unmodified
Added
Removed

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

    r83 r84  
    3838                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    3939                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    40                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     40                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    4141                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    4242                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    … …  
    6969                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    7070                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    71                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     71                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    7272                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7373

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

    r83 r84  
    4040                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    4141                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    42                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     42                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    4343                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    4444                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    … …  
    7070                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    7171                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    72                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     72                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    7373                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7474

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

    r83 r84  
    3737                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    3838                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    39                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     39                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    4040                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    4141                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    … …  
    6767                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    6868                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    69                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     69                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    7070                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7171

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

    r83 r84  
    3838                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    3939                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    40                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     40                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    4141                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    4242                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    … …  
    7575                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    7676                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    77                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     77                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    7878                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7979

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

    r83 r84  
    3636                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    3737                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    38                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     38                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    3939                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    4040                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    … …  
    6666                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    6767                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    68                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     68                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    6969                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7070

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

    r83 r84  
    3939                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    4040                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    41                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     41                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    4242                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    4343                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    … …  
    6969                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    7070                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    71                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     71                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    7272                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7373

  • trunk/src/test/java/omq/test/persistence/PersistentTest.java

    r83 r84  
    4848                msgImplProps = new Properties();
    4949                msgImplProps.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
    50                 msgImplProps.setProperty(ParameterQueue.DURABLE_QUEUES, "true");
     50                msgImplProps.setProperty(ParameterQueue.DURABLE_QUEUE, "true");
    5151                msgImplProps.setProperty(ParameterQueue.EXCLUSIVE_QUEUE, "false");
    5252                msgImplProps.setProperty(ParameterQueue.AUTO_DELETE_QUEUE, "false");
    5353                msgImplProps.setProperty(ParameterQueue.MULTI_QUEUE_NAME, "multiMessageQueue");
     54                msgImplProps.setProperty(ParameterQueue.DURABLE_MQUEUE, "true");
     55                msgImplProps.setProperty(ParameterQueue.EXCLUSIVE_MQUEUE, "true");
     56                msgImplProps.setProperty(ParameterQueue.AUTO_DELETE_MQUEUE, "false");
    5457                msgImplProps.setProperty(ParameterQueue.DELIVERY_MODE, "1");
     58                msgImplProps.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
    5559
    5660                /*
    … …  
    6569                clientProps.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    6670                clientProps.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    67                 clientProps.setProperty(ParameterQueue.DURABLE_QUEUES, "true");
     71                clientProps.setProperty(ParameterQueue.DURABLE_QUEUE, "true");
    6872                clientProps.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    6973                clientProps.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
    7074                clientProps.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "persistent_message_reply_queue");
     75                clientProps.setProperty(ParameterQueue.DURABLE_QUEUE, "true");
     76                clientProps.setProperty(ParameterQueue.EXCLUSIVE_QUEUE, "true");
     77                clientProps.setProperty(ParameterQueue.AUTO_DELETE_QUEUE, "false");
    7178                clientProps.setProperty(ParameterQueue.DELIVERY_MODE, "2");
     79                clientProps.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
    7280                // TODO msgProps -> rpc_exchange, serializer type and delivery mode
    7381        }

  • trunk/src/test/java/omq/test/python/Server.java

    r83 r84  
    2424                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    2525                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    26                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     26                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    2727                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    2828

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

    r83 r84  
    3131                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    3232                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    33                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     33                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    3434                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    3535
    … …  
    5555                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    5656                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    57                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     57                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    5858                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    5959

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

    r83 r84  
    3535                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    3636                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    37                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     37                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    3838                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    3939                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    … …  
    6767                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    6868                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    69                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     69                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    7070                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    7171

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

    r83 r84  
    2525                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    2626                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    27                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     27                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    2828                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    2929

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

    r83 r84  
    3737                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    3838                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    39                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     39                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    4040                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    4141
    … …  
    6363                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    6464                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    65                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     65                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    6666                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    6767                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");

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

    r83 r84  
    4646                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    4747                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    48                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     48                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    4949                env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
    5050                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    … …  
    7676                env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
    7777                env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
    78                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     78                env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
    7979                env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
    8080
Note: See TracChangeset for help on using the changeset viewer.