Author: jstrachan
Date: Tue May 22 01:35:51 2007
New Revision: 540474
URL: http://svn.apache.org/viewvc?view=rev&rev=540474
Log:
added another test case to check the header handling
Added:
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailMessageTest.java
- copied, changed from r539381,
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java
Modified:
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java
Modified:
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java?view=diff&rev=540474&r1=540473&r2=540474
==============================================================================
---
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java
(original)
+++
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java
Tue May 22 01:35:51 2007
@@ -19,6 +19,14 @@
import org.apache.camel.ContextTestSupport;
import org.apache.camel.Endpoint;
+import org.apache.camel.util.ObjectHelper;
+
+import javax.mail.Session;
+import javax.mail.Message;
+import javax.mail.Address;
+import javax.mail.internet.MimeMessage;
+import javax.mail.internet.InternetAddress;
+import java.util.Properties;
/**
* @version $Revision: 1.1 $
@@ -51,6 +59,7 @@
assertEquals("getPort()", 30, config.getPort());
assertEquals("getUsername()", "james", config.getUsername());
}
+
@Override
protected MailEndpoint resolveMandatoryEndpoint(String uri) {
Copied:
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailMessageTest.java
(from r539381,
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java)
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailMessageTest.java?view=diff&rev=540474&p1=activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java&r1=539381&p2=activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailMessageTest.java&r2=540474
==============================================================================
---
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailComponentTest.java
(original)
+++
activemq/camel/trunk/components/camel-mail/src/test/java/org/apache/camel/component/mail/MailMessageTest.java
Tue May 22 01:35:51 2007
@@ -19,37 +19,67 @@
import org.apache.camel.ContextTestSupport;
import org.apache.camel.Endpoint;
+import org.apache.camel.util.ObjectHelper;
+
+import javax.mail.Address;
+import javax.mail.Message;
+import javax.mail.Session;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeMessage;
+import java.util.Properties;
/**
* @version $Revision: 1.1 $
*/
-public class MailComponentTest extends ContextTestSupport {
+public class MailMessageTest extends ContextTestSupport {
+ protected Session mailSession;
+ protected MimeMessage mimeMessage;
+ protected MailEndpoint endpoint;
+ protected String body = "Hello World!";
+
+ public void testMailMessageHandlesMultipleHeaders() throws Exception {
+ mimeMessage.setRecipients(Message.RecipientType.TO, new Address[]{
+ new InternetAddress("[EMAIL PROTECTED]"), new
InternetAddress("[EMAIL PROTECTED]")
+ });
+
+ MailExchange exchange = endpoint.createExchange(mimeMessage);
+ MailMessage in = exchange.getIn();
+ Object header = in.getHeader("TO");
+ String[] values = assertIsInstanceOf(String[].class, header);
+ log.debug("Found values: " + ObjectHelper.asString(values));
+ assertEquals("Size", 2, values.length);
+ assertEquals("values[0]", "[EMAIL PROTECTED]", values[0]);
+ assertEquals("values[1]", "[EMAIL PROTECTED]", values[1]);
- public void testMailEndpointsAreConfiguredProperlyWhenUsingSmtp() throws
Exception {
- MailEndpoint endpoint = resolveMandatoryEndpoint("smtp://[EMAIL
PROTECTED]:30/subject");
- MailConfiguration config = endpoint.getConfiguration();
- assertEquals("getProtocol()", "smtp", config.getProtocol());
- assertEquals("getHost()", "myhost", config.getHost());
- assertEquals("getPort()", 30, config.getPort());
- assertEquals("getUsername()", "james", config.getUsername());
+ assertEquals("body", body, in.getBody());
}
- public void testMailEndpointsAreConfiguredProperlyWhenUsingImap() throws
Exception {
- MailEndpoint endpoint = resolveMandatoryEndpoint("imap://[EMAIL
PROTECTED]:30/subject");
- MailConfiguration config = endpoint.getConfiguration();
- assertEquals("getProtocol()", "imap", config.getProtocol());
- assertEquals("getHost()", "myhost", config.getHost());
- assertEquals("getPort()", 30, config.getPort());
- assertEquals("getUsername()", "james", config.getUsername());
+ public void testMailMessageHandlesSingleHeader() throws Exception {
+ mimeMessage.setRecipients(Message.RecipientType.TO, new Address[]{
+ new InternetAddress("[EMAIL PROTECTED]")
+ });
+
+ MailExchange exchange = endpoint.createExchange(mimeMessage);
+ MailMessage in = exchange.getIn();
+ Object header = in.getHeader("TO");
+ String value = assertIsInstanceOf(String.class, header);
+ assertEquals("value", "[EMAIL PROTECTED]", value);
+
+ assertEquals("body", body, in.getBody());
}
- public void testMailEndpointsAreConfiguredProperlyWhenUsingPop() throws
Exception {
- MailEndpoint endpoint = resolveMandatoryEndpoint("pop3://[EMAIL
PROTECTED]:30/subject");
- MailConfiguration config = endpoint.getConfiguration();
- assertEquals("getProtocol()", "pop3", config.getProtocol());
- assertEquals("getHost()", "myhost", config.getHost());
- assertEquals("getPort()", 30, config.getPort());
- assertEquals("getUsername()", "james", config.getUsername());
+ @Override
+ protected void setUp() throws Exception {
+ super.setUp();
+
+ endpoint = resolveMandatoryEndpoint("pop3://[EMAIL
PROTECTED]:30/subject");
+
+ Properties properties = new Properties();
+ properties.put("mail.smtp.host", "localhost");
+ mailSession = Session.getInstance(properties, null);
+
+ mimeMessage = new MimeMessage(mailSession);
+ mimeMessage.setText(body);
}
@Override
@@ -57,4 +87,4 @@
Endpoint endpoint = super.resolveMandatoryEndpoint(uri);
return assertIsInstanceOf(MailEndpoint.class, endpoint);
}
-}
+}
\ No newline at end of file
