public abstract class SourceTcp extends Object
Modifier and Type | Field and Description |
---|---|
protected ChronicleQueueBuilder.ReplicaChronicleQueueBuilder |
builder |
protected ThreadPoolExecutor |
executor |
protected org.slf4j.Logger |
logger |
protected String |
name |
protected net.openhft.lang.thread.LightPauser |
pauser |
protected AtomicBoolean |
running |
Modifier | Constructor and Description |
---|---|
protected |
SourceTcp(String name,
ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder,
ThreadPoolExecutor executor) |
Modifier and Type | Method and Description |
---|---|
boolean |
close() |
protected abstract Runnable |
createHandler() |
protected Runnable |
createSessionHandler(SocketChannel socketChannel)
Creates a session handler according to the Chronicle the sources is connected to.
|
void |
dataNotification() |
abstract boolean |
isLocalhost() |
SourceTcp |
open() |
String |
toString() |
protected final org.slf4j.Logger logger
protected final String name
protected final AtomicBoolean running
protected final ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder
protected final ThreadPoolExecutor executor
protected final net.openhft.lang.thread.LightPauser pauser
protected SourceTcp(String name, ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder, ThreadPoolExecutor executor)
public SourceTcp open()
public boolean close()
public void dataNotification()
public abstract boolean isLocalhost()
protected abstract Runnable createHandler()
protected Runnable createSessionHandler(@NotNull SocketChannel socketChannel)
socketChannel
- The SocketChannel
Copyright © 2017. All rights reserved.