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
