You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cs...@apache.org on 2019/07/03 10:38:30 UTC
[sling-org-apache-sling-distribution-journal-kafka] 02/02:
SLING-8554 - Add second message to test while loop in poller
This is an automated email from the ASF dual-hosted git repository.
cschneider pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-journal-kafka.git
commit 91c62a795783d53cb80ebb2653e7725c28b010dc
Author: Christian Schneider <cs...@adobe.com>
AuthorDate: Wed Jul 3 12:38:18 2019 +0200
SLING-8554 - Add second message to test while loop in poller
---
.../distribution/journal/kafka/MessagingTest.java | 35 ++++++++++------------
1 file changed, 16 insertions(+), 19 deletions(-)
diff --git a/src/test/java/org/apache/sling/distribution/journal/kafka/MessagingTest.java b/src/test/java/org/apache/sling/distribution/journal/kafka/MessagingTest.java
index 431f692..ae28d4c 100644
--- a/src/test/java/org/apache/sling/distribution/journal/kafka/MessagingTest.java
+++ b/src/test/java/org/apache/sling/distribution/journal/kafka/MessagingTest.java
@@ -62,34 +62,19 @@ public class MessagingTest {
public void testSendReceive() throws Exception {
HandlerAdapter<DiscoveryMessage> handler = HandlerAdapter.create(DiscoveryMessage.class, this::handle);
Closeable poller = provider.createPoller(topicName, Reset.earliest, handler);
- DiscoveryMessage msg = DiscoveryMessage.newBuilder()
- .setSubAgentName("sub1agent")
- .setSubSlingId("subsling")
- .setSubscriberConfiguration(SubscriberConfiguration
- .newBuilder()
- .setEditable(false)
- .setMaxRetries(-1)
- .build())
- .build();
MessageSender<DiscoveryMessage> messageSender = provider.createSender();
- messageSender.send(topicName, msg);
+ messageSender.send(topicName, createMessage());
assertReceived("Consumer started from earliest .. should see our message");
+ messageSender.send(topicName, createMessage());
+ assertReceived("Should also consume a second message");
poller.close();
}
@Test
public void testAssign() throws Exception {
- DiscoveryMessage msg = DiscoveryMessage.newBuilder()
- .setSubAgentName("sub1agent")
- .setSubSlingId("subsling")
- .setSubscriberConfiguration(SubscriberConfiguration
- .newBuilder()
- .setEditable(false)
- .setMaxRetries(-1)
- .build())
- .build();
+ DiscoveryMessage msg = createMessage();
MessageSender<DiscoveryMessage> messageSender = provider.createSender();
messageSender.send(topicName, msg);
@@ -116,6 +101,18 @@ public class MessagingTest {
}
}
+ private DiscoveryMessage createMessage() {
+ return DiscoveryMessage.newBuilder()
+ .setSubAgentName("sub1agent")
+ .setSubSlingId("subsling")
+ .setSubscriberConfiguration(SubscriberConfiguration
+ .newBuilder()
+ .setEditable(false)
+ .setMaxRetries(-1)
+ .build())
+ .build();
+ }
+
private void assertReceived(String message) throws InterruptedException {
assertTrue(message, sem.tryAcquire(30, TimeUnit.SECONDS));
}