[pulsar-client-reactive] branch main updated: Add test for MessageResult (#63)

[lh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git


The following commit(s) were added to refs/heads/main by this push:
     new 18bb4bc  Add test for MessageResult (#63)
18bb4bc is described below

commit 18bb4bc840f07db3c3bfdcdcb8e84d5e1caceed3
Author: Christophe Bornet <cb...@hotmail.com>
AuthorDate: Thu Dec 1 08:54:08 2022 +0100

    Add test for MessageResult (#63)
---
 .../reactive/client/api/MessageResultTest.java     | 255 +++++++++++++++++++++
 1 file changed, 255 insertions(+)

diff --git a/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageResultTest.java b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageResultTest.java
new file mode 100644
index 0000000..018955f
--- /dev/null
+++ b/pulsar-client-reactive-api/src/test/java/org/apache/pulsar/reactive/client/api/MessageResultTest.java
@@ -0,0 +1,255 @@
+/*
+ * Copyright 2022 the original author or authors.
+ *
+ * Licensed 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
+ *
+ *      https://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.pulsar.reactive.client.api;
+
+import java.util.Map;
+import java.util.Optional;
+
+import org.apache.pulsar.client.api.Message;
+import org.apache.pulsar.client.api.MessageId;
+import org.apache.pulsar.common.api.EncryptionContext;
+import org.junit.jupiter.api.Test;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+/**
+ * Tests for {@link MessageResult}.
+ *
+ * @author Christophe Bornet
+ */
+class MessageResultTest {
+
+	private static final MessageId MESSAGE_ID = new TestMessageId();
+
+	@Test
+	void acknowledge() {
+		MessageResult<String> result = MessageResult.acknowledge(MESSAGE_ID, "value");
+		assertThat(result.getValue()).isEqualTo("value");
+		assertThat(result.getMessageId()).isEqualTo(MESSAGE_ID);
+		assertThat(result.isAcknowledgeMessage()).isTrue();
+	}
+
+	@Test
+	void negativeAcknowledge() {
+		MessageResult<String> result = MessageResult.negativeAcknowledge(MESSAGE_ID, "value");
+		assertThat(result.getValue()).isEqualTo("value");
+		assertThat(result.getMessageId()).isEqualTo(MESSAGE_ID);
+		assertThat(result.isAcknowledgeMessage()).isFalse();
+	}
+
+	@Test
+	void acknowledgeEmptyValue() {
+		MessageResult<Void> result = MessageResult.acknowledge(MESSAGE_ID);
+		assertThat(result.getValue()).isNull();
+		assertThat(result.getMessageId()).isEqualTo(MESSAGE_ID);
+		assertThat(result.isAcknowledgeMessage()).isTrue();
+	}
+
+	@Test
+	void negativeAcknowledgeEmptyValue() {
+		MessageResult<Void> result = MessageResult.negativeAcknowledge(MESSAGE_ID);
+		assertThat(result.getValue()).isNull();
+		assertThat(result.getMessageId()).isEqualTo(MESSAGE_ID);
+		assertThat(result.isAcknowledgeMessage()).isFalse();
+	}
+
+	@Test
+	void acknowledgeByMessage() {
+		Message<String> message = new TestMessage();
+		MessageResult<Void> result = MessageResult.acknowledge(message);
+		assertThat(result.getValue()).isNull();
+		assertThat(result.getMessageId()).isEqualTo(MESSAGE_ID);
+		assertThat(result.isAcknowledgeMessage()).isTrue();
+	}
+
+	@Test
+	void negativeAcknowledgeByMessage() {
+		Message<String> message = new TestMessage();
+		MessageResult<Void> result = MessageResult.negativeAcknowledge(message);
+		assertThat(result.getValue()).isNull();
+		assertThat(result.getMessageId()).isEqualTo(MESSAGE_ID);
+		assertThat(result.isAcknowledgeMessage()).isFalse();
+	}
+
+	@Test
+	void acknowledgeAndReturn() {
+		Message<String> message = new TestMessage();
+		MessageResult<Message<String>> result = MessageResult.acknowledgeAndReturn(message);
+		assertThat(result.getValue().getValue()).isEqualTo("message-value");
+		assertThat(result.getMessageId()).isEqualTo(MESSAGE_ID);
+		assertThat(result.isAcknowledgeMessage()).isTrue();
+	}
+
+	static class TestMessageId implements MessageId {
+
+		@Override
+		public byte[] toByteArray() {
+			return new byte[0];
+		}
+
+		@Override
+		public int compareTo(MessageId o) {
+			return 0;
+		}
+
+	}
+
+	static class TestMessage implements Message<String> {
+
+		@Override
+		public Map<String, String> getProperties() {
+			return null;
+		}
+
+		@Override
+		public boolean hasProperty(String name) {
+			return false;
+		}
+
+		@Override
+		public String getProperty(String name) {
+			return null;
+		}
+
+		@Override
+		public byte[] getData() {
+			return new byte[0];
+		}
+
+		@Override
+		public int size() {
+			return 0;
+		}
+
+		@Override
+		public String getValue() {
+			return "message-value";
+		}
+
+		@Override
+		public MessageId getMessageId() {
+			return MESSAGE_ID;
+		}
+
+		@Override
+		public long getPublishTime() {
+			return 0;
+		}
+
+		@Override
+		public long getEventTime() {
+			return 0;
+		}
+
+		@Override
+		public long getSequenceId() {
+			return 0;
+		}
+
+		@Override
+		public String getProducerName() {
+			return null;
+		}
+
+		@Override
+		public boolean hasKey() {
+			return false;
+		}
+
+		@Override
+		public String getKey() {
+			return null;
+		}
+
+		@Override
+		public boolean hasBase64EncodedKey() {
+			return false;
+		}
+
+		@Override
+		public byte[] getKeyBytes() {
+			return new byte[0];
+		}
+
+		@Override
+		public boolean hasOrderingKey() {
+			return false;
+		}
+
+		@Override
+		public byte[] getOrderingKey() {
+			return new byte[0];
+		}
+
+		@Override
+		public String getTopicName() {
+			return null;
+		}
+
+		@Override
+		public Optional<EncryptionContext> getEncryptionCtx() {
+			return Optional.empty();
+		}
+
+		@Override
+		public int getRedeliveryCount() {
+			return 0;
+		}
+
+		@Override
+		public byte[] getSchemaVersion() {
+			return new byte[0];
+		}
+
+		@Override
+		public boolean isReplicated() {
+			return false;
+		}
+
+		@Override
+		public String getReplicatedFrom() {
+			return null;
+		}
+
+		@Override
+		public void release() {
+
+		}
+
+		@Override
+		public boolean hasBrokerPublishTime() {
+			return false;
+		}
+
+		@Override
+		public Optional<Long> getBrokerPublishTime() {
+			return Optional.empty();
+		}
+
+		@Override
+		public boolean hasIndex() {
+			return false;
+		}
+
+		@Override
+		public Optional<Long> getIndex() {
+			return Optional.empty();
+		}
+
+	}
+
+}