IReplayCommits.cs

public interface IReplayCommits
{
    void Replay(DateTime start);
    void Replay(Guid streamId, int minRevision, int maxRevision);
}

ReplayUtility.cs

public class ReplayUtility : IReplayCommits
{
    private readonly IStoreEvents _storeEvents;
    private readonly IEventPublisher _eventPublisher;

    public ReplayUtility()
        : this(DI.Current.Resolve<IStoreEvents>(), DI.Current.Resolve<IEventPublisher>())
    { }

    public ReplayUtility(IStoreEvents storeEvents, IEventPublisher eventPublisher)
    {
        _storeEvents = storeEvents;
        _eventPublisher = eventPublisher;
    }

    public void Replay(DateTime start)
    {
        var commits = _storeEvents.Advanced.GetFrom(start);

        Handle(commits);
    }

    public void Replay(Guid streamId, int minRevision, int maxRevision)
    {
        var commits = _storeEvents.Advanced.GetFrom(streamId, minRevision, maxRevision);

        Handle(commits);
    }

    private void Handle(IEnumerable<Commit> commits)
    {
        // todo: optionally add a header, so consumers not leveraging gateways can determine whether or not to execute
        // note: if optional header is added, create extension method IMessage.IsReplay() for ease of development

        foreach (var commit in commits)
            _eventPublisher.Publish(commit.Events.Select(e => e.Body), commit.Headers, commit.Events.ToDictionary(e => e.Body, e => e.Headers));
    }
}