Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NO-JIRA Add forgotten @Test annotation and make helper methods private

This commit is contained in:
Jiri Danek 2018-07-14 23:52:02 +02:00 committed by Justin Bertram
parent 94c158ebee
commit 56c7fb1a95
4 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
artemis-protocols/artemis-amqp-protocol/src/test/java/org/apache/activemq/artemis/protocol/amqp/converter/message/JMSMappingInboundTransformerTest.java
View File

@ -150,6 +150,7 @@ public class JMSMappingInboundTransformerTest {
* @throws Exception
* if an error occurs during the test.
*/
@Test
public void testCreateBytesMessageFromDataWithUnknownContentType() throws Exception {
MessageImpl message = (MessageImpl) Message.Factory.create();
Binary binary = new Binary(new byte[0]);

8
artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/ClientAckQueueTest.java
View File

@ -52,7 +52,7 @@ public class ClientAckQueueTest extends MessageTestBase {
testAckTimeout();
}
public void testAckTimeout() throws Exception {
private void testAckTimeout() throws Exception {
ClientRequest request = new ClientRequest(generateURL("/queues/testAck"));
ClientResponse<?> response = Util.head(request);
@ -127,7 +127,7 @@ public class ClientAckQueueTest extends MessageTestBase {
testSuccessFirst(3, testName);
}
public void testSuccessFirst(int start, String queueName) throws Exception {
private void testSuccessFirst(int start, String queueName) throws Exception {
ClientRequest request = new ClientRequest(generateURL(Util.getUrlPath(queueName)));
ClientResponse<?> response = Util.head(request);
@ -205,7 +205,7 @@ public class ClientAckQueueTest extends MessageTestBase {
testPull(4, testName);
}
public void testPull(int start, String queueName) throws Exception {
private void testPull(int start, String queueName) throws Exception {
ClientRequest request = new ClientRequest(generateURL(Util.getUrlPath(queueName)));
ClientResponse<?> response = Util.head(request);
@ -287,7 +287,7 @@ public class ClientAckQueueTest extends MessageTestBase {
testReconnect(testName);
}
public void testReconnect(String queueName) throws Exception {
private void testReconnect(String queueName) throws Exception {
ClientRequest request = new ClientRequest(generateURL(Util.getUrlPath(queueName)));
ClientResponse<?> response = Util.head(request);

2
artemis-rest/src/test/java/org/apache/activemq/artemis/rest/test/ClientAckTopicTest.java
View File

@ -51,7 +51,7 @@ public class ClientAckTopicTest extends MessageTestBase {
testAckTimeout();
}
public void testAckTimeout() throws Exception {
private void testAckTimeout() throws Exception {
ClientRequest request = new ClientRequest(TestPortProvider.generateURL("/topics/testAck"));

5
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/cluster/distribution/SimpleSymmetricClusterTest.java
View File

@ -18,6 +18,7 @@ package org.apache.activemq.artemis.tests.integration.cluster.distribution;
import org.apache.activemq.artemis.core.server.cluster.impl.MessageLoadBalancingType;
import org.apache.activemq.artemis.tests.integration.IntegrationTestLogger;
import org.junit.Ignore;
import org.junit.Test;
public class SimpleSymmetricClusterTest extends ClusterTestBase {
@ -282,7 +283,9 @@ public class SimpleSymmetricClusterTest extends ClusterTestBase {
verifyReceiveRoundRobinInSomeOrder(33, 2, 0, 1);
}
public void _testSimpleRoundRobbinNoFailure() throws Exception {
@Test
@Ignore("Test not implemented yet")
public void testSimpleRoundRobbinNoFailure() throws Exception {
//TODO make this test to crash a node
setupServer(0, true, isNetty());
setupServer(1, true, isNetty());