Repository: incubator-usergrid Updated Branches: refs/heads/two-dot-o-dev 1ff4774a3 -> 4f9650b93
Fix dead-letter queue attributes. Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/4e332314 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/4e332314 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/4e332314 Branch: refs/heads/two-dot-o-dev Commit: 4e332314b72c6a59b39f121ca6d9e510b4797964 Parents: 93fb85a Author: Mike Dunker <mikedun...@calbears.net> Authored: Wed Aug 12 14:30:54 2015 -0700 Committer: Mike Dunker <mikedun...@calbears.net> Committed: Wed Aug 12 14:30:54 2015 -0700 ---------------------------------------------------------------------- .../usergrid/persistence/queue/util/AmazonNotificationUtils.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/4e332314/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/util/AmazonNotificationUtils.java ---------------------------------------------------------------------- diff --git a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/util/AmazonNotificationUtils.java b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/util/AmazonNotificationUtils.java index 9561a58..c321715 100644 --- a/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/util/AmazonNotificationUtils.java +++ b/stack/corepersistence/queue/src/main/java/org/apache/usergrid/persistence/queue/util/AmazonNotificationUtils.java @@ -62,8 +62,8 @@ public class AmazonNotificationUtils { deadletterArn ); final Map<String, String> queueAttributes = new HashMap<>( 2 ); - deadLetterAttributes.put( "MessageRetentionPeriod", fig.getRetentionPeriod() ); - deadLetterAttributes.put( "RedrivePolicy", redrivePolicy ); + queueAttributes.put( "MessageRetentionPeriod", fig.getRetentionPeriod() ); + queueAttributes.put( "RedrivePolicy", redrivePolicy ); CreateQueueRequest createQueueRequest = new CreateQueueRequest(). withQueueName( queueName )
