Akka is a toolkit and runtime for building highly concurrent, distributed, and resilient message-driven applications on the JVM.
Questions tagged [akka-io]
17 questions
8
votes
1 answer
Akka TCP client: How can I send a message over TCP using akka actor
I want to send textual messages over TCP. Pretty easy. I want to do so with akka. I read this article about akka IO:
http://doc.akka.io/docs/akka/snapshot/scala/io-tcp.html
The article present a simple implementation of a TCP client, but it's not…
polo
- 1,352
- 2
- 16
- 35
4
votes
1 answer
Why does connection close automatically after 1 minute using Akka TCP?
I'm writing an Interactive Broker API using Scala and Akka actors.
I have a Client actor that connects to the server and communicate with the IO manager to send requests and receive responses from TWS. The connection works fine and I'm able to send…
Fede
- 804
- 1
- 10
- 21
3
votes
1 answer
Sending large messages ( > 200MB) in Akka Cluster
I have to send large messages of size around 200MB in akka-cluster from one actor to multiple actors. I have tried using the akka messaging but it times out as it is taking a long time.
What is the best way to implement this? I have read somewhere…
Laxman Vemula
- 61
- 4
3
votes
2 answers
Initializing an akka actor using Akka-IO TCP
Using Akka-IO TCP, the procedure to establish connection in an actor is as follow:
class MyActor(remote: InetSocketAddress) extends Actor {
IO(Tcp) ! Connect(remote) //this is the first step, remote is the address to connect to
def receive…
vptheron
- 7,426
- 25
- 34
2
votes
0 answers
Akka.io.TCP with SSL
I'm implementing the client side of a protocol (over TCP) which is talking to a server using akka.io.TCP. Depending on how this server is configured, it may or may not support SSL.
To determine whether it supports SSL, first a plain text message is…
irundaia
- 1,720
- 17
- 25
2
votes
1 answer
Akka 2.4 TCP w/ TLS
I'm trying to figure out how to use TLS (or SSL) with Akka IO. I realize that the pipeline stuff has been ripped out of Akka. They mentioned that they will have something shiny and new in the 2.4 release of Akka, but I don't see anything in the…
threejeez
- 2,314
- 6
- 30
- 51
2
votes
2 answers
Were pipelines removed from akka i/o?
While learning how to use akka I/O I am trying to implement a simple protocal on top of akka i/o and was following the documentation here.
However in my gradle file I use version 2.3.9 as shown below
dependencies {
compile group: 'org.slf4j',…
Bwire
- 1,181
- 1
- 14
- 25
1
vote
1 answer
Akka Stream, Tcp().bind, handle when the client close the socket
I'm quite new in Akka Stream and I'd like to learn how handle a TCP socket for a project of mine. I took this piece of code from the Akka Stream official documentation.
import akka.stream.scaladsl.Framing
val connections: Source[IncomingConnection,…
lucataglia
- 728
- 5
- 18
1
vote
1 answer
Akka and watching a variable with a Future
A Tcp.OuttgoingConnection gathers data from an audio mixer and is send async to a sourceQueue, which processes the data.
After issuing a command there is no guarantee the next bit of data is the response. How can I feed back the response?
A 'dirty'…
Luuk D. Jansen
- 4,402
- 8
- 47
- 90
1
vote
1 answer
Sending non-ByteString over Tcp Client using Akka IO
I am using akka-io to create a Tcp Client Actor that communicates with a non-jvm tcp (non-akka) server over a socket. Because akka-io sends ByteString and the program expects a regular String outputted to it, the ByteString message is never…
Zee
- 1,321
- 2
- 18
- 41
1
vote
1 answer
Can you refresh or redisplay unflushed telnet input?
I'm writing an old school text based telnet server that right now is a glorified chat room in Scala with Akka actor based IO. What is happening is that client the client will start to type something and then an event will happen and when it gets…
kapunga
- 436
- 3
- 7
0
votes
1 answer
Bytestring to normal chars. python's struct.pack
I've this python code that generates bytes
import threading
import socket
import struct
import time
from datetime import datetime
import random
TICKERS = ["AAPL", "GOOG", "MSFT", "SPY"]
timestamp = datetime.utcnow()
ticker =…
Alexander Kondaurov
- 3,677
- 5
- 42
- 64
0
votes
1 answer
System.TypeLoadException: Cannot instantiate transport [Akka.Remote.AkkaIOTransport.AkkaIOTransport, Akka.Remote.AkkaIOTransport].
I came across this error while trying out the AKKA.NET IO following this tutorial:
http://getakka.net/docs/IO#akka-i-o
I get this error:
System.TypeLoadException: Cannot instantiate transport [Akka.Remote.AkkaIOTransport.AkkaIOTransport,…
Nikola Schou
- 2,386
- 3
- 23
- 47
0
votes
1 answer
Streaming data from an actor to Play Result
I have data arriving at an actor in chunks and would like to return those chunks as a stream in a Play Result. Since the only way to get a response from Ok.stream looks like the ideal candidate, something like this:
Action.async { request =>
…
Arne Claassen
- 14,088
- 5
- 67
- 106
0
votes
1 answer
How to increase Tcp Chunk size in Akka IO using Tcp
I am using Akka-Cluster and sending large objects over network using Akka IO through Tcp. The data is being cut down into very small chunks. The size of the data ByteString received through 'Received' message is very small (around 7KB). Is there any…
Laxman Vemula
- 61
- 4