zenios

PgSubscriber reconnects when shutting down

1

When vertx is shutting down which will eventually shutdown the pool PgSubscribers with reconnect policy are not aware of it and try to reconnect resulting to exceptions being thrown

Streams: consider allowing non-numerical values for publishingId

2

### Is your feature request related to a problem? Please describe. Hi I was in the process of implementing embedded debezium using postgres connector and rabbitmq streams utilizing publishingId based...

Variable from interceptor to originSelector

3

Sometimes we might want to assign a variable inside an interceptor that will help the origin selector to decide the actual origin. What is the optimal way to do these...

Response should be paused

1

https://github.com/reactiverse/aws-sdk/blob/883755f9068ea111ba54736ba4b473d6d681eb3d/src/main/java/io/reactiverse/awssdk/VertxNioAsyncHttpClient.java#L86 Hi Response should be paused until the subscriber (ReadStreamPublisher) requests data via (stream.fetch(n) which automatically resumes) else you are having the chance of missing data. This is visible when...

Even though subscription requests go through to services, there is no way to return a Publisher from ServiceExecutionResult. Are there any plans to fully support this?

ForwardedRequestCustomizer uses connection port instead of proto default when host lacks port

2

**Description** In a Forwarded header such as: Forwarded: by=203.0.113.43; for=198.51.100.17; host=example.com; proto=https Jetty currently assumes that it should use the connection port rather than inferring the default port for the...

serverVersion and dateHeader are set twice when proxying

2

In jetty 12 when i set a proxy handler to another jetty that already sets the version and date handler the origin sends it twice resullting in two date and...

### Describe the bug Hey i have been chasing a weird race condition in subscriptionExchange that most probably has to do with multiple teardowns. Lets assume that when a subscription...