MCPcopy Create free account
hub / github.com/apache/qpid-proton / dispatch

Method dispatch

cpp/src/messaging_adapter.cpp:323–351  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

321}
322
323void 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}

Callers

nothing calls this directly

Calls 14

pn_event_typeFunction · 0.85
on_connection_boundFunction · 0.85
on_session_remote_openFunction · 0.85
on_session_remote_closeFunction · 0.85
on_link_local_openFunction · 0.85
on_link_remote_openFunction · 0.85
on_link_remote_closeFunction · 0.85
on_link_remote_detachFunction · 0.85
on_link_flowFunction · 0.85
on_deliveryFunction · 0.85

Tested by

no test coverage detected