From d3ea1075e469ef289a49e43d5d0f61219476e667 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Sat, 4 Jan 2020 17:49:36 +0100
Subject: [PATCH] moved compile_definitions into a separate package
---
.codeclimate.yml | 2 +-
.coveragerc | 2 +-
.travis.yml | 2 +-
CHANGELOG.md | 1 +
README.md | 2 +-
compile_definitions/__init__.py | 0
.../__main__.py | 10 +-
.../xml_fields.py | 2 +-
.../xml_tags.py | 8 +-
coolamqp/framing/compilation/__init__.py | 2 +
coolamqp/framing/compilation/utilities.py | 6 -
coolamqp/framing/definitions.py | 356 +++++++++---------
12 files changed, 195 insertions(+), 198 deletions(-)
create mode 100644 compile_definitions/__init__.py
rename compile_definitions.py => compile_definitions/__main__.py (98%)
rename {coolamqp/framing/compilation => compile_definitions}/xml_fields.py (99%)
rename {coolamqp/framing/compilation => compile_definitions}/xml_tags.py (98%)
diff --git a/.codeclimate.yml b/.codeclimate.yml
index 4cff32f..3c66ca9 100644
--- a/.codeclimate.yml
+++ b/.codeclimate.yml
@@ -17,7 +17,7 @@ exclude_paths:
- examples/**
- tests/**
- coolamqp/framing/definitions.py
-- compile_definitions.py
+- compile_definitions/**
- stress_tests/**
ratings:
paths:
diff --git a/.coveragerc b/.coveragerc
index 6fd5d12..e07fda6 100644
--- a/.coveragerc
+++ b/.coveragerc
@@ -5,5 +5,5 @@ include=
omit=
tests/*
stress_tests/*
- compile_definitions.py
coolamqp/framing/definitions.py
+ compile_definitions/*
diff --git a/.travis.yml b/.travis.yml
index b4acabc..3d1da60 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -7,7 +7,7 @@ python:
- "pypy"
- "pypy3.5"
script:
- - python compile_definitions.py
+ - python -m compile_definitions
- python setup.py nosetests --tests tests
- python -m stress_tests
install:
diff --git a/CHANGELOG.md b/CHANGELOG.md
index a43e4e8..4b379fe 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -2,6 +2,7 @@
* bugfix: a race condition during connection setup itself
* moved __version__ to coolamqp root
+* split `compile_definitions` into a separate package
# v0.100:
diff --git a/README.md b/README.md
index 42ff444..275b44c 100644
--- a/README.md
+++ b/README.md
@@ -61,7 +61,7 @@ From there stems the copyright holder name change.
Make sure that you have `yapf` installed, then perform:
```python
-python compile_definitions.py
+python -m compile_definitions
```
and you're all set. The only files modified is
[definitions.py](coolamqp/framing/definitions.py).
\ No newline at end of file
diff --git a/compile_definitions/__init__.py b/compile_definitions/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/compile_definitions.py b/compile_definitions/__main__.py
similarity index 98%
rename from compile_definitions.py
rename to compile_definitions/__main__.py
index 2c87e22..0326730 100644
--- a/compile_definitions.py
+++ b/compile_definitions/__main__.py
@@ -8,11 +8,9 @@ from xml.etree import ElementTree
import math
import six
-from coolamqp.framing.compilation.utilities import Constant, Class, \
- Domain, \
- name_class, format_method_class_name, format_field_name, ffmt, to_docstring, \
- pythonify_name, to_code_binary, \
- frepr, get_size
+from coolamqp.framing.compilation.utilities import name_class, format_method_class_name, \
+ format_field_name, ffmt, to_docstring, pythonify_name, to_code_binary, frepr, get_size
+from .xml_tags import Constant, Class, Domain
TYPE_TRANSLATOR = {
'shortstr': 'binary type (max length 255)',
@@ -67,7 +65,7 @@ import typing as tp
from coolamqp.framing.base import AMQPClass, AMQPMethodPayload, AMQPContentPropertyList
from coolamqp.framing.field_table import enframe_table, deframe_table, frame_table_size
-from coolamqp.framing.compilation.content_property import compile_particular_content_property_list_class
+from coolamqp.framing.compilation import compile_particular_content_property_list_class
logger = logging.getLogger(__name__)
diff --git a/coolamqp/framing/compilation/xml_fields.py b/compile_definitions/xml_fields.py
similarity index 99%
rename from coolamqp/framing/compilation/xml_fields.py
rename to compile_definitions/xml_fields.py
index 2ef977d..12a5fc3 100644
--- a/coolamqp/framing/compilation/xml_fields.py
+++ b/compile_definitions/xml_fields.py
@@ -1,7 +1,7 @@
# coding=UTF-8
from __future__ import print_function, absolute_import, division
+
import six
-import logging
class _Required(object):
diff --git a/coolamqp/framing/compilation/xml_tags.py b/compile_definitions/xml_tags.py
similarity index 98%
rename from coolamqp/framing/compilation/xml_tags.py
rename to compile_definitions/xml_tags.py
index 9dde0e4..00a28af 100644
--- a/coolamqp/framing/compilation/xml_tags.py
+++ b/compile_definitions/xml_tags.py
@@ -1,11 +1,13 @@
# coding=UTF-8
from __future__ import print_function, absolute_import, division
-import six
-import logging
+
import copy
+import logging
+
import math
+
+from compile_definitions.xml_fields import *
from coolamqp.framing.base import BASIC_TYPES, DYNAMIC_BASIC_TYPES
-from .xml_fields import *
logger = logging.getLogger(__name__)
diff --git a/coolamqp/framing/compilation/__init__.py b/coolamqp/framing/compilation/__init__.py
index 665f5dd..a11a0aa 100644
--- a/coolamqp/framing/compilation/__init__.py
+++ b/coolamqp/framing/compilation/__init__.py
@@ -5,3 +5,5 @@ from __future__ import absolute_import, division, print_function
- Compile XML to definitions.py
- Dynamically compile classes from property_flags
"""
+
+from .content_property import compile_particular_content_property_list_class
diff --git a/coolamqp/framing/compilation/utilities.py b/coolamqp/framing/compilation/utilities.py
index c450b2c..a941ff7 100644
--- a/coolamqp/framing/compilation/utilities.py
+++ b/coolamqp/framing/compilation/utilities.py
@@ -2,19 +2,13 @@
from __future__ import absolute_import, division, print_function
import math
-
import six
from coolamqp.framing.base import BASIC_TYPES
-from .xml_tags import *
-
# docs may be None
-
-
-
def get_size(fields): # assume all fields have static length
"""Assuming all fields have static length, return their length together. Supports bits"""
size = 0
diff --git a/coolamqp/framing/definitions.py b/coolamqp/framing/definitions.py
index 48bc4c6..cb5911b 100644
--- a/coolamqp/framing/definitions.py
+++ b/coolamqp/framing/definitions.py
@@ -31,7 +31,7 @@ import typing as tp
from coolamqp.framing.base import AMQPClass, AMQPMethodPayload, AMQPContentPropertyList
from coolamqp.framing.field_table import enframe_table, deframe_table, frame_table_size
-from coolamqp.framing.compilation.content_property import compile_particular_content_property_list_class
+from coolamqp.framing.compilation import compile_particular_content_property_list_class
logger = logging.getLogger(__name__)
@@ -152,15 +152,15 @@ NOT_IMPLEMENTED = 540
# normal operations.
INTERNAL_ERROR = 541
-SOFT_ERRORS = [
- CONTENT_TOO_LARGE, NO_CONSUMERS, ACCESS_REFUSED, NOT_FOUND,
- RESOURCE_LOCKED, PRECONDITION_FAILED
-]
HARD_ERRORS = [
CONNECTION_FORCED, INVALID_PATH, FRAME_ERROR, SYNTAX_ERROR,
COMMAND_INVALID, CHANNEL_ERROR, UNEXPECTED_FRAME, RESOURCE_ERROR,
NOT_ALLOWED, NOT_IMPLEMENTED, INTERNAL_ERROR
]
+SOFT_ERRORS = [
+ CONTENT_TOO_LARGE, NO_CONSUMERS, ACCESS_REFUSED, NOT_FOUND,
+ RESOURCE_LOCKED, PRECONDITION_FAILED
+]
DOMAIN_TO_BASIC_TYPE = {
u'class-id': u'short',
@@ -4888,133 +4888,133 @@ class ConfirmSelectOk(AMQPMethodPayload):
IDENT_TO_METHOD = {
- (10, 60): ConnectionBlocked,
- (10, 50): ConnectionClose,
- (10, 51): ConnectionCloseOk,
- (10, 40): ConnectionOpen,
- (10, 41): ConnectionOpenOk,
- (10, 10): ConnectionStart,
- (10, 20): ConnectionSecure,
+ (90, 21): TxCommitOk,
+ (60, 100): BasicRecoverAsync,
(10, 11): ConnectionStartOk,
- (10, 21): ConnectionSecureOk,
- (10, 30): ConnectionTune,
- (10, 31): ConnectionTuneOk,
- (10, 61): ConnectionUnblocked,
- (20, 40): ChannelClose,
- (20, 41): ChannelCloseOk,
+ (60, 40): BasicPublish,
+ (60, 50): BasicReturn,
+ (40, 21): ExchangeDeleteOk,
(20, 20): ChannelFlow,
- (20, 21): ChannelFlowOk,
- (20, 10): ChannelOpen,
- (20, 11): ChannelOpenOk,
- (40, 30): ExchangeBind,
(40, 31): ExchangeBindOk,
- (40, 10): ExchangeDeclare,
- (40, 20): ExchangeDelete,
- (40, 11): ExchangeDeclareOk,
- (40, 21): ExchangeDeleteOk,
- (40, 40): ExchangeUnbind,
- (40, 51): ExchangeUnbindOk,
- (50, 20): QueueBind,
- (50, 21): QueueBindOk,
- (50, 10): QueueDeclare,
- (50, 40): QueueDelete,
+ (60, 21): BasicConsumeOk,
+ (10, 21): ConnectionSecureOk,
+ (90, 30): TxRollback,
+ (90, 10): TxSelect,
+ (85, 11): ConfirmSelectOk,
+ (10, 61): ConnectionUnblocked,
(50, 11): QueueDeclareOk,
- (50, 41): QueueDeleteOk,
- (50, 30): QueuePurge,
- (50, 31): QueuePurgeOk,
- (50, 50): QueueUnbind,
- (50, 51): QueueUnbindOk,
+ (60, 70): BasicGet,
+ (90, 11): TxSelectOk,
+ (10, 30): ConnectionTune,
+ (60, 11): BasicQosOk,
(60, 80): BasicAck,
- (60, 20): BasicConsume,
- (60, 30): BasicCancel,
- (60, 21): BasicConsumeOk,
- (60, 31): BasicCancelOk,
+ (20, 21): ChannelFlowOk,
(60, 60): BasicDeliver,
- (60, 70): BasicGet,
+ (90, 31): TxRollbackOk,
+ (60, 20): BasicConsume,
+ (85, 10): ConfirmSelect,
+ (20, 40): ChannelClose,
(60, 71): BasicGetOk,
- (60, 72): BasicGetEmpty,
+ (50, 30): QueuePurge,
+ (10, 31): ConnectionTuneOk,
+ (10, 40): ConnectionOpen,
+ (60, 30): BasicCancel,
+ (50, 50): QueueUnbind,
+ (40, 10): ExchangeDeclare,
+ (10, 50): ConnectionClose,
+ (20, 10): ChannelOpen,
+ (20, 41): ChannelCloseOk,
+ (60, 110): BasicRecover,
+ (60, 90): BasicReject,
+ (50, 31): QueuePurgeOk,
+ (50, 40): QueueDelete,
+ (40, 20): ExchangeDelete,
+ (50, 20): QueueBind,
+ (10, 41): ConnectionOpenOk,
(60, 120): BasicNack,
- (60, 40): BasicPublish,
+ (60, 31): BasicCancelOk,
+ (90, 20): TxCommit,
+ (10, 10): ConnectionStart,
(60, 10): BasicQos,
- (60, 11): BasicQosOk,
- (60, 50): BasicReturn,
- (60, 90): BasicReject,
- (60, 100): BasicRecoverAsync,
- (60, 110): BasicRecover,
+ (40, 11): ExchangeDeclareOk,
+ (10, 51): ConnectionCloseOk,
+ (40, 51): ExchangeUnbindOk,
+ (20, 11): ChannelOpenOk,
+ (60, 72): BasicGetEmpty,
+ (40, 30): ExchangeBind,
(60, 111): BasicRecoverOk,
- (90, 20): TxCommit,
- (90, 21): TxCommitOk,
- (90, 30): TxRollback,
- (90, 31): TxRollbackOk,
- (90, 10): TxSelect,
- (90, 11): TxSelectOk,
- (85, 10): ConfirmSelect,
- (85, 11): ConfirmSelectOk,
+ (40, 40): ExchangeUnbind,
+ (10, 20): ConnectionSecure,
+ (50, 41): QueueDeleteOk,
+ (50, 51): QueueUnbindOk,
+ (50, 21): QueueBindOk,
+ (10, 60): ConnectionBlocked,
+ (50, 10): QueueDeclare,
}
BINARY_HEADER_TO_METHOD = {
- b'\x00\x0A\x00\x3C': ConnectionBlocked,
- b'\x00\x0A\x00\x32': ConnectionClose,
- b'\x00\x0A\x00\x33': ConnectionCloseOk,
- b'\x00\x0A\x00\x28': ConnectionOpen,
- b'\x00\x0A\x00\x29': ConnectionOpenOk,
- b'\x00\x0A\x00\x0A': ConnectionStart,
- b'\x00\x0A\x00\x14': ConnectionSecure,
+ b'\x00\x5A\x00\x15': TxCommitOk,
+ b'\x00\x3C\x00\x64': BasicRecoverAsync,
b'\x00\x0A\x00\x0B': ConnectionStartOk,
- b'\x00\x0A\x00\x15': ConnectionSecureOk,
- b'\x00\x0A\x00\x1E': ConnectionTune,
- b'\x00\x0A\x00\x1F': ConnectionTuneOk,
- b'\x00\x0A\x00\x3D': ConnectionUnblocked,
- b'\x00\x14\x00\x28': ChannelClose,
- b'\x00\x14\x00\x29': ChannelCloseOk,
+ b'\x00\x3C\x00\x28': BasicPublish,
+ b'\x00\x3C\x00\x32': BasicReturn,
+ b'\x00\x28\x00\x15': ExchangeDeleteOk,
b'\x00\x14\x00\x14': ChannelFlow,
- b'\x00\x14\x00\x15': ChannelFlowOk,
- b'\x00\x14\x00\x0A': ChannelOpen,
- b'\x00\x14\x00\x0B': ChannelOpenOk,
- b'\x00\x28\x00\x1E': ExchangeBind,
b'\x00\x28\x00\x1F': ExchangeBindOk,
- b'\x00\x28\x00\x0A': ExchangeDeclare,
- b'\x00\x28\x00\x14': ExchangeDelete,
- b'\x00\x28\x00\x0B': ExchangeDeclareOk,
- b'\x00\x28\x00\x15': ExchangeDeleteOk,
- b'\x00\x28\x00\x28': ExchangeUnbind,
- b'\x00\x28\x00\x33': ExchangeUnbindOk,
- b'\x00\x32\x00\x14': QueueBind,
- b'\x00\x32\x00\x15': QueueBindOk,
- b'\x00\x32\x00\x0A': QueueDeclare,
- b'\x00\x32\x00\x28': QueueDelete,
+ b'\x00\x3C\x00\x15': BasicConsumeOk,
+ b'\x00\x0A\x00\x15': ConnectionSecureOk,
+ b'\x00\x5A\x00\x1E': TxRollback,
+ b'\x00\x5A\x00\x0A': TxSelect,
+ b'\x00\x55\x00\x0B': ConfirmSelectOk,
+ b'\x00\x0A\x00\x3D': ConnectionUnblocked,
b'\x00\x32\x00\x0B': QueueDeclareOk,
- b'\x00\x32\x00\x29': QueueDeleteOk,
- b'\x00\x32\x00\x1E': QueuePurge,
- b'\x00\x32\x00\x1F': QueuePurgeOk,
- b'\x00\x32\x00\x32': QueueUnbind,
- b'\x00\x32\x00\x33': QueueUnbindOk,
+ b'\x00\x3C\x00\x46': BasicGet,
+ b'\x00\x5A\x00\x0B': TxSelectOk,
+ b'\x00\x0A\x00\x1E': ConnectionTune,
+ b'\x00\x3C\x00\x0B': BasicQosOk,
b'\x00\x3C\x00\x50': BasicAck,
- b'\x00\x3C\x00\x14': BasicConsume,
- b'\x00\x3C\x00\x1E': BasicCancel,
- b'\x00\x3C\x00\x15': BasicConsumeOk,
- b'\x00\x3C\x00\x1F': BasicCancelOk,
+ b'\x00\x14\x00\x15': ChannelFlowOk,
b'\x00\x3C\x00\x3C': BasicDeliver,
- b'\x00\x3C\x00\x46': BasicGet,
+ b'\x00\x5A\x00\x1F': TxRollbackOk,
+ b'\x00\x3C\x00\x14': BasicConsume,
+ b'\x00\x55\x00\x0A': ConfirmSelect,
+ b'\x00\x14\x00\x28': ChannelClose,
b'\x00\x3C\x00\x47': BasicGetOk,
- b'\x00\x3C\x00\x48': BasicGetEmpty,
+ b'\x00\x32\x00\x1E': QueuePurge,
+ b'\x00\x0A\x00\x1F': ConnectionTuneOk,
+ b'\x00\x0A\x00\x28': ConnectionOpen,
+ b'\x00\x3C\x00\x1E': BasicCancel,
+ b'\x00\x32\x00\x32': QueueUnbind,
+ b'\x00\x28\x00\x0A': ExchangeDeclare,
+ b'\x00\x0A\x00\x32': ConnectionClose,
+ b'\x00\x14\x00\x0A': ChannelOpen,
+ b'\x00\x14\x00\x29': ChannelCloseOk,
+ b'\x00\x3C\x00\x6E': BasicRecover,
+ b'\x00\x3C\x00\x5A': BasicReject,
+ b'\x00\x32\x00\x1F': QueuePurgeOk,
+ b'\x00\x32\x00\x28': QueueDelete,
+ b'\x00\x28\x00\x14': ExchangeDelete,
+ b'\x00\x32\x00\x14': QueueBind,
+ b'\x00\x0A\x00\x29': ConnectionOpenOk,
b'\x00\x3C\x00\x78': BasicNack,
- b'\x00\x3C\x00\x28': BasicPublish,
+ b'\x00\x3C\x00\x1F': BasicCancelOk,
+ b'\x00\x5A\x00\x14': TxCommit,
+ b'\x00\x0A\x00\x0A': ConnectionStart,
b'\x00\x3C\x00\x0A': BasicQos,
- b'\x00\x3C\x00\x0B': BasicQosOk,
- b'\x00\x3C\x00\x32': BasicReturn,
- b'\x00\x3C\x00\x5A': BasicReject,
- b'\x00\x3C\x00\x64': BasicRecoverAsync,
- b'\x00\x3C\x00\x6E': BasicRecover,
+ b'\x00\x28\x00\x0B': ExchangeDeclareOk,
+ b'\x00\x0A\x00\x33': ConnectionCloseOk,
+ b'\x00\x28\x00\x33': ExchangeUnbindOk,
+ b'\x00\x14\x00\x0B': ChannelOpenOk,
+ b'\x00\x3C\x00\x48': BasicGetEmpty,
+ b'\x00\x28\x00\x1E': ExchangeBind,
b'\x00\x3C\x00\x6F': BasicRecoverOk,
- b'\x00\x5A\x00\x14': TxCommit,
- b'\x00\x5A\x00\x15': TxCommitOk,
- b'\x00\x5A\x00\x1E': TxRollback,
- b'\x00\x5A\x00\x1F': TxRollbackOk,
- b'\x00\x5A\x00\x0A': TxSelect,
- b'\x00\x5A\x00\x0B': TxSelectOk,
- b'\x00\x55\x00\x0A': ConfirmSelect,
- b'\x00\x55\x00\x0B': ConfirmSelectOk,
+ b'\x00\x28\x00\x28': ExchangeUnbind,
+ b'\x00\x0A\x00\x14': ConnectionSecure,
+ b'\x00\x32\x00\x29': QueueDeleteOk,
+ b'\x00\x32\x00\x33': QueueUnbindOk,
+ b'\x00\x32\x00\x15': QueueBindOk,
+ b'\x00\x0A\x00\x3C': ConnectionBlocked,
+ b'\x00\x32\x00\x0A': QueueDeclare,
}
CLASS_ID_TO_CONTENT_PROPERTY_LIST = {
@@ -5025,98 +5025,98 @@ CLASS_ID_TO_CONTENT_PROPERTY_LIST = {
# if a method is NOT a reply, it will not be in this dict
# a method may be a reply for AT MOST one method
REPLY_REASONS_FOR = {
- ConnectionCloseOk: ConnectionClose,
- ConnectionOpenOk: ConnectionOpen,
- ConnectionStartOk: ConnectionStart,
- ConnectionSecureOk: ConnectionSecure,
- ConnectionTuneOk: ConnectionTune,
- ChannelCloseOk: ChannelClose,
- ChannelFlowOk: ChannelFlow,
- ChannelOpenOk: ChannelOpen,
- ExchangeBindOk: ExchangeBind,
- ExchangeDeclareOk: ExchangeDeclare,
+ BasicGetEmpty: BasicGet,
+ BasicGetOk: BasicGet,
ExchangeDeleteOk: ExchangeDelete,
- ExchangeUnbindOk: ExchangeUnbind,
+ TxSelectOk: TxSelect,
QueueBindOk: QueueBind,
- QueueDeclareOk: QueueDeclare,
- QueueDeleteOk: QueueDelete,
- QueuePurgeOk: QueuePurge,
- QueueUnbindOk: QueueUnbind,
BasicConsumeOk: BasicConsume,
BasicCancelOk: BasicCancel,
- BasicGetOk: BasicGet,
- BasicGetEmpty: BasicGet,
- BasicQosOk: BasicQos,
- TxCommitOk: TxCommit,
TxRollbackOk: TxRollback,
- TxSelectOk: TxSelect,
+ TxCommitOk: TxCommit,
+ ChannelOpenOk: ChannelOpen,
+ QueueDeleteOk: QueueDelete,
+ ExchangeUnbindOk: ExchangeUnbind,
+ ExchangeBindOk: ExchangeBind,
+ ChannelCloseOk: ChannelClose,
+ BasicQosOk: BasicQos,
+ ConnectionStartOk: ConnectionStart,
+ QueueUnbindOk: QueueUnbind,
ConfirmSelectOk: ConfirmSelect,
+ ConnectionCloseOk: ConnectionClose,
+ QueuePurgeOk: QueuePurge,
+ QueueDeclareOk: QueueDeclare,
+ ExchangeDeclareOk: ExchangeDeclare,
+ ConnectionTuneOk: ConnectionTune,
+ ConnectionSecureOk: ConnectionSecure,
+ ConnectionOpenOk: ConnectionOpen,
+ ChannelFlowOk: ChannelFlow,
}
# Methods that are replies for other, ie. ConnectionOpenOk: ConnectionOpen
# a method may be a reply for ONE or NONE other methods
# if a method has no replies, it will have an empty list as value here
REPLIES_FOR = {
- ConnectionBlocked: [],
- ConnectionClose: [ConnectionCloseOk],
- ConnectionCloseOk: [],
- ConnectionOpen: [ConnectionOpenOk],
- ConnectionOpenOk: [],
- ConnectionStart: [ConnectionStartOk],
+ BasicGetEmpty: [],
+ BasicRecoverOk: [],
+ BasicReturn: [],
+ QueueDeclare: [QueueDeclareOk],
+ BasicGetOk: [],
ConnectionSecure: [ConnectionSecureOk],
- ConnectionStartOk: [],
- ConnectionSecureOk: [],
ConnectionTune: [ConnectionTuneOk],
- ConnectionTuneOk: [],
- ConnectionUnblocked: [],
- ChannelClose: [ChannelCloseOk],
- ChannelCloseOk: [],
+ TxRollback: [TxRollbackOk],
+ TxSelectOk: [],
+ QueueBindOk: [],
ChannelFlow: [ChannelFlowOk],
- ChannelFlowOk: [],
- ChannelOpen: [ChannelOpenOk],
+ BasicConsumeOk: [],
+ BasicConsume: [BasicConsumeOk],
+ BasicRecover: [],
+ BasicCancelOk: [],
+ ConfirmSelect: [ConfirmSelectOk],
+ BasicGet: [BasicGetOk, BasicGetEmpty],
+ TxRollbackOk: [],
+ QueueBind: [QueueBindOk],
+ ExchangeDelete: [ExchangeDeleteOk],
+ BasicAck: [],
+ ConnectionClose: [ConnectionCloseOk],
ChannelOpenOk: [],
- ExchangeBind: [ExchangeBindOk],
+ QueueDeleteOk: [],
+ ExchangeUnbindOk: [],
+ ConnectionStart: [ConnectionStartOk],
+ BasicQos: [BasicQosOk],
+ QueueUnbind: [QueueUnbindOk],
+ BasicQosOk: [],
+ BasicReject: [],
ExchangeBindOk: [],
+ ChannelCloseOk: [],
ExchangeDeclare: [ExchangeDeclareOk],
- ExchangeDelete: [ExchangeDeleteOk],
- ExchangeDeclareOk: [],
- ExchangeDeleteOk: [],
+ ConnectionBlocked: [],
+ BasicPublish: [],
ExchangeUnbind: [ExchangeUnbindOk],
- ExchangeUnbindOk: [],
- QueueBind: [QueueBindOk],
- QueueBindOk: [],
- QueueDeclare: [QueueDeclareOk],
+ ExchangeDeleteOk: [],
+ BasicNack: [],
+ ConnectionStartOk: [],
+ ExchangeBind: [ExchangeBindOk],
QueueDelete: [QueueDeleteOk],
- QueueDeclareOk: [],
- QueueDeleteOk: [],
+ ConfirmSelectOk: [],
+ ConnectionCloseOk: [],
QueuePurge: [QueuePurgeOk],
- QueuePurgeOk: [],
- QueueUnbind: [QueueUnbindOk],
QueueUnbindOk: [],
- BasicAck: [],
- BasicConsume: [BasicConsumeOk],
+ ChannelOpen: [ChannelOpenOk],
+ ChannelClose: [ChannelCloseOk],
+ QueuePurgeOk: [],
+ QueueDeclareOk: [],
BasicCancel: [BasicCancelOk],
- BasicConsumeOk: [],
- BasicCancelOk: [],
- BasicDeliver: [],
- BasicGet: [BasicGetOk, BasicGetEmpty],
- BasicGetOk: [],
- BasicGetEmpty: [],
- BasicNack: [],
- BasicPublish: [],
- BasicQos: [BasicQosOk],
- BasicQosOk: [],
- BasicReturn: [],
- BasicReject: [],
- BasicRecoverAsync: [],
- BasicRecover: [],
- BasicRecoverOk: [],
- TxCommit: [TxCommitOk],
+ ExchangeDeclareOk: [],
TxCommitOk: [],
- TxRollback: [TxRollbackOk],
- TxRollbackOk: [],
+ ConnectionTuneOk: [],
+ ConnectionSecureOk: [],
+ ConnectionUnblocked: [],
+ ConnectionOpenOk: [],
+ ChannelFlowOk: [],
+ BasicRecoverAsync: [],
TxSelect: [TxSelectOk],
- TxSelectOk: [],
- ConfirmSelect: [ConfirmSelectOk],
- ConfirmSelectOk: [],
+ BasicDeliver: [],
+ TxCommit: [TxCommitOk],
+ ConnectionOpen: [ConnectionOpenOk],
}
--
GitLab