activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1478549 - in /activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp: AmqpTestSupport.java JMSClientTest.java
Date Thu, 02 May 2013 21:07:41 GMT
Author: chirino
Date: Thu May  2 21:07:41 2013
New Revision: 1478549

URL: http://svn.apache.org/r1478549
Log:
Remove commented out tests.

Modified:
    activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
    activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java

Modified: activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java?rev=1478549&r1=1478548&r2=1478549&view=diff
==============================================================================
--- activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
(original)
+++ activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
Thu May  2 21:07:41 2013
@@ -99,210 +99,4 @@ public class AmqpTestSupport {
         autoFailTestSupport.stopAutoFailThread();
     }
 
-
-
-//    @Test
-//    public void testSendAndReceiveAMQP() throws Exception {
-//        addAMQPConnector(brokerService);
-//        brokerService.start();
-//        AMQP amqp = new AMQP();
-//        final BlockingConnection subscribeConnection = amqp.blockingConnection();
-//        subscribeConnection.connect();
-//        Topic topic = new Topic("foo/bah",QoS.AT_MOST_ONCE);
-//        Topic[] topics = {topic};
-//        subscribeConnection.subscribe(topics);
-//        final CountDownLatch latch = new CountDownLatch(numberOfMessages);
-//
-//        Thread thread = new Thread(new Runnable() {
-//            public void run() {
-//                for (int i = 0; i < numberOfMessages; i++){
-//                    try {
-//                        Message message = subscribeConnection.receive();
-//                        message.ack();
-//                        latch.countDown();
-//                    } catch (Exception e) {
-//                        e.printStackTrace();
-//                        break;
-//                    }
-//
-//                }
-//            }
-//        });
-//        thread.start();
-//
-//        BlockingConnection publisherConnection = amqp.blockingConnection();
-//        publisherConnection.connect();
-//        for (int i = 0; i < numberOfMessages; i++){
-//            String payload = "Message " + i;
-//            publisherConnection.publish(topic.name().toString(),payload.getBytes(),QoS.AT_LEAST_ONCE,false);
-//        }
-//
-//        latch.await(10, TimeUnit.SECONDS);
-//        assertEquals(0, latch.getCount());
-//    }
-//
-//    @Test
-//    public void testSendAndReceiveAtMostOnce() throws Exception {
-//        addAMQPConnector(brokerService);
-//        brokerService.start();
-//        AMQP amqp = createAMQPConnection();
-//        amqp.setKeepAlive(Short.MAX_VALUE);
-//        BlockingConnection connection = amqp.blockingConnection();
-//
-//        connection.connect();
-//
-//
-//        Topic[] topics = {new Topic(utf8("foo"), QoS.AT_MOST_ONCE)};
-//        connection.subscribe(topics);
-//        for (int i = 0; i < numberOfMessages; i++) {
-//            String payload = "Test Message: " + i;
-//            connection.publish("foo", payload.getBytes(), QoS.AT_MOST_ONCE, false);
-//            Message message = connection.receive();
-//            assertEquals(payload, new String(message.getPayload()));
-//        }
-//        connection.disconnect();
-//    }
-//
-//    @Test
-//    public void testSendAndReceiveAtLeastOnce() throws Exception {
-//        addAMQPConnector(brokerService);
-//        brokerService.start();
-//        AMQP amqp = createAMQPConnection();
-//        amqp.setKeepAlive(Short.MAX_VALUE);
-//        BlockingConnection connection = amqp.blockingConnection();
-//
-//        connection.connect();
-//
-//        Topic[] topics = {new Topic(utf8("foo"), QoS.AT_LEAST_ONCE)};
-//        connection.subscribe(topics);
-//        for (int i = 0; i < numberOfMessages; i++) {
-//            String payload = "Test Message: " + i;
-//            connection.publish("foo", payload.getBytes(), QoS.AT_LEAST_ONCE, false);
-//            Message message = connection.receive();
-//            message.ack();
-//            assertEquals(payload, new String(message.getPayload()));
-//        }
-//        connection.disconnect();
-//    }
-//
-//    @Test
-//    public void testSendAndReceiveExactlyOnce() throws Exception {
-//        addAMQPConnector(brokerService);
-//        brokerService.start();
-//        AMQP publisher = createAMQPConnection();
-//        BlockingConnection pubConnection = publisher.blockingConnection();
-//
-//        pubConnection.connect();
-//
-//        AMQP subscriber = createAMQPConnection();
-//        BlockingConnection subConnection = subscriber.blockingConnection();
-//
-//        subConnection.connect();
-//
-//        Topic[] topics = {new Topic(utf8("foo"), QoS.EXACTLY_ONCE)};
-//        subConnection.subscribe(topics);
-//        for (int i = 0; i < numberOfMessages; i++) {
-//            String payload = "Test Message: " + i;
-//            pubConnection.publish("foo", payload.getBytes(), QoS.EXACTLY_ONCE, false);
-//            Message message = subConnection.receive();
-//            message.ack();
-//            assertEquals(payload, new String(message.getPayload()));
-//        }
-//        subConnection.disconnect();
-//        pubConnection.disconnect();
-//    }
-//
-//    @Test
-//    public void testSendAndReceiveLargeMessages() throws Exception {
-//        byte[] payload = new byte[1024 * 32];
-//        for (int i = 0; i < payload.length; i++){
-//            payload[i] = '2';
-//        }
-//        addAMQPConnector(brokerService);
-//        brokerService.start();
-//
-//        AMQP publisher = createAMQPConnection();
-//        BlockingConnection pubConnection = publisher.blockingConnection();
-//
-//        pubConnection.connect();
-//
-//        AMQP subscriber = createAMQPConnection();
-//        BlockingConnection subConnection = subscriber.blockingConnection();
-//
-//        subConnection.connect();
-//
-//        Topic[] topics = {new Topic(utf8("foo"), QoS.AT_LEAST_ONCE)};
-//        subConnection.subscribe(topics);
-//        for (int i = 0; i < 10; i++) {
-//            pubConnection.publish("foo", payload, QoS.AT_LEAST_ONCE, false);
-//            Message message = subConnection.receive();
-//            message.ack();
-//            assertArrayEquals(payload, message.getPayload());
-//        }
-//        subConnection.disconnect();
-//        pubConnection.disconnect();
-//    }
-//
-//
-//    @Test
-//    public void testSendAMQPReceiveJMS() throws Exception {
-//        addAMQPConnector(brokerService);
-//        brokerService.addConnector(ActiveMQConnectionFactory.DEFAULT_BROKER_BIND_URL);
-//        brokerService.start();
-//        AMQP amqp = createAMQPConnection();
-//        BlockingConnection connection = amqp.blockingConnection();
-//        final String DESTINATION_NAME = "foo.*";
-//        connection.connect();
-//
-//        ActiveMQConnection activeMQConnection = (ActiveMQConnection) new ActiveMQConnectionFactory().createConnection();
-//        activeMQConnection.start();
-//        Session s = activeMQConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-//        javax.jms.Topic jmsTopic = s.createTopic(DESTINATION_NAME);
-//        MessageConsumer consumer = s.createConsumer(jmsTopic);
-//
-//        for (int i = 0; i < numberOfMessages; i++) {
-//            String payload = "Test Message: " + i;
-//            connection.publish("foo/bah", payload.getBytes(), QoS.AT_LEAST_ONCE, false);
-//            ActiveMQMessage message = (ActiveMQMessage) consumer.receive();
-//            ByteSequence bs = message.getContent();
-//            assertEquals(payload, new String(bs.data, bs.offset, bs.length));
-//        }
-//
-//
-//        activeMQConnection.close();
-//        connection.disconnect();
-//    }
-//
-//    @Test
-//    public void testSendJMSReceiveAMQP() throws Exception {
-//        addAMQPConnector(brokerService);
-//        brokerService.addConnector(ActiveMQConnectionFactory.DEFAULT_BROKER_BIND_URL);
-//        brokerService.start();
-//        AMQP amqp = createAMQPConnection();
-//        amqp.setKeepAlive(Short.MAX_VALUE);
-//        BlockingConnection connection = amqp.blockingConnection();
-//        connection.connect();
-//
-//        ActiveMQConnection activeMQConnection = (ActiveMQConnection) new ActiveMQConnectionFactory().createConnection();
-//        activeMQConnection.start();
-//        Session s = activeMQConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-//        javax.jms.Topic jmsTopic = s.createTopic("foo.far");
-//        MessageProducer producer = s.createProducer(jmsTopic);
-//
-//        Topic[] topics = {new Topic(utf8("foo/+"), QoS.AT_MOST_ONCE)};
-//        connection.subscribe(topics);
-//        for (int i = 0; i < numberOfMessages; i++) {
-//            String payload = "This is Test Message: " + i;
-//            TextMessage sendMessage = s.createTextMessage(payload);
-//            producer.send(sendMessage);
-//            Message message = connection.receive();
-//            message.ack();
-//            assertEquals(payload, new String(message.getPayload()));
-//        }
-//        connection.disconnect();
-//    }
-//
-//
-
-
 }
\ No newline at end of file

Modified: activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java?rev=1478549&r1=1478548&r2=1478549&view=diff
==============================================================================
--- activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
(original)
+++ activemq/trunk/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
Thu May  2 21:07:41 2013
@@ -64,77 +64,6 @@ public class JMSClientTest extends AmqpT
 
     }
 
-//    @Test
-//    public void testSendReceive() throws Exception {
-//        ActiveMQAdmin.enableJMSFrameTracing();
-//        QueueImpl queue = new QueueImpl("queue://testqueue");
-//        int nMsgs = 1;
-//        final String dataFormat = "%01024d";
-//
-//
-//        try {
-//            Connection connection = createConnection();
-//            {
-//                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-//                MessageProducer p = session.createProducer(queue);
-//                for (int i = 0; i < nMsgs; i++) {
-//                    System.out.println("Sending " + i);
-//                    p.send(session.createTextMessage(String.format(dataFormat, i)));
-//                }
-//            }
-//            connection.close();
-//
-//            System.out.println("=======================================================================================");
-//            System.out.println(" failing a receive ");
-//            System.out.println("=======================================================================================");
-//            connection = createConnection();
-//            {
-//                Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE);
-//                MessageConsumer c = session.createConsumer(queue);
-//
-//                // Receive messages non-transacted
-//                int i = 0;
-//                while ( i < 1) {
-//                    TextMessage msg = (TextMessage) c.receive();
-//                    if( msg!=null ) {
-//                        String s = msg.getText();
-//                        assertEquals(String.format(dataFormat, i), s);
-//                        System.out.println("Received: " + i);
-//                        i++;
-//                    }
-//                }
-//            }
-//            connection.close();
-//
-//
-//            System.out.println("=======================================================================================");
-//            System.out.println(" receiving ");
-//            System.out.println("=======================================================================================");
-//            connection = createConnection();
-//            {
-//                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-//                MessageConsumer c = session.createConsumer(queue);
-//
-//                // Receive messages non-transacted
-//                int i = 0;
-//                while ( i < nMsgs) {
-//                    TextMessage msg = (TextMessage) c.receive();
-//                    if( msg!=null ) {
-//                        String s = msg.getText();
-//                        assertEquals(String.format(dataFormat, i), s);
-//                        System.out.println("Received: " + i);
-//                        i++;
-//                    }
-//                }
-//            }
-//            connection.close();
-//
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//        }
-//
-//    }
-
     private Connection createConnection() throws JMSException {
         final ConnectionFactoryImpl factory = new ConnectionFactoryImpl("localhost", port,
"admin", "password");
         final Connection connection = factory.createConnection();



Mime
View raw message