|
@@ -72,14 +72,7 @@ fields(config) ->
|
|
|
desc => ?DESC("username")
|
|
desc => ?DESC("username")
|
|
|
}
|
|
}
|
|
|
)},
|
|
)},
|
|
|
- {password,
|
|
|
|
|
- hoconsc:mk(
|
|
|
|
|
- typerefl:binary(),
|
|
|
|
|
- #{
|
|
|
|
|
- required => true,
|
|
|
|
|
- desc => ?DESC("password")
|
|
|
|
|
- }
|
|
|
|
|
- )},
|
|
|
|
|
|
|
+ {password, fun emqx_connector_schema_lib:password/1},
|
|
|
{pool_size,
|
|
{pool_size,
|
|
|
hoconsc:mk(
|
|
hoconsc:mk(
|
|
|
typerefl:pos_integer(),
|
|
typerefl:pos_integer(),
|
|
@@ -129,14 +122,6 @@ fields(config) ->
|
|
|
desc => ?DESC("heartbeat")
|
|
desc => ?DESC("heartbeat")
|
|
|
}
|
|
}
|
|
|
)},
|
|
)},
|
|
|
- {auto_reconnect,
|
|
|
|
|
- hoconsc:mk(
|
|
|
|
|
- emqx_schema:duration_ms(),
|
|
|
|
|
- #{
|
|
|
|
|
- default => <<"2s">>,
|
|
|
|
|
- desc => ?DESC("auto_reconnect")
|
|
|
|
|
- }
|
|
|
|
|
- )},
|
|
|
|
|
%% Things related to sending messages to RabbitMQ
|
|
%% Things related to sending messages to RabbitMQ
|
|
|
{exchange,
|
|
{exchange,
|
|
|
hoconsc:mk(
|
|
hoconsc:mk(
|