You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 14 Next »



CPS-821 - Getting issue details... STATUS


Description/Scope

The scope of this spike is to ascertain:

  • How to use messaging (producer, agree topic etc))
  • Using existing rest endpoint with additional flag indicating async response
  • Also consider asynchronous request option using messaging in the proposal

Associated Jira

Key Summary T Created Updated Due Assignee Reporter P Status Resolution
Refresh

Issues/Decisions

#IssueDecisionNotes/Jira
1What topic to use? proposed ncmp-async-xxx

2Agree proposed change to url

3passthrough request need to be able to handle different response types (using accept header) but the async option would have a fixed and possibly different response type.

4How many messages are we expecting at peak time?

5Should we create a standalone app to demo or are tests sufficient?


Proposed Diagram

Rest Endpoint with Async Flag

CurrentProposed

<ncmp>/v1/ch/PNFDemo/data/ds/ncmp-datastore:passthrough-running?resourceIdentifier=stores:bookstore

<ncmp>/v1/ch/PNFDemo/data/async/ds/ncmp-datastore:passthrough-running?resourceIdentifier=stores:bookstore


Kafka config


Response types for passthrough

Will we be able to handle everything "as-is"?

Future or alternative

Whats are Futures?




Java 8 introduced the CompletableFuture class. Along with the Future interface, it also implemented the CompletionStage interface. This interface defines the contract for an asynchronous computation step that we can combine with other steps.

CompletableFuture is at the same time a building block and a framework, with about 50 different methods for composing, combining, and executing asynchronous computation steps and handling errors.


Simple Future Example 
public Future<String> calculateAsync() throws InterruptedException {
    CompletableFuture<String> completableFuture = new CompletableFuture<>();

    Executors.newCachedThreadPool().submit(() -> {
        Thread.sleep(500);
        completableFuture.complete("Hello");
        return null;
    });

    return completableFuture;
}



source: https://www.baeldung.com/java-completablefuture

RequestID Generation

TypeMethod
UUID
String uniqueID = UUID.randomUUID().toString();

Async Request Option using Messaging




  • No labels