Fix bug of incorrect use of Memoizer function

This commit is contained in:
Warren Zhu 2018-07-05 15:30:57 +08:00
Родитель 62430e1f01
Коммит ed768eb575
2 изменённых файлов: 8 добавлений и 3 удалений

Просмотреть файл

@ -26,13 +26,15 @@ import java.util.function.Function;
public class DefaultServiceBusQueueClientFactory extends AbstractServiceBusSenderFactory
implements ServiceBusQueueClientFactory {
private final Function<String, IQueueClient> queueClientCreator = Memoizer.memoize(this::createQueueClient);
public DefaultServiceBusQueueClientFactory(AzureAdmin azureAdmin, String namespace) {
super(azureAdmin, namespace);
}
@Override
public Function<String, IQueueClient> getQueueClientCreator() {
return Memoizer.memoize(this::createQueueClient);
return queueClientCreator;
}
@Override

Просмотреть файл

@ -26,6 +26,9 @@ import java.util.function.Function;
*/
public class DefaultServiceBusTopicClientFactory extends AbstractServiceBusSenderFactory
implements ServiceBusTopicClientFactory {
private final Function<Tuple<String, String>, ISubscriptionClient> subscriptionClientCreator = Memoizer.memoize(this::createSubscriptionClient);
private final Function<String, ? extends IMessageSender> sendCreator = Memoizer.memoize(this::createTopicClient);
public DefaultServiceBusTopicClientFactory(AzureAdmin azureAdmin, String namespace) {
super(azureAdmin, namespace);
@ -33,12 +36,12 @@ public class DefaultServiceBusTopicClientFactory extends AbstractServiceBusSende
@Override
public Function<Tuple<String, String>, ISubscriptionClient> getSubscriptionClientCreator() {
return Memoizer.memoize(this::createSubscriptionClient);
return subscriptionClientCreator;
}
@Override
public Function<String, ? extends IMessageSender> getSenderCreator() {
return Memoizer.memoize(this::createTopicClient);
return sendCreator;
}
private ISubscriptionClient createSubscriptionClient(Tuple<String, String> nameAndSubscription) {