Merge pull request #13 from ghillert/INTSAMPLES-34
INTSAMPLES-34 Initial commit of the Enricher Sample
This commit is contained in:
Gunnar Hillert
36
basic/enricher/README.md
Normal file
36
basic/enricher/README.md
Normal file
@@ -0,0 +1,36 @@
|
||||
Spring Integration - Enricher Sample
|
||||
================================
|
||||
|
||||
# Overview
|
||||
|
||||
This sample demonstrates how the Enricher components can be used.
|
||||
|
||||
# Getting Started
|
||||
|
||||
You can run the sample application by either
|
||||
|
||||
* running the "Main" class from within STS (Right-click on Main class --> Run As --> Java Application)
|
||||
* or from the command line execute:
|
||||
- mvn package
|
||||
- mvn exec:java
|
||||
|
||||
This example illustrates the usage of the Content Enricher.
|
||||
|
||||
Once the application has started, lease execute the various Content Enricher examples by
|
||||
|
||||
* entering 1 + Enter
|
||||
* entering 2 + Enter
|
||||
* entering 3 + Enter
|
||||
|
||||
3 different message flows are triggered. For use-cases 1+2 a **User** object containing only the **username** is passed in. For use-case 3 a Map with the **username** key is passed in and enriched with the **User** object using the **user** key:
|
||||
|
||||
* 1: In the *Enricher*, pass the full **User** object to the **request channel**.
|
||||
* 2: In the *Enricher*, pass only the **username** to the **request channel** by using the **request-payload-expression** attribute.
|
||||
* 3: In the *Enricher*, pass only the username to the **request channel**, executing the same Service Activator as in **2**.
|
||||
|
||||
# Resources
|
||||
|
||||
For help please take a look at the Spring Integration documentation:
|
||||
|
||||
http://www.springsource.org/spring-integration
|
||||
|
||||
123
basic/enricher/pom.xml
Normal file
123
basic/enricher/pom.xml
Normal file
@@ -0,0 +1,123 @@
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<groupId>org.springframework.integration.samples</groupId>
|
||||
<artifactId>enricher</artifactId>
|
||||
<version>1.0-SNAPSHOT</version>
|
||||
<packaging>jar</packaging>
|
||||
|
||||
<name>enricher-sample</name>
|
||||
<url>http://www.springsource.org/spring-integration</url>
|
||||
|
||||
<properties>
|
||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||
<spring.integration.version>2.1.0.BUILD-SNAPSHOT</spring.integration.version>
|
||||
<slf4j.version>1.6.1</slf4j.version>
|
||||
<junit.version>4.7</junit.version>
|
||||
</properties>
|
||||
|
||||
<repositories>
|
||||
<repository>
|
||||
<id>repository.springframework.maven.release</id>
|
||||
<name>Spring Framework Maven Release Repository</name>
|
||||
<url>http://maven.springframework.org/release</url>
|
||||
</repository>
|
||||
<repository>
|
||||
<id>repository.springframework.maven.milestone</id>
|
||||
<name>Spring Framework Maven Milestone Repository</name>
|
||||
<url>http://maven.springframework.org/milestone</url>
|
||||
</repository>
|
||||
</repositories>
|
||||
|
||||
<build>
|
||||
<plugins>
|
||||
<plugin>
|
||||
<artifactId>maven-eclipse-plugin</artifactId>
|
||||
<version>2.8</version>
|
||||
<configuration>
|
||||
<additionalProjectnatures>
|
||||
<projectnature>org.springframework.ide.eclipse.core.springnature</projectnature>
|
||||
</additionalProjectnatures>
|
||||
<additionalBuildcommands>
|
||||
<buildcommand>org.springframework.ide.eclipse.core.springbuilder</buildcommand>
|
||||
</additionalBuildcommands>
|
||||
<downloadSources>true</downloadSources>
|
||||
<downloadJavadocs>true</downloadJavadocs>
|
||||
</configuration>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-compiler-plugin</artifactId>
|
||||
<version>2.3.2</version>
|
||||
<configuration>
|
||||
<source>1.6</source>
|
||||
<target>1.6</target>
|
||||
<compilerArgument>-Xlint:all</compilerArgument>
|
||||
<showWarnings>true</showWarnings>
|
||||
<showDeprecation>true</showDeprecation>
|
||||
</configuration>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.codehaus.mojo</groupId>
|
||||
<artifactId>exec-maven-plugin</artifactId>
|
||||
<version>1.2</version>
|
||||
<configuration>
|
||||
<mainClass>org.springframework.integration.samples.enricher.Main</mainClass>
|
||||
</configuration>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
|
||||
<dependencies>
|
||||
|
||||
<!-- Testing -->
|
||||
|
||||
<dependency>
|
||||
<groupId>junit</groupId>
|
||||
<artifactId>junit</artifactId>
|
||||
<version>${junit.version}</version>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
|
||||
<!-- Spring Integration -->
|
||||
|
||||
<dependency>
|
||||
<groupId>org.springframework.integration</groupId>
|
||||
<artifactId>spring-integration-core</artifactId>
|
||||
<version>${spring.integration.version}</version>
|
||||
</dependency>
|
||||
|
||||
<!-- Logging -->
|
||||
|
||||
<dependency>
|
||||
<groupId>ch.qos.logback</groupId>
|
||||
<artifactId>logback-classic</artifactId>
|
||||
<version>0.9.28</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>slf4j-api</artifactId>
|
||||
<version>${slf4j.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>log4j-over-slf4j</artifactId>
|
||||
<version>${slf4j.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>jcl-over-slf4j</artifactId>
|
||||
<version>${slf4j.version}</version>
|
||||
</dependency>
|
||||
|
||||
<!-- Embedded Database -->
|
||||
|
||||
<dependency>
|
||||
<groupId>com.h2database</groupId>
|
||||
<artifactId>h2</artifactId>
|
||||
<version>1.3.160</version>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
</project>
|
||||
@@ -0,0 +1,142 @@
|
||||
/*
|
||||
* Copyright 2002-2010 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
|
||||
*
|
||||
* 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.springframework.integration.samples.enricher;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import java.util.Scanner;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.context.support.AbstractApplicationContext;
|
||||
import org.springframework.context.support.ClassPathXmlApplicationContext;
|
||||
import org.springframework.integration.samples.enricher.service.UserService;
|
||||
|
||||
|
||||
/**
|
||||
* Starts the Spring Context and will initialize the Spring Integration routes.
|
||||
*
|
||||
* @author Gunnar Hillert
|
||||
* @version 1.0
|
||||
*
|
||||
*/
|
||||
public final class Main {
|
||||
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(Main.class);
|
||||
|
||||
private static final String LINE_SEPARATOR = "\n==========================================================================";
|
||||
private static final String EMPTY_LINE = "\n ";
|
||||
|
||||
private Main() { }
|
||||
|
||||
/**
|
||||
* Load the Spring Integration Application Context
|
||||
*
|
||||
* @param args - command line arguments
|
||||
*/
|
||||
public static void main(final String... args) {
|
||||
|
||||
LOGGER.info(LINE_SEPARATOR
|
||||
+ EMPTY_LINE
|
||||
+ "\n Welcome to Spring Integration! "
|
||||
+ EMPTY_LINE
|
||||
+ "\n For more information please visit: "
|
||||
+ "\n http://www.springsource.org/spring-integration "
|
||||
+ EMPTY_LINE
|
||||
+ LINE_SEPARATOR );
|
||||
|
||||
final AbstractApplicationContext context =
|
||||
new ClassPathXmlApplicationContext("classpath:META-INF/spring/integration/*-context.xml");
|
||||
|
||||
context.registerShutdownHook();
|
||||
|
||||
final Scanner scanner = new Scanner(System.in);
|
||||
|
||||
final UserService service = context.getBean(UserService.class);
|
||||
|
||||
LOGGER.info(LINE_SEPARATOR
|
||||
+ EMPTY_LINE
|
||||
+ "\n Please press 'q + Enter' to quit the application. "
|
||||
+ EMPTY_LINE
|
||||
+ LINE_SEPARATOR
|
||||
+ EMPTY_LINE
|
||||
+ "\n This example illustrates the usage of the Content Enricher. "
|
||||
+ EMPTY_LINE
|
||||
+ "\n Usage: Please enter 1 or 2 or 3 + Enter "
|
||||
+ EMPTY_LINE
|
||||
+ "\n 3 different message flows are triggered. For sample 1+2 a "
|
||||
+ "\n user object containing only the username is passed in. "
|
||||
+ "\n For sample 3 a Map with the 'username' key is passed in and enriched "
|
||||
+ "\n with the user object using the 'user' key. "
|
||||
+ EMPTY_LINE
|
||||
+ "\n 1: In the Enricher, pass the full User object to the request channel. "
|
||||
+ "\n 2: In the Enricher, pass only the username to the request channel. "
|
||||
+ "\n 3: In the Enricher, pass only the username to the request channel. "
|
||||
+ EMPTY_LINE
|
||||
+ LINE_SEPARATOR);
|
||||
|
||||
while (!scanner.hasNext("q")) {
|
||||
|
||||
final String input = scanner.nextLine();
|
||||
|
||||
User user = new User("foo", null, null);
|
||||
|
||||
if ("1".equals(input)) {
|
||||
|
||||
final User fullUser = service.findUser(user);
|
||||
printUserInformation(fullUser);
|
||||
|
||||
} else if ("2".equals(input)) {
|
||||
|
||||
final User fullUser = service.findUserByUsername(user);
|
||||
printUserInformation(fullUser);
|
||||
|
||||
} else if ("3".equals(input)) {
|
||||
|
||||
final Map<String, Object> userData = new HashMap<String, Object>();
|
||||
userData.put("username", "foo_map");
|
||||
|
||||
final Map<String, Object> enrichedUserData = service.findUserWithUsernameInMap(userData);
|
||||
|
||||
final User fullUser = (User) enrichedUserData.get("user");
|
||||
|
||||
printUserInformation(fullUser);
|
||||
|
||||
} else {
|
||||
LOGGER.info("\n\n Please enter '1' or '2' <enter>:\n\n");
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
LOGGER.info("\n\nExiting application...bye.");
|
||||
|
||||
System.exit(0);
|
||||
|
||||
}
|
||||
|
||||
private static void printUserInformation(User user) {
|
||||
|
||||
if (user != null) {
|
||||
LOGGER.info("\n\n User found - Username: '{}', Email: '{}', Password: '{}'.\n\n",
|
||||
new Object[] {user.getUsername(), user.getEmail(), user.getPassword()});
|
||||
|
||||
} else {
|
||||
LOGGER.info("\n\n No User found for username: 'foo'.\n\n");
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,63 @@
|
||||
/*
|
||||
* Copyright 2002-2011 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
|
||||
*
|
||||
* 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.springframework.integration.samples.enricher;
|
||||
|
||||
public class User {
|
||||
private String username;
|
||||
private String password;
|
||||
private String email;
|
||||
|
||||
public User(String username, String password, String email) {
|
||||
super();
|
||||
this.username = username;
|
||||
this.password = password;
|
||||
this.email = email;
|
||||
}
|
||||
|
||||
public String getUsername() {
|
||||
return this.username;
|
||||
}
|
||||
|
||||
public String getPassword() {
|
||||
return this.password;
|
||||
}
|
||||
|
||||
public String getEmail() {
|
||||
return this.email;
|
||||
}
|
||||
|
||||
public void setUsername(String username) {
|
||||
this.username = username;
|
||||
}
|
||||
|
||||
public void setPassword(String password) {
|
||||
this.password = password;
|
||||
}
|
||||
|
||||
public void setEmail(String email) {
|
||||
this.email = email;
|
||||
}
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
StringBuilder builder = new StringBuilder();
|
||||
builder.append("User [username=")
|
||||
.append(this.username)
|
||||
.append(", password=")
|
||||
.append(this.password)
|
||||
.append(", email=")
|
||||
.append(this.email).append("]");
|
||||
return builder.toString();
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,46 @@
|
||||
/*
|
||||
* Copyright 2002-2011 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
|
||||
*
|
||||
* 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.springframework.integration.samples.enricher.service;
|
||||
|
||||
import java.util.Map;
|
||||
|
||||
import org.springframework.integration.samples.enricher.User;
|
||||
|
||||
/**
|
||||
* Provides user services.
|
||||
*/
|
||||
public interface UserService {
|
||||
|
||||
/**
|
||||
* Retrieves a user based on the provided user. User object is routed to the
|
||||
* "findUserEnricherChannel" channel.
|
||||
*/
|
||||
User findUser(User user);
|
||||
|
||||
/**
|
||||
* Retrieves a user based on the provided user. User object is routed to the
|
||||
* "findUserByUsernameEnricherChannel" channel.
|
||||
*/
|
||||
User findUserByUsername(User user);
|
||||
|
||||
/**
|
||||
* Retrieves a user based on the provided username that is provided as a Map
|
||||
* entry using the mapkey 'username'. Map object is routed to the
|
||||
* "findUserWithMapChannel" channel.
|
||||
*/
|
||||
Map<String, Object> findUserWithUsernameInMap(Map<String, Object> userdata);
|
||||
|
||||
}
|
||||
@@ -0,0 +1,55 @@
|
||||
/*
|
||||
* Copyright 2002-2011 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
|
||||
*
|
||||
* 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.springframework.integration.samples.enricher.service.impl;
|
||||
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.integration.samples.enricher.User;
|
||||
|
||||
/**
|
||||
* Simple Service class for retrieving user information.
|
||||
*
|
||||
* @author Gunnar Hillert
|
||||
*
|
||||
*/
|
||||
public class SystemService {
|
||||
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(SystemService.class);
|
||||
|
||||
/** Default Constructor. */
|
||||
public SystemService() {
|
||||
super();
|
||||
}
|
||||
|
||||
public User findUser(User user) {
|
||||
|
||||
LOGGER.info("Calling method 'findUser' with parameter {}", user);
|
||||
|
||||
final User fullUser = new User(user.getUsername(),
|
||||
"secret",
|
||||
user.getUsername() + "@springintegration.org");
|
||||
return fullUser;
|
||||
}
|
||||
|
||||
public User findUserByUsername(String username) {
|
||||
|
||||
LOGGER.info("Calling method 'findUserByUsername' with parameter: {}", username);
|
||||
|
||||
return new User(username, "secret", username + "@springintegration.org");
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,59 @@
|
||||
<?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:int="http://www.springframework.org/schema/integration"
|
||||
xsi:schemaLocation="http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration-2.1.xsd
|
||||
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
|
||||
|
||||
<int:channel id="findUserEnricherChannel"/>
|
||||
<int:channel id="findUserByUsernameEnricherChannel"/>
|
||||
<int:channel id="findUserWithMapEnricherChannel"/>
|
||||
|
||||
<int:channel id="findUserServiceChannel"/>
|
||||
<int:channel id="findUserByUsernameServiceChannel"/>
|
||||
|
||||
<!-- See also:
|
||||
http://static.springsource.org/spring-integration/reference/htmlsingle/#gateway-proxy
|
||||
http://www.eaipatterns.com/MessagingGateway.html -->
|
||||
<int:gateway id="userGateway" default-request-timeout="5000"
|
||||
default-reply-timeout="5000"
|
||||
service-interface="org.springframework.integration.samples.enricher.service.UserService">
|
||||
<int:method name="findUser" request-channel="findUserEnricherChannel"/>
|
||||
<int:method name="findUserByUsername" request-channel="findUserByUsernameEnricherChannel"/>
|
||||
<int:method name="findUserWithUsernameInMap" request-channel="findUserWithMapEnricherChannel"/>
|
||||
</int:gateway>
|
||||
|
||||
<int:enricher id="findUserEnricher"
|
||||
input-channel="findUserEnricherChannel"
|
||||
request-channel="findUserServiceChannel">
|
||||
<int:property name="email" expression="payload.email"/>
|
||||
<int:property name="password" expression="payload.password"/>
|
||||
</int:enricher>
|
||||
|
||||
<int:enricher id="findUserByUsernameEnricher"
|
||||
input-channel="findUserByUsernameEnricherChannel"
|
||||
request-channel="findUserByUsernameServiceChannel"
|
||||
request-payload-expression="payload.username">
|
||||
<int:property name="email" expression="payload.email"/>
|
||||
<int:property name="password" expression="payload.password"/>
|
||||
</int:enricher>
|
||||
|
||||
<int:enricher id="findUserWithMapEnricher"
|
||||
input-channel="findUserWithMapEnricherChannel"
|
||||
request-channel="findUserByUsernameServiceChannel"
|
||||
request-payload-expression="payload.username">
|
||||
<int:property name="user" expression="payload"/>
|
||||
</int:enricher>
|
||||
|
||||
<int:service-activator id="findUserServiceActivator"
|
||||
ref="systemService" method="findUser"
|
||||
input-channel="findUserServiceChannel"/>
|
||||
|
||||
<int:service-activator id="findUserByUsernameServiceActivator"
|
||||
ref="systemService" method="findUserByUsername"
|
||||
input-channel="findUserByUsernameServiceChannel"/>
|
||||
|
||||
<bean id="systemService"
|
||||
class="org.springframework.integration.samples.enricher.service.impl.SystemService"/>
|
||||
|
||||
</beans>
|
||||
24
basic/enricher/src/main/resources/logback.xml
Normal file
24
basic/enricher/src/main/resources/logback.xml
Normal file
@@ -0,0 +1,24 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
|
||||
<configuration>
|
||||
|
||||
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
|
||||
<encoder>
|
||||
<pattern>%d %5p | %t | %-55logger{55} | %m %n</pattern>
|
||||
</encoder>
|
||||
</appender>
|
||||
|
||||
<logger name="org.springframework.integration">
|
||||
<level value="INFO" />
|
||||
</logger>
|
||||
|
||||
<logger name="org.springframework">
|
||||
<level value="INFO" />
|
||||
</logger>
|
||||
|
||||
<root>
|
||||
<level value="INFO" />
|
||||
<appender-ref ref="CONSOLE" />
|
||||
</root>
|
||||
|
||||
</configuration>
|
||||
@@ -0,0 +1,77 @@
|
||||
/*
|
||||
* Copyright 2002-2010 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
|
||||
*
|
||||
* 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.springframework.integration.samples.enricher.service;
|
||||
|
||||
import static junit.framework.Assert.*;
|
||||
|
||||
import org.junit.Test;
|
||||
import org.springframework.context.ApplicationContext;
|
||||
import org.springframework.context.support.ClassPathXmlApplicationContext;
|
||||
import org.springframework.integration.samples.enricher.User;
|
||||
import org.springframework.integration.samples.enricher.service.UserService;
|
||||
|
||||
|
||||
/**
|
||||
* Verify that the Spring Integration Application Context starts successfully.
|
||||
*/
|
||||
public class UserServiceTest {
|
||||
|
||||
@Test
|
||||
public void testStartupOfSpringInegrationContext() throws Exception{
|
||||
final ApplicationContext context
|
||||
= new ClassPathXmlApplicationContext("/META-INF/spring/integration/spring-integration-context.xml",
|
||||
UserServiceTest.class);
|
||||
Thread.sleep(2000);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testExecuteFindUser() {
|
||||
|
||||
final ApplicationContext context
|
||||
= new ClassPathXmlApplicationContext("/META-INF/spring/integration/spring-integration-context.xml",
|
||||
UserServiceTest.class);
|
||||
|
||||
final UserService service = context.getBean(UserService.class);
|
||||
|
||||
User user = new User("foo", null, null);
|
||||
final User fullUser = service.findUser(user);
|
||||
|
||||
assertEquals("foo", fullUser.getUsername());
|
||||
assertEquals("foo@springintegration.org", fullUser.getEmail());
|
||||
assertEquals("secret", fullUser.getPassword());
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testExecuteFindUserByUsername() {
|
||||
|
||||
final ApplicationContext context
|
||||
= new ClassPathXmlApplicationContext("/META-INF/spring/integration/spring-integration-context.xml",
|
||||
UserServiceTest.class);
|
||||
|
||||
final UserService service = context.getBean(UserService.class);
|
||||
|
||||
User user = new User("foo", null, null);
|
||||
final User fullUser = service.findUserByUsername(user);
|
||||
|
||||
assertEquals("foo", fullUser.getUsername());
|
||||
assertEquals("foo@springintegration.org", fullUser.getEmail());
|
||||
assertEquals("secret", fullUser.getPassword());
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@@ -11,6 +11,7 @@
|
||||
|
||||
<modules>
|
||||
<module>amqp</module>
|
||||
<module>enricher</module>
|
||||
<module>feed</module>
|
||||
<module>file</module>
|
||||
<module>ftp</module>
|
||||
|
||||
Reference in New Issue
Block a user