[prev in list] [next in list] [prev in thread] [next in thread]
List: james-dev
Subject: svn commit: r1716964 - in /james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/
From: btellier () apache ! org
Date: 2015-11-28 13:07:09
Message-ID: 20151128130709.8459D3A0367 () svn01-us-west ! apache ! org
[Download RAW message or body]
Author: btellier
Date: Sat Nov 28 13:07:09 2015
New Revision: 1716964
URL: http://svn.apache.org/viewvc?rev=1716964&view=rev
Log:
MAILBOX-211 Broadcast integration tests
Added:
james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/store/event/distributed/BroadcastDelegatingMailboxListenerIntegrationTest.java
james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/store/event/distributed/PublisherReceiver.java
Added: james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/store/event/distributed/BroadcastDelegatingMailboxListenerIntegrationTest.java
URL: http://svn.apache.org/viewvc/james/project/trunk/mailbox/store/src/test/java/org/ \
apache/james/mailbox/store/event/distributed/BroadcastDelegatingMailboxListenerIntegrationTest.java?rev=1716964&view=auto
==============================================================================
--- james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/store/event/distributed/BroadcastDelegatingMailboxListenerIntegrationTest.java \
(added)
+++ james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/store/event/distributed/BroadcastDelegatingMailboxListenerIntegrationTest.java \
Sat Nov 28 13:07:09 2015 @@ -0,0 +1,147 @@
+/****************************************************************
+ * 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.james.mailbox.store.event.distributed;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import org.apache.james.mailbox.MailboxListener;
+import org.apache.james.mailbox.MailboxSession;
+import org.apache.james.mailbox.mock.MockMailboxSession;
+import org.apache.james.mailbox.model.MailboxPath;
+import org.apache.james.mailbox.model.MessageMetaData;
+import org.apache.james.mailbox.store.TestId;
+import org.apache.james.mailbox.store.TestIdDeserializer;
+import org.apache.james.mailbox.store.event.EventFactory;
+import org.apache.james.mailbox.store.json.MessagePackEventSerializer;
+import org.apache.james.mailbox.store.json.event.EventConverter;
+import org.apache.james.mailbox.store.json.event.MailboxConverter;
+import org.apache.james.mailbox.store.mail.model.impl.SimpleMailbox;
+import org.apache.james.mailbox.util.EventCollector;
+import org.junit.Before;
+import org.junit.Test;
+
+import java.util.TreeMap;
+
+/**
+ Integration tests for BroadcastDelegatingMailboxListener.
+
+ We simulate communications using message queues in memory and check the Listener \
works as intended. + */
+public class BroadcastDelegatingMailboxListenerIntegrationTest {
+
+ public static final MailboxPath MAILBOX_PATH_1 = new MailboxPath("#private", \
"user", "mbx"); + public static final MailboxPath MAILBOX_PATH_2 = new \
MailboxPath("#private", "user", "mbx.other"); + public static final String TOPIC = \
"TOPIC"; + private BroadcastDelegatingMailboxListener \
broadcastDelegatingMailboxListener1; + private BroadcastDelegatingMailboxListener \
broadcastDelegatingMailboxListener2; + private BroadcastDelegatingMailboxListener \
broadcastDelegatingMailboxListener3; + private EventCollector \
eventCollectorMailbox1; + private EventCollector eventCollectorMailbox2;
+ private EventCollector eventCollectorMailbox3;
+ private EventCollector eventCollectorOnce1;
+ private EventCollector eventCollectorOnce2;
+ private EventCollector eventCollectorOnce3;
+ private EventCollector eventCollectorEach1;
+ private EventCollector eventCollectorEach2;
+ private EventCollector eventCollectorEach3;
+ private MailboxSession mailboxSession;
+
+ @Before
+ public void setUp() throws Exception {
+ PublisherReceiver publisherReceiver = new PublisherReceiver();
+ broadcastDelegatingMailboxListener1 = new \
BroadcastDelegatingMailboxListener(publisherReceiver, + publisherReceiver,
+ new MessagePackEventSerializer<TestId>(
+ new EventConverter<TestId>(new MailboxConverter<TestId>(new \
TestIdDeserializer())) + ),
+ TOPIC);
+ broadcastDelegatingMailboxListener2 = new \
BroadcastDelegatingMailboxListener(publisherReceiver, + publisherReceiver,
+ new MessagePackEventSerializer<TestId>(
+ new EventConverter<TestId>(new MailboxConverter<TestId>(new \
TestIdDeserializer())) + ),
+ TOPIC);
+ broadcastDelegatingMailboxListener3 = new \
BroadcastDelegatingMailboxListener(publisherReceiver, + publisherReceiver,
+ new MessagePackEventSerializer<TestId>(
+ new EventConverter<TestId>(new MailboxConverter<TestId>(new \
TestIdDeserializer())) + ),
+ TOPIC);
+ eventCollectorMailbox1 = new \
EventCollector(MailboxListener.ListenerType.MAILBOX); + eventCollectorMailbox2 \
= new EventCollector(MailboxListener.ListenerType.MAILBOX); + \
eventCollectorMailbox3 = new EventCollector(MailboxListener.ListenerType.MAILBOX); + \
eventCollectorOnce1 = new EventCollector(MailboxListener.ListenerType.ONCE); + \
eventCollectorOnce2 = new EventCollector(MailboxListener.ListenerType.ONCE); + \
eventCollectorOnce3 = new EventCollector(MailboxListener.ListenerType.ONCE); + \
eventCollectorEach1 = new EventCollector(MailboxListener.ListenerType.EACH_NODE); + \
eventCollectorEach2 = new EventCollector(MailboxListener.ListenerType.EACH_NODE); + \
eventCollectorEach3 = new EventCollector(MailboxListener.ListenerType.EACH_NODE); + \
mailboxSession = new MockMailboxSession("Test"); + \
broadcastDelegatingMailboxListener1.addGlobalListener(eventCollectorOnce1, \
mailboxSession); + \
broadcastDelegatingMailboxListener2.addGlobalListener(eventCollectorOnce2, \
mailboxSession); + \
broadcastDelegatingMailboxListener3.addGlobalListener(eventCollectorOnce3, \
mailboxSession); + \
broadcastDelegatingMailboxListener1.addGlobalListener(eventCollectorEach1, \
mailboxSession); + \
broadcastDelegatingMailboxListener2.addGlobalListener(eventCollectorEach2, \
mailboxSession); + \
broadcastDelegatingMailboxListener3.addGlobalListener(eventCollectorEach3, \
mailboxSession); + \
broadcastDelegatingMailboxListener1.addListener(MAILBOX_PATH_1, \
eventCollectorMailbox1, mailboxSession); + \
broadcastDelegatingMailboxListener2.addListener(MAILBOX_PATH_1, \
eventCollectorMailbox2, mailboxSession); + \
broadcastDelegatingMailboxListener3.addListener(MAILBOX_PATH_2, \
eventCollectorMailbox3, mailboxSession); + }
+
+ @Test
+ public void mailboxEventListenersShouldBeTriggeredIfRegistered() throws \
Exception { + SimpleMailbox<TestId> simpleMailbox = new \
SimpleMailbox<TestId>(MAILBOX_PATH_1, 42); + \
simpleMailbox.setMailboxId(TestId.of(52)); + final MailboxListener.Event event \
= new EventFactory<TestId>().added(mailboxSession, new TreeMap<Long, \
MessageMetaData>(), simpleMailbox); +
+ broadcastDelegatingMailboxListener1.event(event);
+
+ assertThat(eventCollectorMailbox1.getEvents()).hasSize(1);
+ assertThat(eventCollectorMailbox2.getEvents()).hasSize(1);
+ assertThat(eventCollectorMailbox3.getEvents()).isEmpty();
+ }
+
+ @Test
+ public void onceEventListenersShouldBeTriggeredOnceAcrossTheCluster() {
+ SimpleMailbox<TestId> simpleMailbox = new \
SimpleMailbox<TestId>(MAILBOX_PATH_1, 42); + \
simpleMailbox.setMailboxId(TestId.of(52)); + final MailboxListener.Event event \
= new EventFactory<TestId>().added(mailboxSession, new TreeMap<Long, \
MessageMetaData>(), simpleMailbox); +
+ broadcastDelegatingMailboxListener1.event(event);
+
+ assertThat(eventCollectorOnce1.getEvents()).hasSize(1);
+ assertThat(eventCollectorOnce2.getEvents()).isEmpty();
+ assertThat(eventCollectorOnce3.getEvents()).isEmpty();
+ }
+
+ @Test
+ public void eachEventListenersShouldBeTriggeredOnEachNode() {
+ SimpleMailbox<TestId> simpleMailbox = new \
SimpleMailbox<TestId>(MAILBOX_PATH_1, 42); + \
simpleMailbox.setMailboxId(TestId.of(52)); + final MailboxListener.Event event \
= new EventFactory<TestId>().added(mailboxSession, new TreeMap<Long, \
MessageMetaData>(), simpleMailbox); +
+ broadcastDelegatingMailboxListener1.event(event);
+
+ assertThat(eventCollectorEach1.getEvents()).hasSize(1);
+ assertThat(eventCollectorEach2.getEvents()).hasSize(1);
+ assertThat(eventCollectorEach3.getEvents()).hasSize(1);
+ }
+
+}
Added: james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/store/event/distributed/PublisherReceiver.java
URL: http://svn.apache.org/viewvc/james/project/trunk/mailbox/store/src/test/java/org/ \
apache/james/mailbox/store/event/distributed/PublisherReceiver.java?rev=1716964&view=auto
==============================================================================
--- james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/store/event/distributed/PublisherReceiver.java \
(added)
+++ james/project/trunk/mailbox/store/src/test/java/org/apache/james/mailbox/store/event/distributed/PublisherReceiver.java \
Sat Nov 28 13:07:09 2015 @@ -0,0 +1,71 @@
+/****************************************************************
+ * 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.james.mailbox.store.event.distributed;
+
+import com.google.common.collect.HashMultimap;
+import com.google.common.collect.Multimap;
+import org.apache.james.mailbox.store.publisher.MessageConsumer;
+import org.apache.james.mailbox.store.publisher.MessageReceiver;
+import org.apache.james.mailbox.store.publisher.Publisher;
+import org.apache.james.mailbox.store.publisher.Topic;
+
+public class PublisherReceiver implements Publisher, MessageConsumer {
+
+ private final Multimap<Topic, MessageReceiver> messageReceiverMultimap;
+ // Test code is mutable. Agree, this is not nice, but quite convenient . \
MessageConsumer is designed to handle only one message receiver. + // Here we want \
to emulate a complete event systems, across multiple servers... + private \
MessageReceiver messageReceiver; +
+ public PublisherReceiver() {
+ this.messageReceiverMultimap = HashMultimap.create();
+ }
+
+ @Override
+ public void close() {
+
+ }
+
+ @Override
+ public void publish(Topic topic, byte[] message) {
+ for (MessageReceiver messageReceiver : messageReceiverMultimap.get(topic)) {
+ messageReceiver.receiveSerializedEvent(message);
+ }
+ }
+
+ @Override
+ public void init() {
+
+ }
+
+ @Override
+ public void setMessageReceiver(MessageReceiver messageReceiver) {
+ this.messageReceiver = messageReceiver;
+ }
+
+ @Override
+ public void init(Topic topic) throws Exception {
+ messageReceiverMultimap.put(topic, messageReceiver);
+ }
+
+ @Override
+ public void destroy() throws Exception {
+
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic