T
- public interface ReactiveRedisCallback<T>
ReactiveRedisConnection
. Allows to execute
any number of operations on a single ReactiveRedisConnection
, using any type and number of commands.
This is particularly useful for delegating to existing data access code that expects a
ReactiveRedisConnection
to work on. For newly written code, it is strongly recommended to use
ReactiveRedisOperations
's more specific operations.
ReactiveRedisOperations.execute(ReactiveRedisCallback)
Modifier and Type | Method and Description |
---|---|
org.reactivestreams.Publisher<T> |
doInRedis(ReactiveRedisConnection connection)
Gets called by
ReactiveRedisTemplate.execute(ReactiveRedisCallback) with an active Redis connection. |
org.reactivestreams.Publisher<T> doInRedis(ReactiveRedisConnection connection) throws DataAccessException
ReactiveRedisTemplate.execute(ReactiveRedisCallback)
with an active Redis connection. Does
not need to care about activating or closing the ReactiveRedisConnection
.
Allows for returning a result object created within the callback, i.e. a domain object or a collection of domain objects.
connection
- active Redis connection.DataAccessException
- in case of custom exceptionsCopyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.