You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2018/10/31 23:11:48 UTC
[pulsar] branch master updated: Use unique test names in
PartitionedProducerConsumerTest to avoid individual tests
inter-dependencies (#2867)
This is an automated email from the ASF dual-hosted git repository.
mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new c1baa74 Use unique test names in PartitionedProducerConsumerTest to avoid individual tests inter-dependencies (#2867)
c1baa74 is described below
commit c1baa74ea56480a54d192486677f0f861ad297f1
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Wed Oct 31 16:11:44 2018 -0700
Use unique test names in PartitionedProducerConsumerTest to avoid individual tests inter-dependencies (#2867)
---
.../api/PartitionedProducerConsumerTest.java | 27 ++++++++++++++--------
1 file changed, 17 insertions(+), 10 deletions(-)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java
index ae7757d..c7f1a6d 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PartitionedProducerConsumerTest.java
@@ -68,7 +68,7 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
log.info("-- Starting {} test --", methodName);
int numPartitions = 4;
- TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic1");
+ TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic1-" + System.currentTimeMillis());
admin.topics().createPartitionedTopic(topicName.toString(), numPartitions);
@@ -110,7 +110,7 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
int numPartitions = 4;
final String specialCharacter = "! * ' ( ) ; : @ & = + $ , \\ ? % # [ ]";
TopicName topicName = TopicName
- .get("persistent://my-property/my-ns/my-partitionedtopic1" + specialCharacter);
+ .get("persistent://my-property/my-ns/my-partitionedtopic1-" + System.currentTimeMillis() + specialCharacter);
admin.topics().createPartitionedTopic(topicName.toString(), numPartitions);
// Try to create producer which does lookup and create connection with broker
@@ -126,7 +126,8 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
log.info("-- Starting {} test --", methodName);
int numPartitions = 4;
- TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic2");
+ TopicName topicName = TopicName
+ .get("persistent://my-property/my-ns/my-partitionedtopic2-" + System.currentTimeMillis());
admin.topics().createPartitionedTopic(topicName.toString(), numPartitions);
@@ -167,7 +168,8 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
log.info("-- Starting {} test --", methodName);
int numPartitions = 4;
- TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic3");
+ TopicName topicName = TopicName
+ .get("persistent://my-property/my-ns/my-partitionedtopic3-" + System.currentTimeMillis());
String dummyKey1 = "dummykey1";
String dummyKey2 = "dummykey2";
@@ -219,7 +221,8 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
log.info("-- Starting {} test --", methodName);
int numPartitions = 4;
- TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic4");
+ TopicName topicName = TopicName
+ .get("persistent://my-property/my-ns/my-partitionedtopic4-" + System.currentTimeMillis());
admin.topics().createPartitionedTopic(topicName.toString(), numPartitions);
Consumer<byte[]> consumer = pulsarClient.newConsumer().topic(topicName.toString())
@@ -269,7 +272,8 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
public void testSillyUser() throws Exception {
int numPartitions = 4;
- TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic5");
+ TopicName topicName = TopicName
+ .get("persistent://my-property/my-ns/my-partitionedtopic5-" + System.currentTimeMillis());
admin.topics().createPartitionedTopic(topicName.toString(), numPartitions);
Producer<byte[]> producer = null;
@@ -311,7 +315,8 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
@Test(timeOut = 30000)
public void testDeletePartitionedTopic() throws Exception {
int numPartitions = 4;
- TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic6");
+ TopicName topicName = TopicName
+ .get("persistent://my-property/my-ns/my-partitionedtopic6-" + System.currentTimeMillis());
admin.topics().createPartitionedTopic(topicName.toString(), numPartitions);
Producer<byte[]> producer = pulsarClient.newProducer().topic(topicName.toString()).create();
@@ -338,7 +343,8 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
final Set<String> consumeMsgs = Sets.newHashSet();
int numPartitions = 4;
- TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic1");
+ TopicName topicName = TopicName
+ .get("persistent://my-property/my-ns/my-partitionedtopic1-" + System.currentTimeMillis());
admin.topics().createPartitionedTopic(topicName.toString(), numPartitions);
Producer<byte[]> producer = pulsarClient.newProducer().topic(topicName.toString())
@@ -386,7 +392,8 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
final Set<String> consumeMsgs = Sets.newHashSet();
int numPartitions = 4;
- TopicName topicName = TopicName.get("persistent://my-property/my-ns/my-partitionedtopic1");
+ TopicName topicName = TopicName
+ .get("persistent://my-property/my-ns/my-partitionedtopic1-" + System.currentTimeMillis());
admin.topics().createPartitionedTopic(topicName.toString(), numPartitions);
@@ -436,7 +443,7 @@ public class PartitionedProducerConsumerTest extends ProducerConsumerBase {
log.info("-- Starting {} test --", methodName);
final int numPartitions = 2;
- final String topicName = "persistent://my-property/my-ns/my-topic";
+ final String topicName = "persistent://my-property/my-ns/my-topic-" + System.currentTimeMillis();
final String producer1Msg = "producer1";
final String producer2Msg = "producer2";
final int queueSize = 10;