java-apns service

apns.scala

  private val service = {
    val baseBuilder =
      APNS.newService().asPool(maxConnections).
        asBatched(batchWaitTimeInSec, maxBatchWaitTimeInSec).
        withCert(getClass.getResourceAsStream(certPath), certPassword).
        withDelegate(new ApnsDelegate {
          override def connectionClosed(e: DeliveryError, messageId: Int) {
            logger.error(s"ConnectionClosed MessageID: $messageId Error: $e")
          }
          override def cacheLengthExceeded(newCacheLength: Int) {
            logger.info(s"Cache length exceeded, newCacheLength: $newCacheLength")
          }
          override def notificationsResent(resendCount: Int) {
            logger.info(s"Message resent, resend count: $resendCount")
          }
          override def messageSendFailed(msg: ApnsNotification, e: Throwable) {
            logger.error(s"MessageSendFailed Msg: $msg Exception: $e")
          }
          override def messageSent(msg: ApnsNotification, resent: Boolean) {
            logger.info(s"MessageSent Msg: $msg, Resent: $resent")
          }
        })
    environment match {
      case ApnsProduction => baseBuilder.withProductionDestination()
      case ApnsSandbox    => baseBuilder.withSandboxDestination()
    }
  }.build