PubSubSubscriptionExample.kt

override fun init(config: ServletConfig) {

    ThreadManager.createThreadForCurrentRequest {
      val moduleService = ModulesServiceFactory.getModulesService()
      val module = moduleService.currentModule

      val versionHostname = moduleService.getVersionHostname(module, moduleService.getDefaultVersion(module))
      val sp = versionHostname.split(".")

      val moduleName = sp[1]
      val appName = sp[2]

      val targetUrl = "https://$module-dot-$appName.appspot.com/_ah/push-handlers/receive_message"
      val pubSubService = GaePubSubService(appName)

      pubSubService.createPushSubscription("emails", "email-service", targetUrl)

      println("version hostname: https://$moduleName-dot-$appName.appspot.com")

    }.start()
  }