| 58 | } |
| 59 | |
| 60 | static void decode_message(pn_rwbytes_t data) { |
| 61 | pn_message_t *m = pn_message(); |
| 62 | int err = pn_message_decode(m, data.start, data.size); |
| 63 | if (!err) { |
| 64 | /* Print the decoded message */ |
| 65 | char *s = pn_tostring(pn_message_body(m)); |
| 66 | printf("%s\n", s); |
| 67 | free(s); |
| 68 | pn_message_free(m); |
| 69 | free(data.start); |
| 70 | } else { |
| 71 | fprintf(stderr, "decode_message: %s\n", pn_code(err)); |
| 72 | exit_code = 1; |
| 73 | } |
| 74 | } |
| 75 | |
| 76 | /* Return true to continue, false to exit */ |
| 77 | static bool handle(app_data_t* app, pn_event_t* event) { |
no test coverage detected