akka ищет настройки конфигурации

У меня есть следующий класс, который создает систему акторов и предоставляет конфигурацию в виде строки в коде. Однако я получаю исключение, что netty не может быть запущен на хосте и порту по умолчанию - когда я указал разные значения в конфигах

class RemoteActorSystemCreator extends ActorSystemCreator {

    def create(name: String, hostName: String, port: String) = {

        val string: Config = ConfigFactory.parseString(
            s"""akka {
                        actor {
                            provider = "akka.remote.RemoteActorRefProvider"
                        }
                        remote {
                            enabled-transports = ["akka.remote.netty.tcp"]
                            netty.tcp {
                                hostname = "$hostName"
                                port = $port
                            }
                        }
                }"""
        )
        ActorSystem.create(name, ConfigFactory.load(string))
    }
}

org.jboss.netty.channel.ChannelException: Failed to bind to: /127.0.1.1:2552
    at org.jboss.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:298)
    at akka.remote.netty.NettyRemoteServer.start(Server.scala:51)
    at akka.remote.netty.NettyRemoteTransport.start(NettyRemoteSupport.scala:181)
org.jboss.netty.channel.ChannelException: Failed to bind to: /127.0.1.1:2552

person Nick    schedule 14.06.2013    source источник


Ответы (1)


Вы используете Akka версии 2.1.x, но конфигурация имеет формат 2.2. Для версии 2.1.4 свойство конфигурации для порта — akka.remote.netty.port.

person Patrik Nordwall    schedule 14.06.2013
comment
да, только что сам это обнаружил. Спасибо - person Nick; 15.06.2013