Невозможно сохранить данные в dos космоса через микро сервис весенней загрузки

Question

Я пытаюсь сохранить сущность в db космоса через микро сервис весенней загрузки. Я не получаю никакой ошибки, только 1 предупреждение ' [osEventL oop -6-1] c .ad c .idrntbd.RntbdRequestManager: ChannelHandlerContext (RntbdRequestManager # 0, [id: 0x999bfba c, L: 0.0.0.0/0.0.0.0: 56979! R: cdb-ms-prod - ***** - ****. Документы. azure .com / ********] ) channelNnregistered исключительно ', но данные не сохраняются в космос db. Я использую реактивную систему.

вот мой пом. xml

<properties>
        <java.version>1.8</java.version>
        <azure.version>2.2.0</azure.version>
    </properties>
<dependency>
            <groupId>com.microsoft.azure</groupId>
            <artifactId>azure-cosmosdb-spring-boot-starter</artifactId>
            <version>${azure.version}</version>
        </dependency>

моя сущность

import com.microsoft.azure.spring.data.cosmosdb.core.mapping.Document;

@Document(collection = "dashboardsnapshot")

public class DashboardSnapshot {

    private String id;
    private String clientId;
    private String snapshotJSON;

    public String getId() {
        return id;
    }
    public void setId(String id) {
        this.id = id;
    }
    public String getClientId() {
        return clientId;
    }
    public void setClientId(String clientId) {
        this.clientId = clientId;
    }
    public String getSnapshotJSON() { 
        return snapshotJSON; 
    } 
    public void setSnapshotJSON(String snapshotJSON) { 
        this.snapshotJSON = snapshotJSON; 
    }


    @Override
    public String toString() {
        return "DashboardSnapshot [id=" + id + ", clientId=" + clientId + ", snapshotJSON=" + snapshotJSON + "]";
    }

}

мой репозиторий

import org.springframework.stereotype.Repository;

import com.ka.concept.dashboardconfig.entity.DashboardSnapshot;
import com.microsoft.azure.spring.data.cosmosdb.repository.ReactiveCosmosRepository;

import reactor.core.publisher.Flux;

@Repository
public interface SnapshotDao extends ReactiveCosmosRepository<DashboardSnapshot, String>{

    Flux<DashboardSnapshot> findbyClientId(String ClientId);

}

мой сервис

@Service
public class SnapshotServiceImpl implements SnapshotService{

    @Autowired
    public SnapshotDao snapshotdao;

    @Override
    public boolean saveSnapshotConfig(DashboardSnapshot snapshotJSON) {
        // TODO Auto-generated method stub

        snapshotdao.save(snapshotJSON);
        return true;
    }

}

Answer 1

@ AksВы должны позвонить по подписке (). Издатель ничего не делает, пока кто-нибудь не подпишется.

snapshotdao.save (снимок JSON). Subscribe ();