eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-24 14:38:45 +00:00
Code Activity

bug4811: interims commit regarding replication parameter building

Browse Source
This commit is contained in:
Axel Uhl
2020-11-04 01:46:47 +01:00
parent d98894a919
commit 47af8ee26b
7 changed files with 213 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sailing.landscape.test/src/com/sap/sailing/landscape/test/TestProcedures.java
+9
View File
@@ -16,9 +16,11 @@ import com.sap.sailing.landscape.SailingAnalyticsHost;
import com.sap.sailing.landscape.SailingAnalyticsMaster;
import com.sap.sailing.landscape.SailingAnalyticsMetrics;
import com.sap.sailing.landscape.SailingAnalyticsReplica;
import com.sap.sailing.landscape.impl.BearerTokenReplicationCredentials;
import com.sap.sailing.landscape.procedures.StartSailingAnalyticsMaster;
import com.sap.sse.common.Duration;
import com.sap.sse.common.TimePoint;
import com.sap.sse.landscape.ReplicationConfiguration;
import com.sap.sse.landscape.aws.AwsLandscape;
import com.sap.sse.landscape.aws.Tags;
import com.sap.sse.landscape.aws.impl.AwsRegion;
@@ -41,11 +43,14 @@ public class TestProcedures {
private static final Optional<Duration> optionalTimeout = Optional.of(Duration.ONE_MINUTE.times(10));
private AwsLandscape<String, SailingAnalyticsMetrics, SailingAnalyticsMaster<String>, SailingAnalyticsReplica<String>> landscape;
private AwsRegion region;
private final static String SECURITY_SERVICE_REPLICATION_BEARER_TOKEN = "security.service.replication.bearer.token";
private String securityServiceReplicationBearerToken;
@Before
public void setUp() {
landscape = AwsLandscape.obtain();
region = new AwsRegion(Region.EU_WEST_2);
securityServiceReplicationBearerToken = System.getProperty(SECURITY_SERVICE_REPLICATION_BEARER_TOKEN);
}
@Test
@@ -63,6 +68,10 @@ public class TestProcedures {
.setCommaSeparatedEmailAddressesToNotifyOfStartup("axel.uhl@sap.com")
.setTags(Optional.of(Tags.with("Hello", "World")))
.setOptionalTimeout(optionalTimeout)
.setReplicationConfiguration(ReplicationConfiguration.builder()
.setCredentials(new BearerTokenReplicationCredentials(securityServiceReplicationBearerToken))
.build())
.setRabbitConfiguration(landscape.getDefaultRabbitConfiguration(region))
.build();
startSailingAnalyticsMaster.run();
final SailingAnalyticsHost<String> host = startSailingAnalyticsMaster.getHost();