Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit 07c0a38

Browse files
troypaynemarcelmojzis
authored andcommittedNov 17, 2016
Add support for apns-collapse-id header (#9)
1 parent ca235a3 commit 07c0a38

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed
 

‎connector/src/main/scala/reactivehub/akka/stream/apns/ApnsConnectionHandler.scala

+3
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,7 @@ private[apns] object ApnsConnectionHandler {
7272
val HeaderExpiration = "apns-expiration"
7373
val HeaderPriority = "apns-priority"
7474
val HeaderTopic = "apns-topic"
75+
val HeaderCollapseId = "apns-collapse-id"
7576
val HeaderStatus = ":status"
7677
}
7778

@@ -136,6 +137,8 @@ private[apns] final class ApnsConnectionHandler(
136137
}
137138

138139
topic.foreach(topic headers.add(HeaderTopic, topic))
140+
141+
collapseId.foreach(collapseId headers.add(HeaderCollapseId, collapseId))
139142

140143
val headersPromise = ctx.newPromise()
141144
encoder.writeHeaders(ctx, streamId, headers, 0, false, headersPromise)

‎connector/src/main/scala/reactivehub/akka/stream/apns/Notification.scala

+2-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,8 @@ final case class Notification(
1515
id: Option[UUID] = None,
1616
expiration: Option[Expiration] = None,
1717
priority: Option[Priority] = None,
18-
topic: Option[String] = None)
18+
topic: Option[String] = None,
19+
collapseId: Option[String] = None)
1920

2021
object Notification {
2122
def apply(deviceToken: DeviceToken, payload: Payload, id: UUID): Notification =

0 commit comments

Comments
 (0)
Please sign in to comment.