summaryrefslogtreecommitdiff
path: root/librabbitmq
diff options
context:
space:
mode:
Diffstat (limited to 'librabbitmq')
-rw-r--r--librabbitmq/amqp_socket.c2
-rw-r--r--librabbitmq/codegen.py2
2 files changed, 2 insertions, 2 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c
index 953d52b..debed2a 100644
--- a/librabbitmq/amqp_socket.c
+++ b/librabbitmq/amqp_socket.c
@@ -305,7 +305,7 @@ amqp_rpc_reply_t amqp_simple_rpc(amqp_connection_state_t state,
||
((frame.channel == 0) &&
(frame.payload.method.id == AMQP_CONNECTION_CLOSE_METHOD)) ) ))
- {
+ {
amqp_frame_t *frame_copy = amqp_pool_alloc(&state->decoding_pool, sizeof(amqp_frame_t));
amqp_link_t *link = amqp_pool_alloc(&state->decoding_pool, sizeof(amqp_link_t));
diff --git a/librabbitmq/codegen.py b/librabbitmq/codegen.py
index 918b56a..905d313 100644
--- a/librabbitmq/codegen.py
+++ b/librabbitmq/codegen.py
@@ -539,7 +539,7 @@ int amqp_encode_properties(uint16_t class_id,
print " req.%s = %s;" % (n, val)
- reply = cConstantName(c_ize(m.klass.name) + '_' + c_ize(m.name)
+ reply = cConstantName(c_ize(m.klass.name) + '_' + c_ize(m.name)
+ "_ok_method")
print """
return amqp_simple_rpc_decoded(state, channel, %s, %s, &req);