- [ ] need a new type of broker connection pool that we then create here [here](https://github.com/INTERSECT-SDK/broker-http-proxy/blob/main/proxy-http-client/src/main.rs#L39-L60) which has this function [here] for the get_connection_pool - this gets passed down to the event source loop [here](https://github.com/INTERSECT-SDK/broker-http-proxy/blob/main/proxy-http-client/src/event_source.rs#L54) - and web app application state [here](https://github.com/INTERSECT-SDK/broker-http-proxy/blob/main/proxy-http-server/src/webapp.rs#L29C9-L29C29) - and in publish [here](https://github.com/INTERSECT-SDK/broker-http-proxy/blob/9284ad6360fd3a1463ad2a37a23642044b952037/proxy-http-server/src/routes/publish.rs#L63) - and subscribe [here](https://github.com/INTERSECT-SDK/broker-http-proxy/blob/9284ad6360fd3a1463ad2a37a23642044b952037/shared-deps/src/protocols/amqp/subscribe.rs#L53) - [ ] Add an MQTT protocol [here](https://github.com/INTERSECT-SDK/broker-http-proxy/tree/main/shared-deps/src/protocols)