Skip to content

Added a stop_rule_set callback after a successful message processing. #102

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
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Added a stop_rule_set callback after a successful message processing. #102

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
5 changes: 4 additions & 1 deletion README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,10 @@ Otherwise, you can use an existing one.
object key prefix. Leave Encrypt Message unchecked and SNS Topic set to [none].

- For the Lambda action: Choose the SesForwarder Lambda function. Leave
Invocation Type set to Event and SNS Topic set to [none].
Invocation Type set to Event and SNS Topic set to [RequestResponse].

- Set the SNS topic for the Stop Action to a topic that will handle any emails
that fail to process. The SNS topic can be subscribed to by an email address.

- Finish by naming the rule, ensuring it's enabled and that spam and virus
checking are used.
Expand Down
3 changes: 2 additions & 1 deletion index.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -312,7 +312,8 @@ exports.handler = function(event, context, callback, overrides) {
Promise.series(steps, data)
.then(function(data) {
data.log({level: "info", message: "Process finished successfully."});
return data.callback();
// Success: Let SES know to stop the rule set processing.
callback(null, { disposition: 'stop_rule_set', });
})
.catch(function(err) {
data.log({level: "error", message: "Step returned error: " + err.message,
Expand Down