Home
last modified time | relevance | path

Searched refs:client_properties (Results 1 – 25 of 106) sorted by relevance

12345

/dports/net/p5-Net-AMQP-RabbitMQ/Net-AMQP-RabbitMQ-2.40008/t/
H A D029_amqp_properties.t20 my $client_properties = $helper->get_client_properties;
21 ok $client_properties, "get_client_properties";
22 ok exists( $client_properties->{product} ), 'product should be returned';
23 is $client_properties->{'product'}, 'rabbitmq-c', 'product is rabbitmq-c';
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/amqp_client/src/
H A Damqp_connection.erl179 #amqp_params_network{client_properties = Props} = Params) ->
181 client_properties = [
185 #amqp_params_direct{client_properties = Props} = Params) ->
187 client_properties = [
390 [{_, #amqp_params_network{client_properties = Props}}] -> Props;
391 [{_, #amqp_params_direct{client_properties = Props}}] -> Props
H A Damqp_direct_connection.erl36 user, vhost, client_properties, type,
102 i(client_properties, #state{params = P}) ->
103 P#amqp_params_direct.client_properties;
H A Damqp_network_connection.erl279 client_properties = UserProps},
288 client_properties = client_properties(UserProps),
314 client_properties(UserProperties) -> function
/dports/net/rabbiteer/rabbiteer-rs-c881238/cargo-crates/amqp-0.1.1/src/
H A Dsession.rs135 let mut client_properties = Table::new(); in init() localVariable
143 client_properties.insert("capabilities".to_owned(), FieldTable(capabilities)); in init()
144 client_properties.insert("product".to_owned(), LongString("rust-amqp".to_owned())); in init()
145 client_properties.insert("platform".to_owned(), LongString("rust".to_owned())); in init()
146 client_properties.insert("version".to_owned(), LongString(VERSION.to_owned())); in init()
147 client_properties.insert("information".to_owned(), in init()
149 client_properties.extend(options.properties); in init()
153 client_properties: client_properties, in init()
/dports/x11/xpra/xpra-4.3/xpra/server/mixins/
H A Dwindow_server.py179 wprops = self.client_properties.get(wid)
205 self.client_properties.pop(wid, None)
224 wprops = self.client_properties.get(wid, {}).get(ss.uuid)
273 client_properties = packet[5]
276 client_properties = {}
286 wid_windows, options, client_properties)
288 if batch_props or client_properties:
290 self.update_batch_config(proto, wid_windows, typedict(batch_props), client_properties)
298 def update_batch_config(self, proto, wid_windows, batch_props, client_properties): argument
305 self._set_client_properties(proto, wid, window, client_properties)
/dports/net/py-amqplib/amqplib-1.0.2/amqplib/client_0_8/
H A Dconnection.py73 client_properties=None, argument
102 if client_properties:
103 d.update(client_properties)
664 def _x_start_ok(self, client_properties, mechanism, response, locale): argument
715 args.write_table(client_properties)
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/amqp_client/include/
H A Damqp_client.hrl29 client_properties = [],
37 client_properties = []}).
/dports/net/py-amqp/amqp-2.6.1/amqp/
H A Dconnection.py192 virtual_host='/', locale='en_US', client_properties=None, argument
232 self.client_properties = dict(
233 self.library_properties, **client_properties or {}
365 client_properties = self.client_properties
381 cap = client_properties.setdefault('capabilities', {})
390 client_properties.pop('capabilities', None)
408 (client_properties, authentication.mechanism,
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_stream_management/priv/www/js/tmpl/
H A DstreamConnections.ejs23 <th><%= fmt_sort('Name', 'client_properties.connection_name') %></th>
77 <% if(connection.client_properties) { %>
80 <sub><%= fmt_string(short_conn(connection.client_properties.connection_name)) %></sub>
120 <td><%= fmt_client_name(connection.client_properties) %></td>
H A DstreamConnection.ejs18 <% if (connection.client_properties.connection_name) { %>
21 <td><%= fmt_string(connection.client_properties.connection_name) %></td>
132 <% if (properties_size(connection.client_properties) > 0) { %>
136 <%= fmt_table_long(connection.client_properties) %>
/dports/net/py-amqp/amqp-2.6.1/t/integration/
H A Dtest_integration.py224 assert conn.client_properties == CLIENT_PROPERTIES
239 client_properties = dict(CLIENT_PROPERTIES)
240 del client_properties['capabilities']
259 client_properties, 'AMQPLAIN',
281 assert conn.client_properties == client_properties
304 client_properties = dict(CLIENT_PROPERTIES)
305 client_properties['capabilities'] = {
326 client_properties, 'AMQPLAIN',
348 assert conn.client_properties == client_properties
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_management/priv/www/js/tmpl/
H A Dconnections.ejs24 <th><%= fmt_sort('Name', 'client_properties.connection_name') %></th>
84 <% if(connection.client_properties) { %>
87 <sub><%= fmt_string(short_conn(connection.client_properties.connection_name)) %></sub>
133 <td><%= fmt_client_name(connection.client_properties) %></td>
H A Dconnection.ejs18 <% if (connection.client_properties.connection_name) { %>
21 <td><%= fmt_string(connection.client_properties.connection_name) %></td>
129 <% if (properties_size(connection.client_properties) > 0) { %>
133 <%= fmt_table_long(connection.client_properties) %>
/dports/x11/xpra/xpra-4.3/xpra/client/
H A Dclient_tray.py115 client_properties = {
122 client_properties["orientation"] = orientation
126 self, force_send_configure, geometry, (sx, sy, sw, sh, client_properties))
127 self._client.send("configure-window", self._id, sx, sy, sw, sh, client_properties)
/dports/net/py-amqp/amqp-2.6.1/t/unit/
H A Dtest_connection.py183 self.conn.client_properties, b'AMQPLAIN',
199 self.conn.client_properties, b'AMQPLAIN',
235 self.conn.client_properties, login_method,
245 cap = self.conn.client_properties['capabilities']
253 cap = self.conn.client_properties['capabilities']
261 cap = self.conn.client_properties['capabilities']
269 assert 'capabilities' not in self.conn.client_properties
/dports/devel/py-pika/pika-1.1.0/pika/
H A Dconnection.py85 self.client_properties = self.DEFAULT_CLIENT_PROPERTIES
200 def client_properties(self): member in Parameters
210 @client_properties.setter
211 def client_properties(self, value): member in Parameters
562 client_properties=_DEFAULT, argument
612 if client_properties is not self._DEFAULT:
613 self.client_properties = client_properties
814 self.client_properties = ast.literal_eval(value)
1528 if self.params.client_properties:
1529 properties.update(self.params.client_properties)
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_stomp/include/
H A Drabbit_stomp.hrl35 client_properties,
/dports/x11/xpra/xpra-4.3/xpra/client/mixins/
H A Dwindow_manager.py743 client_properties = {}
745 client_properties = packet[7]
748 … self.make_new_window(wid, wx, wy, ww, wh, bw, bh, metadata, override_redirect, client_properties)
750 …make_new_window(self, wid, wx, wy, ww, wh, bw, bh, metadata, override_redirect, client_properties): argument
779 metadata, override_redirect, client_properties,
957 client_properties = window._client_properties
988 …w = self.make_new_window(wid, x, y, ww, wh, bw, bh, metadata, override_redirect, client_properties)
1346 …rol_refresh(self, wid, suspend_resume, refresh, quality=100, options=None, client_properties=None): argument
1349 client_properties = client_properties or {}
1362 log("sending buffer refresh: options=%s, client_properties=%s", options, client_properties)
[all …]
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_mqtt/include/
H A Drabbit_mqtt.hrl69 client_properties,
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_mqtt/src/
H A Drabbit_mqtt_processor.erl46 {client_properties,
86 ClientProperties = proplists:get_value(client_properties, AdditionalInfo1, [])
88 AdditionalInfo2 = case lists:keysearch(client_properties, 1, AdditionalInfo1) of
90 lists:keyreplace(client_properties,
93 {client_properties, ClientProperties});
95 [{client_properties, ClientProperties} | AdditionalInfo1]
1081 info(client_properties, PState) -> additional_info(client_properties, PState);
/dports/net/p5-Net-AMQP-RabbitMQ/Net-AMQP-RabbitMQ-2.40008/
H A Damqp_socket.c1232 const amqp_table_t *client_properties, in amqp_login_inner() argument
1352 res = amqp_merge_capabilities(&default_table, client_properties, in amqp_login_inner()
1353 &state->client_properties, channel_pool); in amqp_login_inner()
1358 s.client_properties = state->client_properties; in amqp_login_inner()
1481 int frame_max, int heartbeat, const amqp_table_t *client_properties, in amqp_login_with_properties() argument
1489 client_properties, state->handshake_timeout, in amqp_login_with_properties()
/dports/net/rabbitmq-c/rabbitmq-c-0.11.0/librabbitmq/
H A Damqp_socket.c1235 const amqp_table_t *client_properties, in amqp_login_inner() argument
1355 res = amqp_merge_capabilities(&default_table, client_properties, in amqp_login_inner()
1356 &state->client_properties, channel_pool); in amqp_login_inner()
1361 s.client_properties = state->client_properties; in amqp_login_inner()
1484 int frame_max, int heartbeat, const amqp_table_t *client_properties, in amqp_login_with_properties() argument
1492 client_properties, state->handshake_timeout, in amqp_login_with_properties()
/dports/net/rabbitmq-c-devel/rabbitmq-c-0.10.0/librabbitmq/
H A Damqp_socket.c1231 int frame_max, int heartbeat, const amqp_table_t *client_properties, in amqp_login_inner() argument
1349 res = amqp_merge_capabilities(&default_table, client_properties, in amqp_login_inner()
1350 &state->client_properties, channel_pool); in amqp_login_inner()
1355 s.client_properties = state->client_properties; in amqp_login_inner()
1478 int frame_max, int heartbeat, const amqp_table_t *client_properties, in amqp_login_with_properties() argument
1486 client_properties, state->handshake_timeout, in amqp_login_with_properties()
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_stream_common/include/
H A Drabbit_stream.hrl85 client_properties,

12345