Skip to content

Commit

Permalink
if ERR__QUEUE_FULL, use list instead of list_deals
Browse files Browse the repository at this point in the history
  • Loading branch information
Jon committed Jul 24, 2018
1 parent df3b4cb commit 3c83609
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion matchengine/me_message.c
Original file line number Diff line number Diff line change
Expand Up @@ -164,7 +164,7 @@ static int push_message(char *message, rd_kafka_topic_t *topic, list_t *list)
if (ret == -1) {
log_fatal("Failed to produce: %s to topic %s: %s\n", message, rd_kafka_topic_name(rkt_deals), rd_kafka_err2str(rd_kafka_last_error()));
if (rd_kafka_last_error() == RD_KAFKA_RESP_ERR__QUEUE_FULL) {
list_add_node_tail(list_deals, message);
list_add_node_tail(list, message);
return 0;
}
free(message);
Expand Down

0 comments on commit 3c83609

Please sign in to comment.