Repository: camel Updated Branches: refs/heads/camel-2.14.x 524a5b317 -> 849f6d12c
CAMEL-8240 support to setup the in the expiration time for the push message from message header in camel-apns Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/849f6d12 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/849f6d12 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/849f6d12 Branch: refs/heads/camel-2.14.x Commit: 849f6d12c15909fe13eb11b3db22d5dd6137a8a7 Parents: 524a5b3 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Thu Jan 15 12:53:12 2015 +0800 Committer: Claus Ibsen <davscl...@apache.org> Committed: Sat Jan 17 12:10:09 2015 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/apns/ApnsProducer.java | 9 +++++++-- .../apache/camel/component/apns/model/ApnsConstants.java | 1 + 2 files changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/849f6d12/components/camel-apns/src/main/java/org/apache/camel/component/apns/ApnsProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-apns/src/main/java/org/apache/camel/component/apns/ApnsProducer.java b/components/camel-apns/src/main/java/org/apache/camel/component/apns/ApnsProducer.java index 1ea91b0..76f6a49 100644 --- a/components/camel-apns/src/main/java/org/apache/camel/component/apns/ApnsProducer.java +++ b/components/camel-apns/src/main/java/org/apache/camel/component/apns/ApnsProducer.java @@ -19,6 +19,7 @@ package org.apache.camel.component.apns; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; +import java.util.Date; import java.util.List; import com.notnoop.apns.APNS; @@ -84,8 +85,12 @@ public class ApnsProducer extends DefaultProducer { } else { payload = message; } - - getEndpoint().getApnsService().push(tokens, payload); + Date expiry = exchange.getIn().getHeader(ApnsConstants.HEADER_EXPIRY, Date.class); + if (expiry != null) { + getEndpoint().getApnsService().push(tokens, payload, expiry); + } else { + getEndpoint().getApnsService().push(tokens, payload); + } } public String getHeaderTokens(Exchange exchange) { http://git-wip-us.apache.org/repos/asf/camel/blob/849f6d12/components/camel-apns/src/main/java/org/apache/camel/component/apns/model/ApnsConstants.java ---------------------------------------------------------------------- diff --git a/components/camel-apns/src/main/java/org/apache/camel/component/apns/model/ApnsConstants.java b/components/camel-apns/src/main/java/org/apache/camel/component/apns/model/ApnsConstants.java index 1d1ca8d..120d99b 100644 --- a/components/camel-apns/src/main/java/org/apache/camel/component/apns/model/ApnsConstants.java +++ b/components/camel-apns/src/main/java/org/apache/camel/component/apns/model/ApnsConstants.java @@ -20,6 +20,7 @@ public final class ApnsConstants { public static final String HEADER_TOKENS = "CamelApnsTokens"; public static final String HEADER_MESSAGE_TYPE = "CamelApnsMessageType"; + public static final String HEADER_EXPIRY = "CamelApnsExpiry"; private ApnsConstants() { }
