Demonstrates how to dynamically register Spring for Apache Pulsar listener containers at runtime.
There are 2 REST endpoints:
-
register/{id}- will dynamically create, start, and register a listener container w/ specified id -
send/{id}- will send a random message to the listener w/ the specified id
-
Start Pulsar
-
./gradlew build -
./gradlew bootRun
Once the app is started you can issue the following commands to register 2 listeners and send messages to each:
curl http://localhost:9090/register/1
curl http://localhost:9090/register/2
curl http://localhost:9090/send/1
curl http://localhost:9090/send/2The output will look something like:
***** REGISTERED CONTAINER w/ id = 1
***** REGISTERED CONTAINER w/ id = 2
***** SENT msg-to-container-1-1716604802431
***** SENT msg-to-container-2-1716604808128|
Note
|
Because we registered the containers w/ the application context, and they implement lifecycle methods properly, they will cleanup after themselves properly. If you do not want this, you can skip registering them w/ the app context and manage the stop/destroy of the containers yourself. |