Author: cmueller
Date: Mon Dec 19 17:17:50 2011
New Revision: 1220853
URL: http://svn.apache.org/viewvc?rev=1220853&view=rev
Log:
CAMEL-3591: Add Simple Email Service SES to camel-aws
Modified:
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesConfiguration.java
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java
camel/trunk/components/camel-aws/src/test/java/org/apache/camel/component/aws/ses/SesComponentConfigurationTest.java
Modified:
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesConfiguration.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesConfiguration.java?rev=1220853&r1=1220852&r2=1220853&view=diff
==============================================================================
---
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesConfiguration.java
(original)
+++
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesConfiguration.java
Mon Dec 19 17:17:50 2011
@@ -30,6 +30,7 @@ public class SesConfiguration {
private AmazonSimpleEmailService amazonSESClient;
private String accessKey;
private String secretKey;
+ private String amazonSESEndpoint;
private String subject;
private String from;
private List<String> to;
@@ -107,6 +108,14 @@ public class SesConfiguration {
public void setReplyToAddresses(String replyToAddresses) {
this.replyToAddresses = Arrays.asList(replyToAddresses.split(","));
}
+
+ public String getAmazonSESEndpoint() {
+ return amazonSESEndpoint;
+ }
+
+ public void setAmazonSESEndpoint(String amazonSesEndpoint) {
+ this.amazonSESEndpoint = amazonSesEndpoint;
+ }
@Override
public String toString() {
@@ -114,6 +123,7 @@ public class SesConfiguration {
+ "accessKey='" + accessKey + '\''
+ ", amazonSESClient=" + amazonSESClient
+ ", secretKey=xxxxxxxxxxxxxxx"
+ + ", amazonSesEndpoint='" + amazonSESEndpoint + '\''
+ ", subject='" + subject + '\''
+ ", from='" + from + '\''
+ ", to='" + to + '\''
Modified:
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java?rev=1220853&r1=1220852&r2=1220853&view=diff
==============================================================================
---
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java
(original)
+++
camel/trunk/components/camel-aws/src/main/java/org/apache/camel/component/aws/ses/SesEndpoint.java
Mon Dec 19 17:17:50 2011
@@ -64,6 +64,9 @@ public class SesEndpoint extends Default
private AmazonSimpleEmailService createSESClient() {
AWSCredentials credentials = new
BasicAWSCredentials(configuration.getAccessKey(), configuration.getSecretKey());
AmazonSimpleEmailService client = new
AmazonSimpleEmailServiceClient(credentials);
+ if (configuration.getAmazonSESEndpoint() != null) {
+ client.setEndpoint(configuration.getAmazonSESEndpoint());
+ }
configuration.setAmazonSESClient(client);
return client;
}
Modified:
camel/trunk/components/camel-aws/src/test/java/org/apache/camel/component/aws/ses/SesComponentConfigurationTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-aws/src/test/java/org/apache/camel/component/aws/ses/SesComponentConfigurationTest.java?rev=1220853&r1=1220852&r2=1220853&view=diff
==============================================================================
---
camel/trunk/components/camel-aws/src/test/java/org/apache/camel/component/aws/ses/SesComponentConfigurationTest.java
(original)
+++
camel/trunk/components/camel-aws/src/test/java/org/apache/camel/component/aws/ses/SesComponentConfigurationTest.java
Mon Dec 19 17:17:50 2011
@@ -31,6 +31,7 @@ public class SesComponentConfigurationTe
assertEquals("[email protected]",
endpoint.getConfiguration().getFrom());
assertEquals("xxx", endpoint.getConfiguration().getAccessKey());
assertEquals("yyy", endpoint.getConfiguration().getSecretKey());
+ assertNull(endpoint.getConfiguration().getAmazonSESEndpoint());
assertNull(endpoint.getConfiguration().getAmazonSESClient());
assertNull(endpoint.getConfiguration().getTo());
assertNull(endpoint.getConfiguration().getSubject());
@@ -52,6 +53,7 @@ public class SesComponentConfigurationTe
assertEquals("[email protected]",
endpoint.getConfiguration().getFrom());
assertNull(endpoint.getConfiguration().getAccessKey());
assertNull(endpoint.getConfiguration().getSecretKey());
+ assertNull(endpoint.getConfiguration().getAmazonSESEndpoint());
assertSame(mock, endpoint.getConfiguration().getAmazonSESClient());
assertNull(endpoint.getConfiguration().getTo());
assertNull(endpoint.getConfiguration().getSubject());
@@ -63,12 +65,13 @@ public class SesComponentConfigurationTe
public void createEndpointWithMaximalConfiguration() throws Exception {
SesComponent component = new SesComponent(context);
SesEndpoint endpoint = (SesEndpoint)
component.createEndpoint("aws-ses://[email protected]?accessKey=xxx"
- +
"&secretKey=yyy&[email protected],[email protected]&subject=Subject&[email protected]"
- + "&[email protected],[email protected]");
+ +
"&secretKey=yyy&[email protected],[email protected]&amazonSESEndpoint=us-east-1&subject=Subject"
+ +
"&[email protected]&[email protected],[email protected]");
assertEquals("[email protected]",
endpoint.getConfiguration().getFrom());
assertEquals("xxx", endpoint.getConfiguration().getAccessKey());
assertEquals("yyy", endpoint.getConfiguration().getSecretKey());
+ assertEquals("us-east-1",
endpoint.getConfiguration().getAmazonSESEndpoint());
assertNull(endpoint.getConfiguration().getAmazonSESClient());
assertEquals(2, endpoint.getConfiguration().getTo().size());
assertTrue(endpoint.getConfiguration().getTo().contains("[email protected]"));
