Skip to content
This repository has been archived by the owner on Feb 9, 2021. It is now read-only.

Commit

Permalink
Minor refactorings
Browse files Browse the repository at this point in the history
  • Loading branch information
Dariusz Lenartowicz committed Oct 31, 2016
1 parent 4465ce0 commit 8d6aa0a
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/Ses.Subscriptions/SubscriptionPoller.cs
Original file line number Diff line number Diff line change
Expand Up @@ -24,15 +24,15 @@ protected SubscriptionPoller(ISubscriptionEventSource[] sources)
_contractSubscriptions = new Dictionary<ISubscriptionEventSource, int>(Sources.Length);
}

private HandlerRegistrar CreateHandlerRegistrar() => new HandlerRegistrar(FindHandlerTypes());

private HandlerRegistrar CreateHandlerRegistrar() { return new HandlerRegistrar(FindHandlerTypes()); }
public ISubscriptionEventSource[] Sources { get; }
public PollerRetriesPolicy RetriesPolicy { get; protected set; }
public virtual TimeSpan? RunForDuration => null;
public virtual TimeSpan GetFetchTimeout() => TimeSpan.Zero;
public virtual TimeSpan? RunForDuration { get; } = null;
public virtual TimeSpan GetFetchTimeout() { return TimeSpan.Zero; }

protected abstract IEnumerable<Type> FindHandlerTypes();
protected abstract IHandle CreateHandlerInstance(Type handlerType);
protected virtual IEnumerable<Type> GetConcreteSubscriptionEventTypes() => null;
protected virtual IEnumerable<Type> GetConcreteSubscriptionEventTypes() { return null; }
protected virtual void PreHandleEvent(EventEnvelope envelope, Type handlerType) { }
protected virtual void PostHandleEvent(EventEnvelope envelope, Type handlerType) { }
protected virtual void PostHandleEventError(EventEnvelope envelope, Type handlerType, Exception exception, int retryAttempts) { }
Expand Down

0 comments on commit 8d6aa0a

Please sign in to comment.