org.springframework.xd.dirt.stream.redis

Class RedisStreamDefinitionRepository

java.lang.Object

org.springframework.xd.store.AbstractRedisRepository<D,java.lang.String>

org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository<StreamDefinition>

org.springframework.xd.dirt.stream.redis.RedisStreamDefinitionRepository

All Implemented Interfaces:

org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>, org.springframework.data.repository.PagingAndSortingRepository<StreamDefinition,java.lang.String>, org.springframework.data.repository.Repository<StreamDefinition,java.lang.String>, StreamDefinitionRepository, DomainRepository<StreamDefinition,java.lang.String>, RangeCapableRepository<StreamDefinition,java.lang.String>

public class RedisStreamDefinitionRepository
extends AbstractRedisDefinitionRepository<StreamDefinition>
implements StreamDefinitionRepository

An implementation of StreamDefinitionRepository that persists StreamDefinition in Redis.

Author:

Eric Bottard

Field Summary

Fields inherited from class org.springframework.xd.store.AbstractRedisRepository

redisOperations, repoPrefix, zSetOperations

Constructor Summary

Constructors

Constructor and Description
RedisStreamDefinitionRepository(org.springframework.data.redis.core.RedisOperations<java.lang.String,java.lang.String> redisOperations, ModuleDependencyRepository dependencyRepository)

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(StreamDefinition entity)
void	delete(java.lang.String id)
protected StreamDefinition	deserialize(java.lang.String redisKey, java.lang.String v) Deserialize from the String representation to the domain object.
StreamDefinition	save(StreamDefinition entity)
protected java.lang.String	serialize(StreamDefinition entity) Provide a String representation of the domain entity.

Methods inherited from class org.springframework.xd.dirt.stream.redis.AbstractRedisDefinitionRepository

deserializeId, keyFor, serializeId

Methods inherited from class org.springframework.xd.store.AbstractRedisRepository

count, delete, deleteAll, exists, findAll, findAll, findAll, findAll, findAllInRange, findOne, getPrefix, idFromRedisKey, redisKeyFromId, save, setPrefix, trackMembership

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.repository.PagingAndSortingRepository

findAll, findAll

Methods inherited from interface org.springframework.data.repository.CrudRepository

count, delete, deleteAll, exists, findAll, findAll, findOne, save

Methods inherited from interface org.springframework.xd.store.RangeCapableRepository

findAllInRange

Constructor Detail

RedisStreamDefinitionRepository

public RedisStreamDefinitionRepository(org.springframework.data.redis.core.RedisOperations<java.lang.String,java.lang.String> redisOperations,
                               ModuleDependencyRepository dependencyRepository)

Method Detail

save

public StreamDefinition save(StreamDefinition entity)

Specified by:

save in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

Overrides:

save in class AbstractRedisRepository<StreamDefinition,java.lang.String>

delete

public void delete(StreamDefinition entity)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

Overrides:

delete in class AbstractRedisRepository<StreamDefinition,java.lang.String>

delete

public void delete(java.lang.String id)

Specified by:

delete in interface org.springframework.data.repository.CrudRepository<StreamDefinition,java.lang.String>

Overrides:

delete in class AbstractRedisRepository<StreamDefinition,java.lang.String>

deserialize

protected StreamDefinition deserialize(java.lang.String redisKey,
                           java.lang.String v)

Description copied from class: AbstractRedisRepository

Deserialize from the String representation to the domain object.

Specified by:

deserialize in class AbstractRedisRepository<StreamDefinition,java.lang.String>

Parameters:

redisKey - the entity id

v - the serialized representation of the domain object

serialize

protected java.lang.String serialize(StreamDefinition entity)

Description copied from class: AbstractRedisRepository

Provide a String representation of the domain entity.

Specified by:

serialize in class AbstractRedisRepository<StreamDefinition,java.lang.String>