You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ch...@apache.org on 2020/10/20 16:02:16 UTC
[qpid-dispatch] 01/04: DISPATCH-1654: need to set to field on
message
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 <gs...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org