JarCasting
socketactor-jumi
Provides SocketChannelActor, making it easy to create TCP clients/servers using the jumi-actors framework.
Usage
Add the following dependencies to your pom.xml:
<dependency>
<groupId>net.avh4.util.socket</groupId>
<artifactId>socketactor-jumi</artifactId>
<version>0.0.1</version>
</dependency>
To create a TCP client, you will first need to initialize jumi-actors:
ExecutorService threadPool = Executors.newCachedThreadPool();
Actors actors = new MultiThreadedActors(threadPool,
new DynamicEventizerProvider(),
new CrashEarlyFailureHandler(),
new PrintStreamMessageLogger(System.out));
ActorThread actorThread = actors.startActorThread();
Now you can create your received and disconnected callbacks: (If your TCP protocol is not line-based, use BytesListener instead of LinesListener.)
ActorRef<Socket> socket;
ActorRef<LineListener> listener = actorThread.bindActor(LineListener.class,
new LineListener() {
@Override public void receivedLine(String line) {
System.out.println("RECEIVED: " + line);
socket.tell().next();
}
@Override public void disconnected(Throwable cause) {
System.out.println("DISCONNECTED: " + cause.getLocalizedMessage());
}
});
Now connect your client to a server: (If your TCP protocol is not line-based, use SocketChannelActor.bytesSocketChannelActor instead of linesSocketChannelActor.)
socket = actorThread.bindActor(Socket.class,
SocketChannelActor.linesSocketChannelActor(host, port, listener));
socket.tell().connect(listener);
socket.tell().write(listener, "currentsong\n".getBytes());
Build commands
- Mutation coverage:
mvn clean test org.pitest:pitest-maven:mutationCoverage