| /dports/devel/py-pika/pika-1.1.0/pika/ |
| H A D | channel.py | 1016 def _on_cancel(self, method_frame): argument
1029 def _on_cancelok(self, method_frame): argument
1059 def _on_close_from_broker(self, method_frame): argument
1112 def _on_closeok(self, method_frame): argument
1147 def _on_eventok(self, method_frame): argument
1166 def _on_flowok(self, method_frame): argument
1179 def _on_getempty(self, method_frame): argument
1189 def _on_getok(self, method_frame, header_frame, body): argument
1204 def _on_openok(self, method_frame): argument
1226 def _on_return(self, method_frame, header_frame, body): argument
[all …]
|
| H A D | connection.py | 1614 def _get_credentials(self, method_frame): argument
1734 def _on_connection_blocked(self, _connection, method_frame): argument
1753 def _on_connection_unblocked(self, _connection, method_frame): argument
1770 def _on_connection_close_from_broker(self, method_frame): argument
1783 def _on_connection_close_ok(self, method_frame): argument
1802 def _on_connection_open_ok(self, method_frame): argument
1818 def _on_connection_start(self, method_frame): argument
1893 def _on_connection_tune(self, method_frame): argument
2236 def _send_message(self, channel_number, method_frame, content): argument
2279 def _set_server_information(self, method_frame): argument
|
| /dports/devel/py-pika/pika-1.1.0/examples/ |
| H A D | consume.py | 13 def on_message(chan, method_frame, _header_frame, body, userdata=None): argument
|
| H A D | direct_reply_to.py | 58 def on_server_rx_rpc_request(ch, method_frame, properties, body): argument
|
| H A D | blocking_consume_recover_multiple_hosts.py | 9 def on_message(ch, method_frame, _header_frame, body, userdata=None): argument
|
| H A D | basic_consumer_threaded.py | 39 def on_message(ch, method_frame, _header_frame, body, args): argument
|
| H A D | asynchronous_publisher_example.py | 243 def on_delivery_confirmation(self, method_frame): argument
|
| H A D | asyncio_consumer_example.py | 292 def on_consumer_cancelled(self, method_frame): argument
|
| H A D | asynchronous_consumer_example.py | 288 def on_consumer_cancelled(self, method_frame): argument
|
| /dports/net/py-rabbitpy/rabbitpy-1.0.0/rabbitpy/ |
| H A D | channel.py | 322 def _create_message(self, method_frame, header_frame, body): argument
392 def _reject_inbound_message(self, method_frame): argument
448 def _wait_for_content_frames(self, method_frame): argument
|
| H A D | connection.py | 354 def _create_message(self, channel_id, method_frame, header_frame, body): argument
|
| /dports/devel/py-mypy/mypy-0.910/mypy/ |
| H A D | tvar_scope.py | 50 def method_frame(self) -> 'TypeVarLikeScope': member in TypeVarLikeScope
|
| /dports/devel/py-pika/pika-1.1.0/pika/adapters/ |
| H A D | blocking_connection.py | 235 def __init__(self, callback, method_frame): argument
589 def _on_connection_blocked(self, user_callback, _impl, method_frame): argument
601 def _on_connection_unblocked(self, user_callback, _impl, method_frame): argument
979 def __init__(self, method_frame): argument
1411 def _on_consumer_cancelled_by_broker(self, method_frame): argument
|
| H A D | twisted_connection.py | 145 def _on_consumer_cancelled_by_broker(self, method_frame): argument
691 def _on_delivery_confirmation(self, method_frame): argument
|
| /dports/net/rabbiteer/rabbiteer-rs-c881238/cargo-crates/amqp-0.1.1/src/ |
| H A D | channel.rs | 115 let method_frame = try!(self.raw_rpc(method)); in rpc() localVariable
253 let method_frame = try!(MethodFrame::decode(&frame)); in try_consume() localVariable
|
| H A D | basic.rs | 79 let method_frame = match method_frame_result { in next() localVariable
|
| H A D | session.rs | 119 let method_frame = try!(MethodFrame::decode(&frame)); in init() localVariable
|
| /dports/www/nginx-full/njs-0.7.1/src/ |
| H A D | njs_vmcode.c | 109 njs_vmcode_method_frame_t *method_frame; in njs_vmcode_interpreter() local
|