Spring/spring-integration-extensions
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DSL: MailTests - SearchTermStrategy

Browse Source 
Change lamda expression to a Method reference.
This commit is contained in:
Gary Russell
2014-09-10 10:55:47 -05:00
parent 782999f576
commit 87745d43a1
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-integration-java-dsl/src/test/java/org/springframework/integration/dsl/test/mail/MailTests.java
View File

@@ -26,6 +26,7 @@ import static org.junit.Assert.assertTrue;
import java.util.Properties;
import javax.mail.Flags;
import javax.mail.Folder;
import javax.mail.internet.AddressException;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
@@ -222,7 +223,7 @@ public class MailTests {
public IntegrationFlow imapMailFlow() {
return IntegrationFlows
.from(Mail.imapInboundAdapter("imap://user:pw@localhost:" + imapPort + "/INBOX")
.searchTermStrategy((f, l) -> fromAndNotSeenTerm())
.searchTermStrategy(this::fromAndNotSeenTerm)
.javaMailProperties(p -> p.put("mail.debug", "true")),
e -> e.autoStartup(true)
.poller(Pollers.fixedDelay(1000)))
@@ -234,7 +235,7 @@ public class MailTests {
public IntegrationFlow imapIdleFlow() {
return IntegrationFlows
.from(Mail.imapIdleAdapter("imap://user:pw@localhost:" + imapIdlePort + "/INBOX")
.searchTermStrategy((f, l) -> fromAndNotSeenTerm())
.searchTermStrategy(this::fromAndNotSeenTerm)
.javaMailProperties(p -> p.put("mail.debug", "true")
.put("mail.imap.connectionpoolsize", "5"))
.shouldReconnectAutomatically(false))
@@ -242,7 +243,7 @@ public class MailTests {
.get();
}
private SearchTerm fromAndNotSeenTerm() {
private SearchTerm fromAndNotSeenTerm(Flags supportedFlags, Folder folder) {
try {
FromTerm fromTerm = new FromTerm(new InternetAddress("bar@baz"));
return new AndTerm(fromTerm, new FlagTerm(new Flags(Flags.Flag.SEEN), false));