This is an automated email from the ASF dual-hosted git repository. chug pushed a commit to branch dev-protocol-adaptors-2 in repository https://gitbox.apache.org/repos/asf/qpid-dispatch.git
commit 9dc69d55b003cd097efa8b30edaed5b3f789a10d Author: Gordon Sim <g...@redhat.com> AuthorDate: Mon Oct 5 20:14:42 2020 +0100 DISPATCH-1654: need to set to field on message --- src/adaptors/tcp_adaptor.c | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/src/adaptors/tcp_adaptor.c b/src/adaptors/tcp_adaptor.c index 0e06059..f5d0ac7 100644 --- a/src/adaptors/tcp_adaptor.c +++ b/src/adaptors/tcp_adaptor.c @@ -149,9 +149,15 @@ static int handle_incoming(qdr_tcp_connection_t *conn) qd_compose_start_list(props); qd_compose_insert_null(props); // message-id qd_compose_insert_null(props); // user-id - qd_compose_insert_null(props); // to - qd_compose_insert_string(props, conn->global_id); // subject - qd_compose_insert_string(props, conn->reply_to); // reply-to + if (conn->ingress) { + qd_compose_insert_string(props, conn->config.address); // to + qd_compose_insert_string(props, conn->global_id); // subject + qd_compose_insert_string(props, conn->reply_to); // reply-to + } else { + qd_compose_insert_string(props, conn->reply_to); // to + qd_compose_insert_string(props, conn->global_id); // subject + qd_compose_insert_null(props); // reply-to + } //qd_compose_insert_null(props); // correlation-id //qd_compose_insert_null(props); // content-type //qd_compose_insert_null(props); // content-encoding --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org