fixes #2, better s3 key decoding

sherzberg · Aug 16, 2017 · bd9f271 · bd9f271
1 parent 668cd7a
commit bd9f271
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pom.xml b/pom.xml
@@ -15,7 +15,7 @@
 
     <groupId>org.sherzberg.graylog.plugins</groupId>
     <artifactId>graylog-plugin-s3</artifactId>
-    <version>2.3.0-SNAPSHOT</version>
+    <version>2.3.0-1-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <name>${project.artifactId}</name>

diff --git a/src/main/java/org/sherzberg/graylog/aws/inputs/s3/notifications/S3SNSNotificationParser.java b/src/main/java/org/sherzberg/graylog/aws/inputs/s3/notifications/S3SNSNotificationParser.java
@@ -35,7 +35,7 @@ public List<S3SNSNotification> parse(Message message) {
             notifications.addAll(s3EventNotification.getRecords().stream().map(record -> new S3SNSNotification(
                     message.getReceiptHandle(),
                     record.getS3().getBucket().getName(),
-                    record.getS3().getObject().getKey()
+                    record.getS3().getObject().getUrlDecodedKey()
             )).collect(Collectors.toList()));
         } catch (Exception e) {
             LOG.error("Could not parse SNS notification: " + message.getBody(), e);