diff options
| -rw-r--r-- | librabbitmq/amqp_connection.c | 4 | ||||
| -rw-r--r-- | librabbitmq/amqp_openssl.c | 1 | ||||
| -rw-r--r-- | librabbitmq/amqp_socket.c | 1 |
3 files changed, 2 insertions, 4 deletions
diff --git a/librabbitmq/amqp_connection.c b/librabbitmq/amqp_connection.c index 18cf941..f8ef4a5 100644 --- a/librabbitmq/amqp_connection.c +++ b/librabbitmq/amqp_connection.c @@ -404,8 +404,8 @@ int amqp_handle_input(amqp_connection_state_t state, } default: - amqp_abort("Internal error: invalid amqp_connection_state_t->state %d", state->state); - return (int)bytes_consumed; + amqp_abort("Internal error: invalid amqp_connection_state_t->state %d", + state->state); } } diff --git a/librabbitmq/amqp_openssl.c b/librabbitmq/amqp_openssl.c index 1ed7812..68808bb 100644 --- a/librabbitmq/amqp_openssl.c +++ b/librabbitmq/amqp_openssl.c @@ -410,7 +410,6 @@ password_cb(AMQP_UNUSED char *buffer, AMQP_UNUSED void *user_data) { amqp_abort("rabbitmq-c does not support password protected keys"); - return 0; } int diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c index da00567..66e4ae5 100644 --- a/librabbitmq/amqp_socket.c +++ b/librabbitmq/amqp_socket.c @@ -351,7 +351,6 @@ start_select: return AMQP_STATUS_SOCKET_ERROR; } } - return AMQP_STATUS_OK; #else # error "poll() or select() is needed to compile rabbitmq-c" #endif |