Skip to content

Commit

Permalink
refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
belalakhter-alphasquad committed Jan 17, 2024
1 parent de89f56 commit a01c08b
Show file tree
Hide file tree
Showing 9 changed files with 8 additions and 1 deletion.
Binary file modified .gradle/8.3/executionHistory/executionHistory.bin
Binary file not shown.
Binary file modified .gradle/8.3/executionHistory/executionHistory.lock
Binary file not shown.
Binary file modified .gradle/8.3/fileHashes/fileHashes.bin
Binary file not shown.
Binary file modified .gradle/8.3/fileHashes/fileHashes.lock
Binary file not shown.
Binary file modified .gradle/8.3/fileHashes/resourceHashesCache.bin
Binary file not shown.
Binary file modified .gradle/buildOutputCleanup/buildOutputCleanup.lock
Binary file not shown.
Binary file modified .gradle/buildOutputCleanup/outputFiles.bin
Binary file not shown.
8 changes: 8 additions & 0 deletions app/build.gradle.kts
Original file line number Diff line number Diff line change
Expand Up @@ -78,3 +78,11 @@ tasks.named("build") {
dependsOn("jar")
}


tasks.register<JavaExec>("client") {
dependsOn("generateCodecs", "jar")

mainClass.set("playground.app.Main")
classpath = files(tasks.getByName<Jar>("jar").archiveFile.get())
jvmArgs("--add-opens", "java.base/sun.nio.ch=ALL-UNNAMED")
}
1 change: 0 additions & 1 deletion app/src/main/java/playground/app/ClusterClient.java
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,6 @@ public void makeClusterAlive() {
pollingThread = new Thread(() -> {
while (running && !aeronCluster.isClosed()) {
aeronCluster.sendKeepAlive();
System.out.println("Sending Heartbeat to the Cluster!");
aeronCluster.pollEgress();
try {
Thread.sleep(HEARTBEAT_INTERVAL_MS);
Expand Down

0 comments on commit a01c08b

Please sign in to comment.