abialas

Formatter does not inherit whitespaces settings from Java fromatter

1

I have Java formatter settings which should format the following: ```groovy def dummyMethod() { def doIt=false if(doIt) { return null } } ``` into: ```groovy def dummyMethod() { def doIt...

Currently, I do not see the option to get the scan result as PDF file. This option is available in hub-scan. It would be great if such a feature can...

Container with new ImageFromDockerfile().withDockerfile(...) cause java.lang.IllegalArgumentException: group id '...' is too big ( > 2097151 ). Use STAR or POSIX extensions to overcome this limit

6

I upgraded the testcontainers version from 1.15.3 to 1.16.2. When I try to run test now I am getting: > Caused by: org.testcontainers.containers.ContainerFetchException: Can't get Docker image: RemoteDockerImage(imageName=, imagePullPolicy=DefaultPullPolicy()) >...

### Describe the feature We used to be able to configure `writeTimeout` and `chunkedEncodingEnabled` using S3AsyncClient with NettyNioAsyncHttpClient: ``` SdkAsyncHttpClient httpClient = NettyNioAsyncHttpClient.builder() .writeTimeout(writeTimeout) .maxConcurrency(maxConcurrency) .build(); S3Configuration serviceConfiguration = S3Configuration.builder()...

LettuceClusterTopologyProvider does not use cached topology

1

In JedisClusterTopologyProvider getTopology uses cached value for some time so it is better for performance and memory. In LettuceClusterTopologyProvider it is not done in the same way - always new...

Receiver creates a new channel for every queue it consuming from. It removes the possibility to set global qos (described here: https://www.rabbitmq.com/consumer-prefetch.html#sharing-the-limit) ## Motivation If single consumer consumes from multiple...

Consumption stopped with slow consumer

2

I have a simple but slow consumer which consumes 1 record at time: ``` private Flux consumeRecords(Flux records) { return records .concatMap(receiverRecord -> handleReceivedRecord(receiverRecord)) .concatMap(this::ackOffset) .doOnEach(logOnError(logErrorReceiveRecord())) .retryWhen(RETRY_FAILED_CONSUMER_SPEC); } ``` Processing...

RabbitMQ trigger not work correctly for mode MessageRate and sum operator

1

### Report I am using trigger based on RabbitMQ and MessageRate as mode. As operation I am using sum and value is set to 150. RabbitMQ has 4 queues. When...