From 61bed37d410c1c241e63c00aa9400717312699fa Mon Sep 17 00:00:00 2001 From: Ivy Rogatko Date: Wed, 4 Dec 2019 11:42:11 -0800 Subject: [PATCH] allow GenServer options to be passed-in for producer --- lib/nsq/producer.ex | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/nsq/producer.ex b/lib/nsq/producer.ex index ae5a881..bfcf429 100644 --- a/lib/nsq/producer.ex +++ b/lib/nsq/producer.ex @@ -143,13 +143,13 @@ defmodule NSQ.Producer do # ------------------------------------------------------- # # API Definitions # # ------------------------------------------------------- # - @spec start_link(binary, NSQ.Config.t) :: {:ok, pid} - def start_link(topic, config) do + @spec start_link(binary, NSQ.Config.t, GenServer.options) :: {:ok, pid} + def start_link(topic, config, genserver_options \\ []) do {:ok, config} = NSQ.Config.validate(config || %NSQ.Config{}) {:ok, config} = NSQ.Config.normalize(config) unless is_valid_topic_name?(topic), do: raise "Invalid topic name #{topic}" state = %{@initial_state | topic: topic, config: config} - GenServer.start_link(__MODULE__, state) + GenServer.start_link(__MODULE__, state, genserver_options) end