| 95 | } |
| 96 | |
| 97 | static void decode_message(pn_rwbytes_t data) { |
| 98 | pn_message_t *m = pn_message(); |
| 99 | int err = pn_message_decode(m, data.start, data.size); |
| 100 | if (!err) { |
| 101 | /* Print the decoded message */ |
| 102 | char *s = pn_tostring(pn_message_body(m)); |
| 103 | printf("%s\n", s); |
| 104 | fflush(stdout); |
| 105 | free(s); |
| 106 | pn_message_free(m); |
| 107 | free(data.start); |
| 108 | } else { |
| 109 | fprintf(stderr, "decode error: %s\n", pn_error_text(pn_message_error(m))); |
| 110 | exit_code = 1; |
| 111 | } |
| 112 | } |
| 113 | |
| 114 | /* This function handles events when we are acting as the receiver */ |
| 115 | static void handle_receive(app_data_t *app, pn_event_t* event) { |
no test coverage detected