init(Options) ->
ConnectOptions = hope_kv_list:get(Options, connect_options , []),
ConsumptionInterval = hope_kv_list:get(Options, consumption_interval, 60000),
init(Options) ->
ConnectOptions = hope_kv_list:get(Options, connect_options , []),
ConsumptionInterval = hope_kv_list:get(Options, consumption_interval, 60000),