Skip to content

Commit

Permalink
post-rebase fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
Horusiath committed Feb 5, 2017
1 parent 5ac02e8 commit 6722539
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 3 deletions.
7 changes: 7 additions & 0 deletions src/core/Akka.Remote/Transport/DotNetty/DotNettyTransport.cs
Original file line number Diff line number Diff line change
Expand Up @@ -122,6 +122,13 @@ protected DotNettyTransport(ActorSystem system, Config config)
{
System = system;
Config = config;

if (system.Settings.Config.HasPath("akka.remote.helios.tcp"))
{
var heliosFallbackConfig = system.Settings.Config.GetConfig("akka.remote.helios.tcp");
config = heliosFallbackConfig.WithFallback(config);
}

Settings = DotNettyTransportSettings.Create(config);
Log = Logging.GetLogger(System, GetType());
serverEventLoopGroup = new MultithreadEventLoopGroup(Settings.ServerSocketWorkerPoolSize);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

namespace Akka.Remote.Transport.DotNetty
{
public sealed class DotNettyTransportSettings
internal sealed class DotNettyTransportSettings
{
public static DotNettyTransportSettings Create(ActorSystem system)
{
Expand Down Expand Up @@ -219,13 +219,13 @@ private static int ComputeWorkerPoolSize(Config config)
ByteOrder = byteOrder;
}
}
public enum TransportMode
internal enum TransportMode
{
Tcp,
Udp
}

public sealed class SslSettings
internal sealed class SslSettings
{
public static readonly SslSettings Empty = new SslSettings();
public static SslSettings Create(Config config)
Expand Down

0 comments on commit 6722539

Please sign in to comment.