Google Cloud Pub/Sub Integration

akashsethiya · March 18, 2019, 7:01pm

I want to integrate google cloud pub/sub into my app which will basically keep pulling messages from the pub/sub queue and spawn a new process for its processing and acknowledge the message.

I found a sample here on the below link, but am not so clear about how to start this subscriber with the start of the app or should i use worker

github.com

GoogleCloudPlatform/elixir-samples/blob/master/pubsub/lib/pubsub_samples_subscriber.ex

defmodule GoogleApi.PubSub.Samples.Subscriber do
  use Task
  @moduledoc """
  Subscriber sample for GoogleApi.PubSub
  """

  # def init(state), do: {:ok, state}

  def start_link(project_id, subscription_name) do
    task = Task.async(GoogleApi.PubSub.Samples.Subscriber, :listen, [project_id, subscription_name])
    {:ok, task.pid}
  end

  @doc """
  Publish a message to a PubSub topic.

  ## Examples

      iex> GoogleApi.PubSub.Samples.publish("YOUR_PROJECT_ID", "test-topic", "This is a message")
      "published message 159505488737289"

This file has been truncated. show original

mbuhot · March 18, 2019, 10:14pm

Since the Subscriber is a Task, you can add it to your applications existing supervision tree.

The Task docs has an example.