Fix typo
This commit is contained in:
parent
e02b5111ad
commit
449c59abed
2
queue.c
2
queue.c
|
@ -199,7 +199,7 @@ static void queue_handle_message(node_t *n, sexp_t *m) {
|
||||||
if (!sexp_stringp(sub->sink) || !sexp_stringp(sub->name)
|
if (!sexp_stringp(sub->sink) || !sexp_stringp(sub->name)
|
||||||
|| !sexp_stringp(reply_sink) || !sexp_stringp(reply_name)) {
|
|| !sexp_stringp(reply_sink) || !sexp_stringp(reply_name)) {
|
||||||
DECREF(sub->uuid, sexp_destructor);
|
DECREF(sub->uuid, sexp_destructor);
|
||||||
warn("Bad sink/name/reply_sink/replay_name in subscribe");
|
warn("Bad sink/name/reply_sink/reply_name in subscribe");
|
||||||
} else {
|
} else {
|
||||||
INCREF(sub->sink);
|
INCREF(sub->sink);
|
||||||
INCREF(sub->name);
|
INCREF(sub->name);
|
||||||
|
|
Loading…
Reference in New Issue