activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kea...@apache.org
Subject git commit: Test to reproduce AMQ-4914 with the failing part @Ignored for now
Date Mon, 02 Dec 2013 16:52:41 GMT
Updated Branches:
  refs/heads/trunk b9f0783af -> cfeea7797


Test to reproduce AMQ-4914 with the failing part @Ignored for now


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/cfeea779
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/cfeea779
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/cfeea779

Branch: refs/heads/trunk
Commit: cfeea7797d9f3cbd5c0685f39d8b2a9cef77d8bb
Parents: b9f0783
Author: Kevin Earls <kevin@kevinearls.com>
Authored: Mon Dec 2 17:52:30 2013 +0100
Committer: Kevin Earls <kevin@kevinearls.com>
Committed: Mon Dec 2 17:52:30 2013 +0100

----------------------------------------------------------------------
 .../transport/amqp/bugs/AMQ4914Test.java        | 119 +++++++++++++++++++
 1 file changed, 119 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/cfeea779/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/bugs/AMQ4914Test.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/bugs/AMQ4914Test.java
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/bugs/AMQ4914Test.java
new file mode 100644
index 0000000..1dde725
--- /dev/null
+++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/bugs/AMQ4914Test.java
@@ -0,0 +1,119 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.transport.amqp.bugs;
+
+import org.apache.activemq.transport.amqp.AmqpTestSupport;
+import org.apache.qpid.amqp_1_0.jms.impl.ConnectionFactoryImpl;
+import org.apache.qpid.amqp_1_0.jms.impl.QueueImpl;
+import org.junit.Ignore;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.TestName;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.jms.Connection;
+import javax.jms.ExceptionListener;
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+
+import static org.junit.Assert.*;
+
+public class AMQ4914Test extends AmqpTestSupport {
+    @Rule
+    public TestName testName = new TestName();
+
+    protected static final Logger LOG = LoggerFactory.getLogger(AMQ4914Test.class);
+    private final static String QUEUE_NAME="queue://ENTMQ476TestQueue";
+
+    /**
+     *
+     * @param sizeInBytes
+     * @return
+     */
+    private String createLargeString(int sizeInBytes) {
+        byte[] base = {1, 2, 3, 4, 5, 6, 7, 8, 9, 0};
+        StringBuilder builder = new StringBuilder();
+        for (int i = 0; i < sizeInBytes; i++) {
+            builder.append(base[i % base.length]);
+        }
+
+        LOG.debug("Created string with size : " + builder.toString().getBytes().length +
" bytes");
+        return builder.toString();
+    }
+
+    @Test(timeout = 2 * 60 * 1000)
+    public void testSendSmallerMessages() throws JMSException {
+        for (int i = 512; i <= (16 * 1024); i += 512) {
+            doTestSendLargeMessage(i);
+        }
+    }
+
+    @Ignore("AMQ-4914")
+    @Test(timeout = 2 * 60 * 1000)
+    public void testSendLargeMessages() throws JMSException {
+        //for (int i = 32000; i < (32 *1024); i++) {
+            doTestSendLargeMessage(32604);       // Fails at 32614; or 32604 with my changes
to AmqpProtocolBuffer
+        //}
+    }
+
+    public void doTestSendLargeMessage(int expectedSize) throws JMSException{
+        LOG.info("doTestSendLargeMessage called with expectedSize " + expectedSize);
+        String payload = createLargeString(expectedSize);
+        assertEquals(expectedSize, payload.getBytes().length);
+
+        Connection connection = createAMQPConnection(port, false);
+
+        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        QueueImpl queue = new QueueImpl(QUEUE_NAME);
+        MessageProducer producer = session.createProducer(queue);
+        TextMessage message = session.createTextMessage();
+        message.setText(payload);
+        producer.send(message);
+        LOG.debug("Returned from send");
+
+        MessageConsumer consumer = session.createConsumer(queue);
+        connection.start();
+        LOG.debug("Calling receive");
+        Message receivedMessage = consumer.receive();
+        assertNotNull(receivedMessage);
+        assertTrue(receivedMessage instanceof TextMessage);
+        TextMessage receivedTextMessage = (TextMessage) receivedMessage;
+        String receivedText = receivedTextMessage.getText();
+        assertEquals(expectedSize, receivedText.getBytes().length);
+        assertEquals(payload, receivedText);
+        connection.close();
+    }
+
+    private Connection createAMQPConnection(int testPort, boolean useSSL) throws JMSException
{
+        LOG.debug("In createConnection using port {} ssl? {}", testPort, useSSL);
+        final ConnectionFactoryImpl connectionFactory = new ConnectionFactoryImpl("localhost",
testPort, "admin", "password", null, useSSL);
+        final Connection connection = connectionFactory.createConnection();
+        connection.setExceptionListener(new ExceptionListener() {
+            @Override
+            public void onException(JMSException exception) {
+                exception.printStackTrace();
+            }
+        });
+        connection.start();
+        return connection;
+    }
+}


Mime
View raw message