activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject [1/7] activemq git commit: https://issues.apache.org/jira/browse/AMQ-5617
Date Thu, 26 Feb 2015 21:20:36 GMT
Repository: activemq
Updated Branches:
  refs/heads/master 79568f16c -> eaf773da5


https://issues.apache.org/jira/browse/AMQ-5617

Remove this older test as the test in JMSClientTest ->
testProduceConsumer covers this accross all four transport variants.

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

Branch: refs/heads/master
Commit: 7a8085c0a49c0cac865ea4a6a91777c49790664d
Parents: 79568f1
Author: Timothy Bish <tabish121@gmail.com>
Authored: Thu Feb 26 14:35:51 2015 -0500
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Thu Feb 26 14:35:51 2015 -0500

----------------------------------------------------------------------
 .../transport/amqp/bugs/AMQ4753Test.java        | 73 --------------------
 1 file changed, 73 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/7a8085c0/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/bugs/AMQ4753Test.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/bugs/AMQ4753Test.java
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/bugs/AMQ4753Test.java
deleted file mode 100644
index 4258039..0000000
--- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/bugs/AMQ4753Test.java
+++ /dev/null
@@ -1,73 +0,0 @@
-/**
- * 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 static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-
-import javax.jms.Connection;
-import javax.jms.JMSException;
-import javax.jms.Message;
-import javax.jms.MessageConsumer;
-import javax.jms.MessageProducer;
-import javax.jms.Queue;
-import javax.jms.Session;
-import javax.jms.TextMessage;
-
-import org.apache.activemq.transport.amqp.AmqpTestSupport;
-import org.apache.activemq.transport.amqp.JmsClientContext;
-import org.junit.Test;
-
-public class AMQ4753Test extends AmqpTestSupport {
-
-    @Override
-    protected boolean isUseTcpConnector() {
-        return false;
-    }
-
-    @Override
-    protected boolean isUseNioPlusSslConnector() {
-        return true;
-    }
-
-    @Test(timeout = 120 * 1000)
-    public void testAmqpNioPlusSslSendReceive() throws JMSException {
-        Connection connection = JmsClientContext.INSTANCE.createConnection(amqpNioPlusSslURI);
-        runSimpleSendReceiveTest(connection);
-    }
-
-    public void runSimpleSendReceiveTest(Connection connection) throws JMSException{
-        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-        Queue queue =session.createQueue("txqueue");
-        MessageProducer producer = session.createProducer(queue);
-        TextMessage message = session.createTextMessage();
-        String messageText = "hello  sent at " + new java.util.Date().toString();
-        message.setText(messageText);
-        producer.send(message);
-
-        // Get the message we just sent
-        MessageConsumer consumer = session.createConsumer(queue);
-        connection.start();
-        Message receivedMessage = consumer.receive(5000);
-        assertNotNull(receivedMessage);
-        assertTrue(receivedMessage instanceof TextMessage);
-        TextMessage textMessage = (TextMessage) receivedMessage;
-        assertEquals(messageText, textMessage.getText());
-        connection.close();
-    }
-}


Mime
View raw message