Skip to content

Commit

Permalink
allow overwriting the Contextual.askWithRetryConfig
Browse files Browse the repository at this point in the history
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
  • Loading branch information
thjaeckle committed Sep 17, 2021
1 parent 86f12c3 commit cc9c203
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@
import org.eclipse.ditto.internal.utils.cache.Cache;
import org.eclipse.ditto.internal.utils.cache.CacheKey;
import org.eclipse.ditto.internal.utils.cacheloaders.config.AskWithRetryConfig;
import org.eclipse.ditto.internal.utils.metrics.instruments.timer.StartedTimer;

import akka.actor.ActorRef;
import akka.actor.ActorSystem;
Expand Down Expand Up @@ -244,19 +243,19 @@ askWithRetryConfig, log, cacheKeyFor(message), receiver, receiverWrapperFunction
responseReceivers, askFuture);
}

Contextual<T> withTimer(final StartedTimer startedTimer) {
Contextual<T> withReceiver(@Nullable final ActorRef receiver) {
return new Contextual<>(message, self, sender, scheduler, executor, pubSubMediator, conciergeForwarder,
askWithRetryConfig, log, cacheKey, receiver, receiverWrapperFunction, responseReceivers,
askFuture);
}

Contextual<T> withReceiver(@Nullable final ActorRef receiver) {
Contextual<T> withReceiverWrapperFunction(final Function<Object, Object> receiverWrapperFunction) {
return new Contextual<>(message, self, sender, scheduler, executor, pubSubMediator, conciergeForwarder,
askWithRetryConfig, log, cacheKey, receiver, receiverWrapperFunction, responseReceivers,
askFuture);
}

Contextual<T> withReceiverWrapperFunction(final Function<Object, Object> receiverWrapperFunction) {
public Contextual<T> withAskWithRetryConfig(final AskWithRetryConfig askWithRetryConfig) {
return new Contextual<>(message, self, sender, scheduler, executor, pubSubMediator, conciergeForwarder,
askWithRetryConfig, log, cacheKey, receiver, receiverWrapperFunction, responseReceivers,
askFuture);
Expand Down

0 comments on commit cc9c203

Please sign in to comment.