/dports/net/p5-Net-AMQP-RabbitMQ/Net-AMQP-RabbitMQ-2.40008/t/ |
H A D | 029_amqp_properties.t | 20 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 D | amqp_connection.erl | 179 #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 D | amqp_direct_connection.erl | 36 user, vhost, client_properties, type, 102 i(client_properties, #state{params = P}) -> 103 P#amqp_params_direct.client_properties;
|
H A D | amqp_network_connection.erl | 279 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 D | session.rs | 135 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 D | window_server.py | 179 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 D | connection.py | 73 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 D | amqp_client.hrl | 29 client_properties = [], 37 client_properties = []}).
|
/dports/net/py-amqp/amqp-2.6.1/amqp/ |
H A D | connection.py | 192 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 D | streamConnections.ejs | 23 <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 D | streamConnection.ejs | 18 <% 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 D | test_integration.py | 224 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 D | connections.ejs | 24 <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 D | connection.ejs | 18 <% 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 D | client_tray.py | 115 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 D | test_connection.py | 183 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 D | connection.py | 85 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 D | rabbit_stomp.hrl | 35 client_properties,
|
/dports/x11/xpra/xpra-4.3/xpra/client/mixins/ |
H A D | window_manager.py | 743 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 D | rabbit_mqtt.hrl | 69 client_properties,
|
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbitmq_mqtt/src/ |
H A D | rabbit_mqtt_processor.erl | 46 {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 D | amqp_socket.c | 1232 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 D | amqp_socket.c | 1235 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 D | amqp_socket.c | 1231 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 D | rabbit_stream.hrl | 85 client_properties,
|