Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Akka.NET v1.0.4 Production Release #1219

Merged
merged 156 commits into from
Aug 7, 2015
Merged
Changes from 2 commits
Commits
Show all changes
156 commits
Select commit Hold shift + click to select a range
1c56952
added version number for next release of Akka.NET to RELEASE_NOTES fo…
Aaronontheweb Jun 3, 2015
2e01835
Fixed serialization of NoSender actor.
ssoshchepkov Jun 3, 2015
a39d7ad
Fixed deserialization of NoSender actor.
ssoshchepkov Jun 3, 2015
cd7aee8
Merge pull request #1037 from ssoshchepkov/nosender-serialization-fix…
Aaronontheweb Jun 3, 2015
7fa0d3c
Revert "Fixes for NoSender serialization bugs"
Aaronontheweb Jun 3, 2015
7229cf4
Merge pull request #1039 from akkadotnet/revert-1037-nosender-seriali…
Aaronontheweb Jun 3, 2015
9da13bf
Merge pull request #1034 from Aaronontheweb/vnext
skotzko Jun 3, 2015
c6faab3
pass exception to NLogLogger exception logging
ashic Jun 3, 2015
4c3c7cf
Merge pull request #1040 from ashic/nlog-exceptions
Aaronontheweb Jun 4, 2015
393414c
Changed NoSender to null as in the scala version.
ssoshchepkov Jun 3, 2015
d462e0d
Skipped broken test (Type assertion on null message causes NullRefere…
ssoshchepkov Jun 5, 2015
5ff3e12
Merge pull request #1041 from ssoshchepkov/nosender-serialization-fix…
rogeralsing Jun 5, 2015
af23526
Update README.md
rogeralsing Jun 8, 2015
bad5413
Update README.md
rogeralsing Jun 9, 2015
55d2e28
Logging message/template fixes
rogeralsing Jun 9, 2015
1cb4368
context bug
rogeralsing Jun 10, 2015
d6e2fcb
Merge pull request #1051 from rogeralsing/persistence-replay-messages…
Horusiath Jun 10, 2015
e4a61cc
F# API - ask wrapper + making messages of wrong types unhandled
Horusiath Jun 11, 2015
4d0bb2e
fix SqlServer snapshot query builder + making Akka.Persistence.TestKi…
Horusiath Jun 11, 2015
36cdfc2
Fixes #1038
Jun 11, 2015
a042978
Merge pull request #1054 from Horusiath/akka-persistence-testkit-sqls…
Aaronontheweb Jun 11, 2015
0085540
Merge pull request #1048 from rogeralsing/logging-templates
Aaronontheweb Jun 11, 2015
b2da5e3
Merge pull request #1055 from jkodroff/1038-move-structuremap-example
Aaronontheweb Jun 11, 2015
525ddf8
bringing in latest changes from master to dev
Aaronontheweb Jun 12, 2015
0602f8b
Merge pull request #1059 from Aaronontheweb/v1.0.3-dev
Aaronontheweb Jun 12, 2015
9e19981
added v1.0.4 release # for nightly builds
Aaronontheweb Jun 12, 2015
0ff298c
Merge pull request #1060 from Aaronontheweb/v1.0.3-dev
Aaronontheweb Jun 12, 2015
015e97f
HOCON config key for replay receive timeout for AsyncWriteProxy
Horusiath Jun 18, 2015
8b00423
Merge pull request #1066 from Horusiath/persistence-async-proxy-confi…
rogeralsing Jun 18, 2015
c9c7914
RemoteDaemon bug, not removing children
rogeralsing Jun 17, 2015
ecbc17d
Removed extremely old legacy code
rogeralsing Jun 20, 2015
0034bb1
Updated actorref Serialization according to JVM.
rogeralsing Jun 20, 2015
fb03e9d
Removed all uses of the ThreadStatic `CurrentTransport` from the code…
rogeralsing Jun 20, 2015
618ae8a
Fixed broken snapshot store serialization
rogeralsing Jun 20, 2015
20d2e64
SnapshotStoreSpec not implementing default snapshot store by default
Horusiath Jun 22, 2015
76a76f4
Merge pull request #1081 from Horusiath/snapshot-store-spec-fix
rogeralsing Jun 22, 2015
442615d
set multinodetests to run on 'all' builds
Aaronontheweb Jun 23, 2015
443a4b4
Merge pull request #1053 from Horusiath/fsapi-fixes
rogeralsing Jun 23, 2015
3f68270
Removed RemoteDeploySpec
rogeralsing Jun 23, 2015
74175ff
Merge pull request #1086 from rogeralsing/remove-remotedeploy
Aaronontheweb Jun 23, 2015
9655e9c
Merge pull request #1068 from rogeralsing/remotedaemon-deathwatchnoti…
Aaronontheweb Jun 23, 2015
737d8ba
ignoring routing tests due to known bugs
Aaronontheweb Jun 23, 2015
46b5d05
commenting out known buggy tests since Skip does not work #1088
Aaronontheweb Jun 23, 2015
d85625e
Merge pull request #1083 from Aaronontheweb/multinodetests-production
rogeralsing Jun 23, 2015
ed0350a
Enable remote watching from RemoteSystemDaemon
rogeralsing Jun 23, 2015
62b41b7
Merge pull request #1091 from rogeralsing/enable-remotewatch-from-daemon
Aaronontheweb Jun 23, 2015
9b79ddc
Fixed build scripts to work around known issues with Mono 4.0
Aaronontheweb Jun 24, 2015
a76c89a
[api-doc] Documentation of namespaces
sean-gilliam Jun 24, 2015
c5de8bc
Merge pull request #1095 from sean-gilliam/namespace-summaries
Aaronontheweb Jun 24, 2015
6042eb2
Merge pull request #1093 from Aaronontheweb/mono-toolchain-fix
stefansedich Jun 24, 2015
747946c
akkadotnet/akka.net#1065 broken test when running mutitple nunit tests
garethbudden Jun 23, 2015
0a55437
fixes #1062 nunit testkit create new actorsystem for each test
garethbudden Jun 23, 2015
d7b1c8f
NUnit TestKit call AfterAll on TearDown and NotSupportedException if …
garethbudden Jun 25, 2015
14746f8
fixing repeated remote rewatch
rogeralsing Jun 25, 2015
d69a7a7
Merge pull request #1099 from rogeralsing/remote-repeat-rewatch-fix
Aaronontheweb Jun 26, 2015
06a8b3e
upgraded version of XUnit test runner to 2.0.0 for Mono builds
Aaronontheweb Jun 26, 2015
df7e34c
Merge pull request #1092 from garethbudden/1065-destroy-actorsystem-a…
Aaronontheweb Jun 26, 2015
b85ea35
Implemented BackoffSupervisor
Horusiath Jun 25, 2015
9bf0dbe
Merge pull request #1102 from Aaronontheweb/xunit2-mono-build
rogeralsing Jun 27, 2015
f1ee394
close #998
Aaronontheweb Jun 28, 2015
147cc69
Merge pull request #1106 from Aaronontheweb/fix-998
rogeralsing Jun 29, 2015
9518aa5
Merge pull request #1098 from Horusiath/backoff-supervisor
Aaronontheweb Jun 29, 2015
ec77845
Merged the Akka.Actor.Internals and Akka.Actor.Internal namespaces
sean-gilliam Jun 30, 2015
8433405
Merge pull request #1109 from sean-gilliam/internals-to-internal-name…
rogeralsing Jul 1, 2015
cbf5dcc
Resolver now uses GetOrAdd not TryAdd
Jul 2, 2015
1d04f39
Revert "Synchronize akka-io with dev"
Aaronontheweb Jul 2, 2015
45a9e28
adding the latest ncrunch files to gitignore
geertvl Jul 2, 2015
a1c1d9d
Initial Akka IO port with TCP driver
fergusn Mar 31, 2015
a60364a
Akka IO UDP driver port
fergusn Jun 12, 2015
d9e3993
Akka IO - DNS Port
fergusn Jun 17, 2015
9fe0dae
Akka IO: added copyright header to new DNS and UDP files
fergusn Jun 17, 2015
e72b5a6
created an example project for TCP echo server
Horusiath Jun 19, 2015
4e18b9b
Akka IO: fixed bug in DNS Manager
fergusn Jun 18, 2015
0990253
Akka IO: Remote Transport and bug fixes
fergusn Jun 21, 2015
c11806b
Akka IO: fixes #1070 - StackOverflowException received when ByteStri…
fergusn Jun 22, 2015
88b788e
Akka IO: Ported TcpIntegrationSpec and missing tests in TcpConnection…
fergusn Jun 24, 2015
9673d1b
Akka IO: Fixes #1113 - ByteString1C indexer always returns first element
fergusn Jul 2, 2015
19b9228
synchronized with dev branch
Horusiath Jul 2, 2015
408ad7d
Merge pull request #1117 from Horusiath/akka-io-to-dev
Horusiath Jul 2, 2015
9f3b3ff
Merge pull request #1118 from akkadotnet/revert-1117-akka-io-to-dev
Aaronontheweb Jul 2, 2015
d2d205c
Merge pull request #1114 from sblackler/NinjectTypeCacheFix
rogeralsing Jul 2, 2015
c840732
Fix for #1126
rogeralsing Jul 7, 2015
ebc46e9
Json.NET 7, removing DU hacks
rogeralsing Jul 7, 2015
44f6f21
This fixes a bug in the remotedaemonmsgserializer that incorrectly pa…
rogeralsing Jul 8, 2015
db6bbb4
Added "apartment" setting for PinnedDispatcher
kekekeks Jul 8, 2015
14ac01d
Either usability improvements
kekekeks Jul 8, 2015
6b14443
Merge pull request #1130 from rogeralsing/daemon-msg-serializer-route…
Aaronontheweb Jul 8, 2015
06fd544
Merge pull request #1116 from GeertVL/dev
Aaronontheweb Jul 8, 2015
af146b0
Merge pull request #1132 from kekekeks/either
Aaronontheweb Jul 8, 2015
85c60ce
Name shouldn't be mandatory for DedicatedThreadPool
kekekeks Jul 8, 2015
470a63d
Merge pull request #1131 from kekekeks/apartment
Aaronontheweb Jul 8, 2015
42d46f7
[tools] Script to check source files for copyright banner
sean-gilliam Jul 8, 2015
32e2cae
Merge pull request #1135 from sean-gilliam/check-for-copyright-notice
Aaronontheweb Jul 8, 2015
fd9619f
Merge pull request #1128 from rogeralsing/json-net-7
Aaronontheweb Jul 9, 2015
aedbcf9
A virtual time scheduler for testing
raypurchasett Jul 9, 2015
6cc7b30
Merge pull request #1137 from sadprofessor/VirtualTimeScheduler
Aaronontheweb Jul 9, 2015
630d51a
[misc] Added copyright banner to files
sean-gilliam Jul 9, 2015
35ae6fc
Merge pull request #1138 from sean-gilliam/copyright-headers
Aaronontheweb Jul 9, 2015
5defe8a
Added Akka.TestKit.XUnit2 as a NuGet dependency for Akka.Persistence.…
Aaronontheweb Jul 9, 2015
e7cf05f
Setting SourceContext properly so it is reported as a path of the log…
tstojecki Jul 13, 2015
5d39e2a
Merge pull request #1144 from tstojecki/dev
Aaronontheweb Jul 13, 2015
3ab3f7f
fixed bug where new ActorSystem UID was generated on every call
Aaronontheweb Jul 14, 2015
40bea71
Akka IO port
fergusn Jul 14, 2015
91117d8
Fix for bug #1149: LocalSnapshotStore failing on pid using forbidden …
Horusiath Jul 14, 2015
b817ebc
new config setting akka.persistence.xyz.connection-string-name
Horusiath Jul 14, 2015
9f10468
Merge pull request #1142 from willieferguson/akka-io-merge
Aaronontheweb Jul 14, 2015
5fd1c04
Akka.NET Dependency Injection testkit for #942
Aaronontheweb Jul 14, 2015
81b1111
Merge pull request #1150 from Horusiath/local-snapshot-bugfix-1149
Aaronontheweb Jul 14, 2015
81f4b36
Merge pull request #1141 from Aaronontheweb/fix-1101
stefansedich Jul 14, 2015
9908298
Merge pull request #1147 from Aaronontheweb/addressuid-fix
stefansedich Jul 14, 2015
68386ea
Akka IO: fixes #1153
fergusn Jul 15, 2015
0f6366d
Clean up config usage for TestScheduler tests
raypurchasett Jul 15, 2015
01f7426
Merge pull request #1151 from Horusiath/persistence-sql-connection-st…
Aaronontheweb Jul 15, 2015
0d2a05c
Merge pull request #1156 from sadprofessor/VirtualTimeScheduler2
Aaronontheweb Jul 15, 2015
76db770
[misc] fixed copyright headers for Akka.IO
sean-gilliam Jul 15, 2015
dfe68b0
removed NuGet key from FAKE messages
Aaronontheweb Jul 15, 2015
3c2d392
Merge pull request #1157 from sean-gilliam/fix-copyright-headers
Aaronontheweb Jul 15, 2015
f9f24cb
Merge pull request #1158 from Aaronontheweb/fake-remove-key
skotzko Jul 15, 2015
b1f2f6a
[api-doc][misc] fixed various typos
sean-gilliam Jul 15, 2015
9923aa6
Merge pull request #1159 from sean-gilliam/fix-typos
Aaronontheweb Jul 15, 2015
27cd38d
Merge pull request #1155 from willieferguson/issue-1153
Aaronontheweb Jul 15, 2015
f92cb3d
[docs] Fixed documentation links
sean-gilliam Jul 16, 2015
f8e97ea
Merge pull request #1162 from sean-gilliam/fix-doc-links
rogeralsing Jul 16, 2015
8df18e9
Merge pull request #1139 from Aaronontheweb/di-testkit-squash
stefansedich Jul 16, 2015
fe94722
Adds support for a default Ask time in HOCON conf.
jordansjones Jul 18, 2015
2a34889
removed debug code from earlier F# DU serialization fix
rogeralsing Jul 18, 2015
32ed355
Merge pull request #1166 from jordansjones/issue-1163
rogeralsing Jul 18, 2015
bd7dbe9
Merge pull request #1168 from rogeralsing/json-defaultsettings-bugfix
Aaronontheweb Jul 18, 2015
5b23783
Added HoconObject.Merge support
rogeralsing Jul 17, 2015
5699658
Merge pull request #1169 from rogeralsing/hocon-updates
Aaronontheweb Jul 19, 2015
38cebd0
implemented remotingterminator
Aaronontheweb Jul 15, 2015
d3ce9c0
add waffle.io badges & more info about contributing
skotzko Jul 21, 2015
6d59b76
add link to issues on next milestone
skotzko Jul 21, 2015
d434cd5
Replace SystemNanoTime with MonotonicClock. #1148
jordansjones Jul 21, 2015
051b07f
Merge pull request #1174 from jordansjones/issue-1148
Aaronontheweb Jul 21, 2015
11e86b9
Merge pull request #1154 from Aaronontheweb/remoting-terminator
rogeralsing Jul 21, 2015
7513e6b
Merge pull request #1173 from skotzko/dev
rogeralsing Jul 21, 2015
490dc8b
Cleaned up some broken bitwise operations
rogeralsing Jul 22, 2015
7a2957c
Merge pull request #1176 from rogeralsing/dev
stefansedich Jul 22, 2015
93240d8
Remove dependency injection examples to reduce build time.
jordansjones Jul 24, 2015
64211cd
Merge pull request #1180 from jordansjones/issue-1171
rogeralsing Jul 24, 2015
7cf19aa
basic Akka.Persistence benchmark app
Horusiath Jul 28, 2015
42de92c
fixed #1194
Aaronontheweb Jul 30, 2015
fb4dbca
Merge pull request #1187 from Horusiath/persistence-benchmark
Aaronontheweb Jul 30, 2015
e6ca2ac
Merge pull request #1195 from Aaronontheweb/1194-fix
rogeralsing Aug 3, 2015
e8327b1
Replaced generic exceptions with more specific ones
sean-gilliam Aug 4, 2015
1443043
Update FsPickler version used by Akka.FSharp
rdavisau Aug 5, 2015
0969040
Merge pull request #1205 from sean-gilliam/specific-exceptions
Aaronontheweb Aug 5, 2015
1507057
Merge pull request #1207 from rdavisau/update-fspickler
Aaronontheweb Aug 5, 2015
91c86c4
FSharp API: fixed problem with jobject deserialization
Horusiath Aug 3, 2015
89ec2ed
resolves #1212
Aaronontheweb Aug 7, 2015
440ead2
Merge pull request #1213 from Aaronontheweb/fix-1212
rogeralsing Aug 7, 2015
3a89069
Merge pull request #1203 from Horusiath/fsapi-jobject-deserialization
Aaronontheweb Aug 7, 2015
7d756cd
added release notes for Akka.NET v1.0.4
Aaronontheweb Aug 7, 2015
581ec04
Merge pull request #1217 from Aaronontheweb/1.0.4-release-notes
rogeralsing Aug 7, 2015
683a7ec
v1.0.4 release
Aaronontheweb Aug 7, 2015
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions src/core/Akka.Cluster/Cluster.cs
Original file line number Diff line number Diff line change
@@ -295,12 +295,12 @@ public void LogInfo(string message)

public void LogInfo(string template, object arg1)
{
_log.Info(String.Format("Cluster Node [{0}] - " + template, SelfAddress, arg1));
_log.Info("Cluster Node [{0}] - " + template, SelfAddress, arg1);
}

public void LogInfo(string template, object arg1, object arg2)
{
_log.Info(String.Format("Cluster Node [{0}] - " + template, SelfAddress, arg1, arg2));
_log.Info("Cluster Node [{0}] - " + template, SelfAddress, arg1, arg2);
}
}
}
Original file line number Diff line number Diff line change
@@ -259,18 +259,18 @@ public ChaosDestination(IActorRef probe)
{
if (ChaosSupportExtensions.ShouldFail(_confirmFailureRate))
{
Log.Error(string.Format("[destination] confirm message failed (message = {0}, {1})", m.DeliveryId, m.I));
Log.Error("[destination] confirm message failed (message = {0}, {1})", m.DeliveryId, m.I);
}
else if (State.Contains(m.I))
{
Log.Debug(string.Format("[destination] ignored duplicate (message = {0}, {1})", m.DeliveryId, m.I));
Log.Debug("[destination] ignored duplicate (message = {0}, {1})", m.DeliveryId, m.I);
Sender.Tell(new Confirm(m.DeliveryId, m.I));
}
else
{
this.Add(m.I);
Sender.Tell(new Confirm(m.DeliveryId, m.I));
Log.Debug(string.Format("[destination] received and confirmed (message = {0}, {1})", m.DeliveryId, m.I));
Log.Debug("[destination] received and confirmed (message = {0}, {1})", m.DeliveryId, m.I);
}
});
}
6 changes: 3 additions & 3 deletions src/core/Akka.Remote.TestKit/Conductor.cs
Original file line number Diff line number Diff line change
@@ -281,21 +281,21 @@ public void OnDisconnect(HeliosConnectionException cause, IConnection closedChan

public void OnMessage(object message, IConnection responseChannel)
{
_log.Debug(string.Format("message from {0}: {1}", responseChannel.RemoteHost, message));
_log.Debug("message from {0}: {1}", responseChannel.RemoteHost, message);
if (message is INetworkOp)
{
_clients[responseChannel].Tell(message);
}
else
{
_log.Debug(string.Format("client {0} sent garbage `{1}`, disconnecting", responseChannel.RemoteHost, message));
_log.Debug("client {0} sent garbage `{1}`, disconnecting", responseChannel.RemoteHost, message);
responseChannel.Close();
}
}

public void OnException(Exception ex, IConnection erroredChannel)
{
_log.Warning(string.Format("handled network error from {0}: {1}", erroredChannel.RemoteHost, ex.Message));
_log.Warning("handled network error from {0}: {1}", erroredChannel.RemoteHost, ex.Message);
}
}

3 changes: 1 addition & 2 deletions src/core/Akka.Remote/Endpoint.cs
Original file line number Diff line number Diff line change
@@ -1225,9 +1225,8 @@ private bool WriteSend(EndpointManager.Send send)
"Internal error: Endpoint is in state Writing, but no association handle is present.");
if (_provider.RemoteSettings.LogSend)
{
var msgLog = string.Format("RemoteMessage: {0} to [{1}]<+[{2}] from [{3}]", send.Message,
_log.Debug("RemoteMessage: {0} to [{1}]<+[{2}] from [{3}]", send.Message,
send.Recipient, send.Recipient.Path, send.SenderOption ?? _system.DeadLetters);
_log.Debug(msgLog);
}

var pdu = _codec.ConstructMessage(send.Recipient.LocalAddressToUse, send.Recipient,
2 changes: 1 addition & 1 deletion src/core/Akka.Remote/Transport/AkkaProtocolTransport.cs
Original file line number Diff line number Diff line change
@@ -609,7 +609,7 @@ private void InitializeFSM()
})
.Default(d =>
{
_log.Debug(string.Format("Expected message of type Associate; instead received {0}", d));
_log.Debug("Expected message of type Associate; instead received {0}", d);
//Expect handshake to be finished, dropping connection
SendDisassociate(wrappedHandle, DisassociateInfo.Unknown);
nextState = Stop();
Original file line number Diff line number Diff line change
@@ -228,9 +228,8 @@ public bool ShouldDropInbound(Address remoteAddress, object instance, string deb
var drop = mode as Drop;
if (Rng.NextDouble() <= drop.InboundDropP)
{
var logString = string.Format("Dropping inbound [{0}] for [{1}] {2}", instance.GetType(),
remoteAddress, debugMessage);
if(_shouldDebugLog) _log.Debug(logString);
if (_shouldDebugLog) _log.Debug("Dropping inbound [{0}] for [{1}] {2}", instance.GetType(),
remoteAddress, debugMessage);
return true;
}
}
@@ -247,8 +246,8 @@ public bool ShouldDropOutbound(Address remoteAddress, object instance, string de
var drop = mode as Drop;
if (Rng.NextDouble() <= drop.OutboundDropP)
{
var logString = string.Format("Dropping outbound [{0}] for [{1}] {2}", instance.GetType(), remoteAddress, debugMessage);
if (_shouldDebugLog) _log.Debug(logString);
if (_shouldDebugLog)
_log.Debug("Dropping outbound [{0}] for [{1}] {2}", instance.GetType(), remoteAddress, debugMessage);
return true;
}
}
5 changes: 2 additions & 3 deletions src/core/Akka/Actor/FSM.cs
Original file line number Diff line number Diff line change
@@ -184,8 +184,7 @@ public void Schedule(IActorRef actor, TimeSpan timeout)
if(_debugLog != null)
send = () =>
{
_debugLog.Debug("{3}Timer '{0}' went off. Sending {1} -> {2}", name, message, actor,
_ref.IsCancellationRequested ? "Cancelled " : "");
_debugLog.Debug("{0}Timer '{1}' went off. Sending {2} -> {3}",_ref.IsCancellationRequested ? "Cancelled " : "", name, message, actor);
actor.Tell(this, Context.Self);
};
else
@@ -691,7 +690,7 @@ private StateFunction HandleEventDefault
{
return delegate(Event<TData> @event)
{
_log.Warning(String.Format("unhandled event {0} in state {1}", @event.FsmEvent, StateName));
_log.Warning("unhandled event {0} in state {1}", @event.FsmEvent, StateName);
return Stay();
};
}
10 changes: 3 additions & 7 deletions src/core/Akka/Serialization/Serialization.cs
Original file line number Diff line number Diff line change
@@ -45,8 +45,7 @@ public Serialization(ExtendedActorSystem system)
var serializerType = Type.GetType(serializerTypeName);
if (serializerType == null)
{
system.Log.Warning(string.Format("The type name for serializer '{0}' did not resolve to an actual Type: '{1}'",
kvp.Key, serializerTypeName));
system.Log.Warning("The type name for serializer '{0}' did not resolve to an actual Type: '{1}'",kvp.Key, serializerTypeName);
continue;
}

@@ -64,17 +63,14 @@ public Serialization(ExtendedActorSystem system)
if (messageType == null)
{

system.Log.Warning(string.Format(
"The type name for message/serializer binding '{0}' did not resolve to an actual Type: '{1}'",
serializerName, typename));
system.Log.Warning("The type name for message/serializer binding '{0}' did not resolve to an actual Type: '{1}'",serializerName, typename);
continue;
}

var serializer = namedSerializers[serializerName];
if (serializer == null)
{
system.Log.Warning(string.Format(
"Serialization binding to non existing serializer: '{0}'", serializerName));
system.Log.Warning("Serialization binding to non existing serializer: '{0}'", serializerName);
continue;
}
_serializerMap.Add(messageType,serializer);