Hi Guido,
Following the release notes i create a config file like this:
"remote": {
"adapters": {
"gremlin": "akka.remote.transport.FailureInjectorProvider",
"trttl": "akka.remote.transport.ThrottlerProvider"
},
"artery": {
"bind-hostname": "127.0.1.1",
"enabled": "on",
"hostname": "127.0.1.1",
"tcp": {
"bind-port": 2551,
"port": 2551
}
},
"backoff-interval": "5 ms",
"backoff-remote-dispatcher": {
"executor": "fork-join-executor",
"fork-join-executor": {
"parallelism-max": 2,
"parallelism-min": 2
},
"type": "Dispatcher"
},
"command-ack-timeout": "30 s",
"default-remote-dispatcher": {
"executor": "fork-join-executor",
"fork-join-executor": {
"parallelism-max": 2,
"parallelism-min": 2
},
"type": "Dispatcher"
},
"enabled-transports": ["akka.remote.netty.tcp"],
"flush-wait-on-shutdown": "2 s",
"gremlin": {
"debug": "off"
},
"initial-system-message-delivery-timeout": "3 m",
"log-buffer-size-exceeding": 50000,
"log-frame-size-exceeding": "off",
"log-received-messages": "off",
"log-remote-lifecycle-events": "off",
"log-sent-messages": "off",
"netty": {
"ssl": {
"applied-adapters": [],
"backlog": 4096,
"bind-hostname": "",
"bind-port": "",
"client-socket-worker-pool": {
"pool-size-factor": 1,
"pool-size-max": 2,
"pool-size-min": 2
},
"connection-timeout": "15 s",
"enable-ssl": true,
"hostname": "",
"maximum-frame-size": "128000b",
"port": 2552,
"receive-buffer-size": "256000b",
"security": {
"enabled-algorithms": ["TLS_RSA_WITH_AES_128_CBC_SHA"],
"key-password": "changeme",
"key-store": "keystore",
"key-store-password": "changeme",
"protocol": "TLSv1",
"random-number-generator": "",
"trust-store": "truststore",
"trust-store-password": "changeme"
},
"send-buffer-size": "256000b",
"server-socket-worker-pool": {
"pool-size-factor": 1,
"pool-size-max": 2,
"pool-size-min": 2
},
"tcp-keepalive": "on",
"tcp-nodelay": "on",
"tcp-reuse-addr": "off-for-windows",
"transport-class": "akka.remote.transport.netty.NettyTransport",
"transport-protocol": "tcp",
"use-dispatcher-for-io": "",
"write-buffer-high-water-mark": "0b",
"write-buffer-low-water-mark": "0b"
},
"tcp": {
"applied-adapters": [],
"backlog": 4096,
"bind-hostname": "",
"bind-port": "",
"client-socket-worker-pool": {
"pool-size-factor": 1,
"pool-size-max": 2,
"pool-size-min": 2
},
"connection-timeout": "15 s",
"enable-ssl": false,
"hostname": "",
"maximum-frame-size": "128000b",
"port": 2552,
"receive-buffer-size": "256000b",
"send-buffer-size": "256000b",
"server-socket-worker-pool": {
"pool-size-factor": 1,
"pool-size-max": 2,
"pool-size-min": 2
},
"tcp-keepalive": "on",
"tcp-nodelay": "on",
"tcp-reuse-addr": "off-for-windows",
"transport-class": "akka.remote.transport.netty.NettyTransport",
"transport-protocol": "tcp",
"use-dispatcher-for-io": "",
"write-buffer-high-water-mark": "0b",
"write-buffer-low-water-mark": "0b"
},
"udp": {
"applied-adapters": [],
"backlog": 4096,
"bind-hostname": "",
"bind-port": "",
"client-socket-worker-pool": {
"pool-size-factor": 1,
"pool-size-max": 2,
"pool-size-min": 2
},
"connection-timeout": "15 s",
"enable-ssl": false,
"hostname": "",
"maximum-frame-size": "128000b",
"port": 2552,
"receive-buffer-size": "256000b",
"send-buffer-size": "256000b",
"server-socket-worker-pool": {
"pool-size-factor": 1,
"pool-size-max": 2,
"pool-size-min": 2
},
"tcp-keepalive": "on",
"tcp-nodelay": "on",
"tcp-reuse-addr": "off-for-windows",
"transport-class": "akka.remote.transport.netty.NettyTransport",
"transport-protocol": "udp",
"use-dispatcher-for-io": "",
"write-buffer-high-water-mark": "0b",
"write-buffer-low-water-mark": "0b"
}
},
and i had this error:
No transport is loaded for protocol: [artery], available protocols: [akka.
tcp]
akka.remote.RemoteTransportException: No transport is loaded for protocol: [
artery], available protocols: [akka.tcp]
Anyway yes i measured the CouchDB query it's go from 30 to 300 ms more or
less. And i implemented it with future so it should be a blocking
operation, am i right?
Thanks!
Il giorno mercoledì 14 settembre 2016 10:31:43 UTC+2, Guido Medina ha
scritto:
>
> What you have seen for Akka Artery M4 is what is available at the moment,
> I did test it when it was M2 but I haven't done anything with M4 yet,
> for M4 I imagine the same applies as it was for M4, the release notes is
> the guide.
>
> Have you measured your application like you were suggested?
> I imagine you can at least log how many ms takes to query from CouchDB?
> I also imagine at Node 1 your actors querying from CouchDB are running on
> a separate dispatcher because any DB operation is considered to be a
> blocking operation?
>
> I believe you need to figure out where is your bottleneck first.
>
> HTH,
>
> Guido.
>
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
