Skip to content

Use Citrus framework for email-listener integration tests #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
christophd wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Use Citrus framework for email-listener integration tests #1

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 7 additions & 0 deletions .gitignore
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,3 +6,10 @@ target/
data/
.attach_*
derby.log
test-output
.DS_Store
.idea
*.iml
*.ipr
*.iws
.metadata
3 changes: 2 additions & 1 deletion pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@
<saxon.bundle.version>9.5.1-1_1</saxon.bundle.version>
<commons-lang-version>2.6</commons-lang-version>
<postgresql-version>8.4-702.jdbc4</postgresql-version>
<spring-jdbc-version>3.2.8.RELEASE</spring-jdbc-version>
<spring-jdbc-version>3.2.8.RELEASE</spring-jdbc-version>

<!-- Logging Properties -->
<slf4j-version>1.6.6</slf4j-version>
Expand All @@ -82,6 +82,7 @@
<ftpserver-version>1.0.6</ftpserver-version>
<sshd-version>0.10.0</sshd-version>
<greenmail-version>1.4.0</greenmail-version>
<citrus-version>2.5.1</citrus-version>

<!-- Plugin Versions -->
<compiler-plugin-version>3.1</compiler-plugin-version>
Expand Down
96 changes: 94 additions & 2 deletions service.polling.emaillistener/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@
<artifactId>entities.travel</artifactId>
<version>${project.version}</version>
</dependency>

<!-- Fuse Dependencies -->
<dependency>
<groupId>org.apache.camel</groupId>
Expand Down Expand Up @@ -56,7 +56,7 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-mail</artifactId>
</dependency>

<!-- the ActiveMQ client with connection pooling -->

<dependency>
Expand Down Expand Up @@ -116,7 +116,99 @@
<version>${greenmail-version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.consol.citrus</groupId>
<artifactId>citrus-core</artifactId>
<version>${citrus-version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.consol.citrus</groupId>
<artifactId>citrus-java-dsl</artifactId>
<version>${citrus-version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.consol.citrus</groupId>
<artifactId>citrus-jms</artifactId>
<version>${citrus-version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.consol.citrus</groupId>
<artifactId>citrus-mail</artifactId>
<version>${citrus-version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.consol.citrus</groupId>
<artifactId>citrus-camel</artifactId>
<version>${citrus-version}</version>
<scope>test</scope>
</dependency>

<!-- Spring dependencies -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>4.2.3.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
<version>4.2.3.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>4.2.3.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
<version>4.2.3.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>4.2.3.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>4.2.3.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>4.2.3.RELEASE</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>4.2.3.RELEASE</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.ow2.asm</groupId>
<artifactId>asm</artifactId>
<version>5.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.ow2.asm</groupId>
<artifactId>asm-commons</artifactId>
<version>5.1</version>
<scope>test</scope>
</dependency>
</dependencies>

<build>
Expand Down
1 change: 1 addition & 0 deletions ...e.polling.emaillistener/src/main/resources/OSGI-INF/blueprint/blueprint-polling-email.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -96,6 +96,7 @@
<to uri="bean:flightSegmentRecordCsvHandler?method=fromCSV" />
<marshal ref="jaxb" />
<log message="Email: FLIGHT SEGMENT RECORD XML --- ${body}" />
<convertBodyTo type="java.lang.String"/>
<to uri="activemq:{{outbound.jms.dest}}" />
</split>
</split>
Expand Down
151 changes: 41 additions & 110 deletions ...istener/src/test/java/org/jboss/fuse/service/polling/emaillistener/EmailListenerTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,74 +1,44 @@
package org.jboss.fuse.service.polling.emaillistener;

import java.io.File;
import java.net.URI;
import java.util.Calendar;
import java.util.List;

import javax.activation.DataHandler;
import javax.activation.DataSource;
import javax.activation.FileDataSource;
import javax.mail.Message;
import javax.mail.Multipart;
import javax.mail.Session;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeBodyPart;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeMultipart;

import org.apache.activemq.broker.BrokerService;
import org.apache.activemq.broker.TransportConnector;
import com.consol.citrus.Citrus;
import com.consol.citrus.container.IteratingConditionExpression;
import com.consol.citrus.context.TestContext;
import com.consol.citrus.dsl.design.DefaultTestDesigner;
import com.consol.citrus.dsl.design.TestDesigner;
import com.consol.citrus.message.MessageType;
import com.icegreen.greenmail.util.GreenMail;
import com.icegreen.greenmail.util.ServerSetupTest;
import org.apache.camel.Route;
import org.apache.camel.ServiceStatus;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.model.ModelCamelContext;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.junit.*;
import org.springframework.core.io.ClassPathResource;

import com.icegreen.greenmail.user.GreenMailUser;
import com.icegreen.greenmail.util.GreenMail;
import com.icegreen.greenmail.util.ServerSetupTest;
import java.util.List;

public class EmailListenerTest extends CamelBlueprintTestSupport {

private static final Logger LOG = LoggerFactory.getLogger(EmailListenerTest.class);

protected static BrokerService broker;

protected static final String ATTACHMENT_DIR_STRING = "./src/test/resources/test-data/";
protected static final File ATTACHMENT_FILE = new File(ATTACHMENT_DIR_STRING + "emailPollRecords-basicTest.txt");

private static final String USER_NAME = "accountone";
private static final String USER_PASSWORD = "accountone";
private static final String EMAIL_USER_ADDRESS = "accountone@localhost";
private static final String EMAIL_TO = "accountone@127.0.0.1";
private static final String EMAIL_SUBJECT = "Test E-Mail";

private GreenMail mailServer;

private GreenMailUser user;
private Citrus citrus;
private TestDesigner designer;

@Override
@Before
public void setUp() throws Exception {

// Embed a JMS Broker for testing
broker = new BrokerService();
final TransportConnector connector = new TransportConnector();
connector.setUri(new URI("tcp://localhost:61615"));
broker.setBrokerName("activemq");
broker.addConnector(connector);
broker.setPersistent(false);
broker.start();

// GreenMail sets Test Server up on Port 3110
mailServer = new GreenMail(ServerSetupTest.POP3);
mailServer = new GreenMail(ServerSetupTest.SMTP_POP3);
mailServer.start();

user = mailServer.setUser(EMAIL_USER_ADDRESS, USER_NAME, USER_PASSWORD);
mailServer.setUser(EMAIL_USER_ADDRESS, USER_NAME, USER_PASSWORD);

citrus = Citrus.newInstance();
designer = new DefaultTestDesigner(citrus.getApplicationContext(), citrus.createTestContext());

// Creates the Blueprint Context
super.setUp();
Expand All @@ -79,10 +49,6 @@ public void setUp() throws Exception {
@After
public void tearDown() throws Exception {
mailServer.stop();

broker.stop();
broker = null;

super.tearDown();
}

Expand All @@ -97,76 +63,41 @@ protected String[] loadConfigAdminConfigurationFile() {
"org.jboss.fuse.service.polling.emaillistener" };
}

@Override
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {

public void configure() {
from("activemq:org.jboss.fuse.service.polling.processor.queue").id("emaillistenunittest")
.to("file:data/out?fileName=record-${date:now:yyyyMMdd-hhmmssSSSS}").to("mock:result");
}

};
}

@Test
public void testEmailRoute() throws Exception {

LOG.info("testEmailRoute::start");

// wait 1 second for Listener Route to start
Thread.sleep(1000);

ServiceStatus routeStatus = this.context.getRouteStatus("poll.email.receive");
designer.echo("testEmailRoute::start");

// Show routes for information
List<Route> routes = this.context().getRoutes();
for (Route r : routes) {
LOG.info("+Route: " + r.getId());
designer.echo("+Route: " + r.getId());
}

if (null != routeStatus) {

assertTrue("Route was not created", routeStatus.isStarted());

MimeMessage message = new MimeMessage((Session) null);
message.setFrom(new InternetAddress(EMAIL_TO));
message.addRecipient(Message.RecipientType.TO, new InternetAddress(EMAIL_USER_ADDRESS));
message.setSubject(EMAIL_SUBJECT);
message.setSentDate(Calendar.getInstance().getTime());

MimeBodyPart bodyPart = new MimeBodyPart();
bodyPart.setText("This is the email body text");

MimeBodyPart attachmentPart = new MimeBodyPart();
DataSource source = new FileDataSource(ATTACHMENT_FILE);
attachmentPart.setDataHandler(new DataHandler(source));
attachmentPart.setFileName("emailPollRecords-basicTest.txt");
designer.camel()
.context((ModelCamelContext) this.context())
.controlBus()
.route("poll.email.receive", "status")
.result(ServiceStatus.Started);

Multipart multipart = new MimeMultipart();
multipart.addBodyPart(bodyPart);
multipart.addBodyPart(attachmentPart);
designer.echo("Delivering Email w/ Attachment");

message.setContent(multipart);
designer.send("mailClient")
.payload(new ClassPathResource("test-data/send-mail.xml"));

LOG.info("Delivering Email w/ Attachment");

user.deliver(message);

// wait 2 seconds for route to start and process
Thread.sleep(2000);

getMockEndpoint("mock:result").expectedMinimumMessageCount(1);

// assert expectations
assertMockEndpointsSatisfied();

} else {
assertFalse("RouteStatus is null", true);
}
designer.iterate().condition(new IteratingConditionExpression() {
@Override
public boolean evaluate(int i, TestContext context) {
return i <= 5;
}
}).actions(
designer.receive("servicePollingJmsEndpoint")
.messageType(MessageType.XML)
.payload("citrus:readFile('test-data/flightSegmentRecord_${i}.xml')")
);

LOG.info("testDynamicEmailRoute::end");
designer.echo("testDynamicEmailRoute::end");

citrus.run(designer.getTestCase());
}

}
37 changes: 37 additions & 0 deletions service.polling.emaillistener/src/test/resources/citrus-context.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,37 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:amq="http://activemq.apache.org/schema/core"
xmlns:citrus="http://www.citrusframework.org/schema/config"
xmlns:citrus-jms="http://www.citrusframework.org/schema/jms/config"
xmlns:citrus-mail="http://www.citrusframework.org/schema/mail/config"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd
http://www.citrusframework.org/schema/config http://www.citrusframework.org/schema/config/citrus-config.xsd
http://www.citrusframework.org/schema/jms/config http://www.citrusframework.org/schema/jms/config/citrus-jms-config.xsd
http://www.citrusframework.org/schema/mail/config http://www.citrusframework.org/schema/mail/config/citrus-mail-config.xsd">

<!-- Embedded ActiveMQ JMS broker -->
<amq:broker useJmx="false" persistent="false">
<amq:transportConnectors>
<amq:transportConnector uri="tcp://localhost:61615" />
</amq:transportConnectors>
</amq:broker>

<bean id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61615" />
<property name="watchTopicAdvisories" value="false"/>
</bean>

<!-- Mail client -->
<citrus-mail:client id="mailClient"
host="localhost"
port="3025"
username="accountone"
password="accountone"/>

<!-- JMS service polling endpoint -->
<citrus-jms:endpoint id="servicePollingJmsEndpoint"
destination-name="org.jboss.fuse.service.polling.processor.queue"/>

</beans>
Loading