Не удалось сохранить данные в хранилище данных Redis - Spring Boot - PullRequest
0 голосов
/ 29 марта 2019

У меня проблема с хранением данных в хранилище Redis.Редис докеризован.Я должен упомянуть, что соединение с Redis успешно открыто, и запрос данных работает отлично - никаких проблем вообще нет, но когда я пытаюсь сохранить данные, возникает исключение ниже.

Исключение:

org.springframework.data.keyvalue.core.UncategorizedKeyValueException: nested exception is java.lang.NullPointerException
at org.springframework.data.keyvalue.core.KeyValuePersistenceExceptionTranslator.translateExceptionIfPossible(KeyValuePersistenceExceptionTranslator.java:49)
at org.springframework.data.keyvalue.core.KeyValueTemplate.resolveExceptionIfPossible(KeyValueTemplate.java:484)
at org.springframework.data.keyvalue.core.KeyValueTemplate.execute(KeyValueTemplate.java:379)
at org.springframework.data.keyvalue.core.KeyValueTemplate.update(KeyValueTemplate.java:209)
at org.springframework.data.keyvalue.repository.support.SimpleKeyValueRepository.save(SimpleKeyValueRepository.java:99)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

Модель:

@RedisHash("TaskSubscriber")
public class TaskSubscriber implements Serializable {

    private static final long serialVersionUID = 20190329202800L;

    private String id;
    private String destination;
    private String username;

    @SuppressWarnings("unused")
    public TaskSubscriber() { }

    public TaskSubscriber(String sessionId, String destination, String username)
    {
        this.id = sessionId;
        this.destination = destination;
        this.username = username;
    }

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getDestination() {
        return destination;
    }

    public void setDestination(String destination) {
        this.destination = destination;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }
}

Хранилище:

@Repository
public interface TaskSubscriberRepository extends JpaRepository<TaskSubscriber, String> {

    List<TaskSubscriber> findAllByDestination(String destination);

    List<TaskSubscriber> findAllByUsername(String username);
}

В классе обслуживания I 'я просто вызываю save метод из репозитория TaskSubscriber, передавая модель TaskSubscriber с данными.

У кого-нибудь есть идеи, как это исправить?Заранее спасибо.

...