in src/main/java/deltix/ember/sample/RiskUpdateSample.java [13:28]
public static void main(String[] args) throws InterruptedException {
sendRequest(
(publication) -> {
MutableRiskUpdateRequest request = createRiskUpdateRequest();
publication.onRiskUpdateRequest(request);
System.out.println("Sent risk update request " + request);
try {
Thread.sleep(30000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
);
}