Home
last modified time | relevance | path

Searched refs:amqp_params_direct (Results 1 – 14 of 14) sorted by relevance

/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/amqp_client/src/
H A Damqp_connection.erl157 #amqp_params_direct{password = Password} ->
158 AmqpParams#amqp_params_direct{password = credentials_obfuscation:encrypt(Password)};
185 #amqp_params_direct{client_properties = Props} = Params) ->
186 Params#amqp_params_direct{
391 [{_, #amqp_params_direct{client_properties = Props}}] -> Props
400 ensure_safe_call_timeout(#amqp_params_direct{}, CallTimeout) ->
H A Damqp_uri.erl59 {ok, #amqp_params_direct{}} |
124 #amqp_params_direct{virtual_host = VHost};
145 set(KVs, Ps = #amqp_params_direct{}) ->
146 set(KVs, Ps, record_info(fields, amqp_params_direct));
188 broker_add_query(Params = #amqp_params_direct{}, Uri) ->
189 broker_add_query(Params, Uri, record_info(fields, amqp_params_direct));
H A Damqp_direct_connection.erl99 i(user, #state{params = P}) -> P#amqp_params_direct.username;
101 i(vhost, #state{params = P}) -> P#amqp_params_direct.virtual_host;
103 P#amqp_params_direct.client_properties;
131 connect(Params = #amqp_params_direct{username = Username,
H A Damqp_connection_type_sup.erl26 type_module(#amqp_params_direct{}) -> {direct, amqp_direct_connection};
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_federation/src/
H A Drabbit_federation_util.erl61 vhost(#amqp_params_direct{virtual_host = VHost}) -> VHost;
84 obfuscate_upstream_params(#upstream_params{uri = Uri, params = #amqp_params_direct{password = Passw…
87 …params = Params#amqp_params_direct{password = credentials_obfuscation:encrypt(rabbit_data_coercion…
98 deobfuscate_upstream_params(#upstream_params{uri = EncryptedUri, params = #amqp_params_direct{passw…
101 … params = Params#amqp_params_direct{password = credentials_obfuscation:decrypt(EncryptedPassword)}
H A Drabbit_federation_link_util.erl38 case open_monitor(#amqp_params_direct{virtual_host = DownVHost}, ConnName) of
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/amqp_client/include/
H A Damqp_client.hrl32 -record(amqp_params_direct, {username = none, record
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_shovel/src/
H A Drabbit_shovel_parameters.erl198 validate_params_user(#amqp_params_direct{}, none) ->
200 validate_params_user(#amqp_params_direct{virtual_host = VHost},
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_tracing/src/
H A Drabbit_tracing_consumer.erl53 #amqp_params_direct{virtual_host = VHost,
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_amqp1_0/src/
H A Drabbit_amqp1_0_session_process.erl44 #amqp_params_direct{username = Username,
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_stomp/src/
H A Drabbit_stomp_processor.erl587 #amqp_params_direct{username = Username,
731 #amqp_params_direct{virtual_host = VHost} = AmqpParams,
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_mqtt/src/
H A Drabbit_mqtt_processor.erl596 case amqp_connection:start(#amqp_params_direct{
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_management/src/
H A Drabbit_mgmt_util.erl965 Params = #amqp_params_direct{username = Username,
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/
H A Drabbit_channel.erl1079 extract_variable_map_from_amqp_params({amqp_params, {amqp_params_direct, _, _, _, _,
1082 extract_variable_map_from_amqp_params({amqp_params_direct, _, _, _, _,