Artem Bilan

OK. If you both agree that common `private final long leaseTime;` value as a configuration option is enough, we can go ahead into that direction everywhere needed.

What I see in the `RedisLockRegistry` is called `expireAfter` and used in the Redis script like: `redis.call('PEXPIRE', KEYS[1], ARGV[2])`. The JDBC solution provides for us a `ttl` option on the...

Hm... I don't see any big problem with casting a `LockRegistry.obtain()` result into the `ILock` and perform many useful Hazelcast features on it, including desired `tryLock(long time, TimeUnit unit, long...

Moved back to Spring integration since it looks like we need to provide a `DistributedLock` contract in other `LockRegistry` implementations. Move info from the https://jira.spring.io/browse/INT-4399

Right. The reactive channel adapter can be turned to imperative very easy - `block()`, `subscribe()` etc. So, I suggest the name as plain as possible: `PulsarMessageHandler` and `PulsarMessageProducer`. We cannot...

I think we can clear state that in the Javadocs of the class and in the docs. Not sure if you are going to use a new feature without reading...

FYI, we have started some effort with Spring for Apache Pulsar: https://github.com/spring-projects-experimental/spring-pulsar. Feel free to give some feedback and contribute! //CC @sobychacko

Hi @rolkhas2 , I don't think so. The Spring for Apache Pulsar is in early stages, so it is unlikely the channel adapters on the matter will make it into...

Some source for inspiration: https://github.com/lhotari/pulsar-spring-cloud-stream-binder

We don't have any objection to support this. Although having our low knowledge about this subject, we would like to ask about contribution: https://github.com/spring-projects/spring-integration/blob/master/CONTRIBUTING.adoc Otherwise we will come back to...