lupapiste-pubsub.subscriber-util — fi.lupapiste/pubsub-client 2.5.3

build-receiver clj

(build-receiver handler)

build-subscriber clj

(build-subscriber {:keys [project-id topic-admin subscription-admin
                          channel-provider credentials-provider thread-count
                          ack-deadline-seconds enable-exactly-once-delivery?
                          max-elements-per-thread]}
                  topic-name
                  handler)

delete-subscription clj

(delete-subscription {:keys [project-id subscription-admin]} topic-name)

setup-subscription clj

(setup-subscription client
                    subscription-name
                    topic
                    ack-deadline-seconds
                    enable-exactly-once-delivery?)

stop-subscriber clj

(stop-subscriber sub)