Add serialization to ISerializeEvents

Author: chrischu

src/NEventStore.Persistence.Sql/DefaultEventSerializer.cs

@@ -16,6 +16,11 @@ public DefaultEventSerializer(ISerialize serializer)
             _serializer = serializer;
         }
 
+        public byte[] SerializeEventMessages(IReadOnlyList<EventMessage> eventMessages)
+        {
+            return _serializer.Serialize(eventMessages);
+        }
+
         public ICollection<EventMessage> DeserializeEventMessages(byte[] input, string bucketId, string streamId,
             int streamRevision, Guid commitId,
             int commitSequence, DateTime commitStamp, long checkpoint, IReadOnlyDictionary<string, object> headers)

src/NEventStore.Persistence.Sql/ISerializeEvents.cs

@@ -6,7 +6,14 @@ namespace NEventStore.Persistence.Sql
     public interface ISerializeEvents
     {
         /// <summary>
-        ///     Deserializes the stream provided and reconstructs the corresponding object graph.
+        ///     Serializes the event messages.
+        /// </summary>
+        /// <param name="eventMessages">The messages to serialize.</param>
+        /// <returns>A byte array representing the serialized messages.</returns>
+        byte[] SerializeEventMessages(IReadOnlyList<EventMessage> eventMessages);
+
+        /// <summary>
+        ///     Deserializes the bytes provided and reconstructs the corresponding object graph.
         /// </summary>
         /// <param name="input">The bytes from which the object will be reconstructed.</param>
         /// <param name="bucketId">The <see cref="ICommit.BucketId" />.</param>

src/NEventStore.Persistence.Sql/SqlPersistenceEngine.cs

@@ -324,7 +324,7 @@ private ICommit PersistCommit(CommitAttempt attempt)
                 cmd.AddParameter(_dialect.CommitSequence, attempt.CommitSequence);
                 cmd.AddParameter(_dialect.CommitStamp, attempt.CommitStamp, _dialect.GetDateTimeDbType());
                 cmd.AddParameter(_dialect.Headers, _serializer.Serialize(attempt.Headers));
-                _dialect.AddPayloadParamater(_connectionFactory, connection, cmd, _serializer.Serialize(attempt.Events.ToList()));
+                _dialect.AddPayloadParamater(_connectionFactory, connection, cmd, _eventSerializer.SerializeEventMessages(attempt.Events.ToList()));
                 OnPersistCommit(cmd, attempt);
                 var checkpointNumber = cmd.ExecuteScalar(_dialect.PersistCommit).ToLong();
                 return new Commit(