Skip to content

Commit

Permalink
now added a EOF marker via the tailer, as the appender may not have b…
Browse files Browse the repository at this point in the history
…een running when it should have been written.
  • Loading branch information
Rob Austin committed Aug 4, 2016
1 parent c4e0b8d commit a395a8d
Show file tree
Hide file tree
Showing 6 changed files with 263 additions and 71 deletions.
2 changes: 1 addition & 1 deletion pom.xml
Expand Up @@ -49,7 +49,7 @@
<dependency> <dependency>
<groupId>net.openhft</groupId> <groupId>net.openhft</groupId>
<artifactId>chronicle-bom</artifactId> <artifactId>chronicle-bom</artifactId>
<version>1.13.12</version> <version>1.13.13-SNAPSHOT</version>
<type>pom</type> <type>pom</type>
<scope>import</scope> <scope>import</scope>
</dependency> </dependency>
Expand Down
Expand Up @@ -23,6 +23,7 @@
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;


import java.io.File; import java.io.File;
import java.nio.file.Path;


import static net.openhft.chronicle.core.pool.ClassAliasPool.CLASS_ALIASES; import static net.openhft.chronicle.core.pool.ClassAliasPool.CLASS_ALIASES;
import static net.openhft.chronicle.wire.WireType.DEFAULT_ZERO_BINARY; import static net.openhft.chronicle.wire.WireType.DEFAULT_ZERO_BINARY;
Expand Down Expand Up @@ -53,6 +54,11 @@ public static void init() {
// make sure the static block has been called. // make sure the static block has been called.
} }


@NotNull
public static SingleChronicleQueueBuilder binary(@NotNull Path path) {
return binary(path.toFile());
}

@NotNull @NotNull
public static SingleChronicleQueueBuilder binary(@NotNull String basePath) { public static SingleChronicleQueueBuilder binary(@NotNull String basePath) {
return binary(new File(basePath)); return binary(new File(basePath));
Expand Down

0 comments on commit a395a8d

Please sign in to comment.