Skip to content

Commit c6f139a

Browse files
committed
AMQP_EMPTY_* were deprecated since v0.1
1 parent 3ec5ded commit c6f139a

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

Modules/_librabbitmq/connection.c

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -256,7 +256,7 @@ PyDict_ToAMQTable(amqp_connection_state_t conn, PyObject *src, amqp_pool_t *pool
256256
uint64_t clong_value = 0;
257257
double cdouble_value = 0.0;
258258
int is_unicode = 0;
259-
amqp_table_t dst = AMQP_EMPTY_TABLE;
259+
amqp_table_t dst = amqp_empty_table;
260260

261261
size = PyDict_Size(src);
262262

@@ -340,7 +340,7 @@ PyDict_ToAMQTable(amqp_connection_state_t conn, PyObject *src, amqp_pool_t *pool
340340
return dst;
341341
error:
342342
assert(PyErr_Occurred());
343-
return AMQP_EMPTY_TABLE;
343+
return amqp_empty_table;
344344
}
345345

346346
static amqp_array_t
@@ -349,7 +349,7 @@ PyIter_ToAMQArray(amqp_connection_state_t conn, PyObject *src, amqp_pool_t *pool
349349
Py_ssize_t pos = 0;
350350
uint64_t clong_value = 0;
351351
int is_unicode = 0;
352-
amqp_array_t dst = AMQP_EMPTY_ARRAY;
352+
amqp_array_t dst = amqp_empty_array;
353353

354354
Py_ssize_t size = PySequence_Size(src);
355355
if (size == -1) return dst;
@@ -684,7 +684,7 @@ PyDict_to_basic_properties(PyObject *p,
684684
amqp_pool_t *pool)
685685
{
686686
PyObject *value = NULL;
687-
props->headers = AMQP_EMPTY_TABLE;
687+
props->headers = amqp_empty_table;
688688
props->_flags = AMQP_BASIC_HEADERS_FLAG;
689689

690690
if ((value = PyDict_GetItemString(p, "content_type")) != NULL) {
@@ -1461,7 +1461,7 @@ PyRabbitMQ_Connection_queue_bind(PyRabbitMQ_Connection *self,
14611461
PyObject *routing_key = NULL;
14621462
PyObject *arguments = NULL;
14631463

1464-
amqp_table_t bargs = AMQP_EMPTY_TABLE;
1464+
amqp_table_t bargs = amqp_empty_table;
14651465
amqp_pool_t *channel_pool = NULL;
14661466
amqp_rpc_reply_t reply;
14671467

@@ -1516,7 +1516,7 @@ PyRabbitMQ_Connection_queue_unbind(PyRabbitMQ_Connection *self,
15161516
PyObject *routing_key = NULL;
15171517
PyObject *arguments = NULL;
15181518

1519-
amqp_table_t uargs = AMQP_EMPTY_TABLE;
1519+
amqp_table_t uargs = amqp_empty_table;
15201520
amqp_pool_t *channel_pool = NULL;
15211521
amqp_rpc_reply_t reply;
15221522

@@ -1618,7 +1618,7 @@ PyRabbitMQ_Connection_queue_declare(PyRabbitMQ_Connection *self,
16181618
amqp_queue_declare_ok_t *ok;
16191619
amqp_rpc_reply_t reply;
16201620
amqp_pool_t *channel_pool = NULL;
1621-
amqp_table_t qargs = AMQP_EMPTY_TABLE;
1621+
amqp_table_t qargs = amqp_empty_table;
16221622
PyObject *ret = NULL;
16231623

16241624
if (PyRabbitMQ_Not_Connected(self))
@@ -1718,7 +1718,7 @@ PyRabbitMQ_Connection_exchange_declare(PyRabbitMQ_Connection *self,
17181718
* as it has been decided that it's not that useful after all. */
17191719
unsigned int auto_delete = 0;
17201720

1721-
amqp_table_t eargs = AMQP_EMPTY_TABLE;
1721+
amqp_table_t eargs = amqp_empty_table;
17221722
amqp_pool_t *channel_pool = NULL;
17231723
amqp_rpc_reply_t reply;
17241724

@@ -1984,7 +1984,7 @@ PyRabbitMQ_Connection_basic_consume(PyRabbitMQ_Connection *self,
19841984
amqp_basic_consume_ok_t *ok;
19851985
amqp_rpc_reply_t reply;
19861986
amqp_pool_t *channel_pool = NULL;
1987-
amqp_table_t cargs = AMQP_EMPTY_TABLE;
1987+
amqp_table_t cargs = amqp_empty_table;
19881988

19891989
if (PyRabbitMQ_Not_Connected(self))
19901990
goto bail;

0 commit comments

Comments
 (0)