| 321 | } |
| 322 | |
| 323 | void messaging_adapter::dispatch(messaging_handler& handler, pn_event_t* event) |
| 324 | { |
| 325 | pn_event_type_t type = pn_event_type(event); |
| 326 | |
| 327 | // Only handle events we are interested in |
| 328 | switch(type) { |
| 329 | case PN_CONNECTION_BOUND: on_connection_bound(handler, event); break; |
| 330 | case PN_CONNECTION_REMOTE_OPEN: on_connection_remote_open(handler, event); break; |
| 331 | case PN_CONNECTION_REMOTE_CLOSE: on_connection_remote_close(handler, event); break; |
| 332 | |
| 333 | case PN_SESSION_REMOTE_OPEN: on_session_remote_open(handler, event); break; |
| 334 | case PN_SESSION_REMOTE_CLOSE: on_session_remote_close(handler, event); break; |
| 335 | |
| 336 | case PN_LINK_LOCAL_OPEN: on_link_local_open(handler, event); break; |
| 337 | case PN_LINK_REMOTE_OPEN: on_link_remote_open(handler, event); break; |
| 338 | case PN_LINK_REMOTE_CLOSE: on_link_remote_close(handler, event); break; |
| 339 | case PN_LINK_REMOTE_DETACH: on_link_remote_detach(handler, event); break; |
| 340 | case PN_LINK_FLOW: on_link_flow(handler, event); break; |
| 341 | |
| 342 | case PN_DELIVERY: on_delivery(handler, event); break; |
| 343 | |
| 344 | case PN_TRANSPORT_CLOSED: on_transport_closed(handler, event); break; |
| 345 | |
| 346 | case PN_CONNECTION_WAKE: on_connection_wake(handler, event); break; |
| 347 | |
| 348 | // Ignore everything else |
| 349 | default: break; |
| 350 | } |
| 351 | } |
| 352 | |
| 353 | } |
nothing calls this directly
no test coverage detected