treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-16

Browse source
This commit is contained in:
ialbert 2022-08-15 15:03:26 +03:00
parent c49fc00d0e
commit baf625f959
4 changed files with 7 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clearing-parent/securities-service/src/main/java/ru/spcex/clearing/securities/service/cud/MoneyMarketSecurityService.java
View file

@ -30,8 +30,7 @@ public class MoneyMarketSecurityService extends QueueConsumer implements Initial
public void afterPropertiesSet() {
callback(MoneyMarketSecurityNewRequest.class)
.setConsumer(this::newMoneyMarket)
.setDestination(Consts.DESTINATION_MONEY_MARKET_SECURITY_NEW, callbacks::put)
.build();
.forDestination(Consts.DESTINATION_MONEY_MARKET_SECURITY_NEW, callbacks::put);
init();
}

2
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/logic/functional/BuilderConsumerStep.java
View file

@ -3,5 +3,5 @@ package ru.spcex.clearing.platform.messaging.logic.functional;
import java.util.function.Consumer;
public interface BuilderConsumerStep<T1> {
BuilderDestinationStep<T1> setConsumer(Consumer<T1> consumer);
BuilderDestinationStep setConsumer(Consumer<T1> consumer);
}

4
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/logic/functional/BuilderDestinationStep.java
View file

@ -2,6 +2,6 @@ package ru.spcex.clearing.platform.messaging.logic.functional;
import java.util.function.BiConsumer;
public interface BuilderDestinationStep<T1> {
Builder<T1> setDestination(String destination, BiConsumer<String, ConsumerSpecificClass<?>> mappingFun);
public interface BuilderDestinationStep {
void forDestination(String destination, BiConsumer<String, ConsumerSpecificClass<?>> mappingFun);
}

14
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/logic/functional/ConsumerSpecificClass.java
View file

@ -3,7 +3,7 @@ package ru.spcex.clearing.platform.messaging.logic.functional;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
public class ConsumerSpecificClass<T> implements BuilderConsumerStep<T>, BuilderDestinationStep<T>, Builder<T> {
public class ConsumerSpecificClass<T> implements BuilderConsumerStep<T>, BuilderDestinationStep {
private Class<T> clazz;
private java.util.function.Consumer<T> consumer;
@ -11,9 +11,8 @@ public class ConsumerSpecificClass<T> implements BuilderConsumerStep<T>, Builder
this.clazz = clazz;
}
public Builder<T> setDestination(String destination, BiConsumer<String, ConsumerSpecificClass<?>> fun) {
public void forDestination(String destination, BiConsumer<String, ConsumerSpecificClass<?>> fun) {
fun.accept(destination, this);
return this;
}
public void accept(T obj) {
@ -33,15 +32,8 @@ public class ConsumerSpecificClass<T> implements BuilderConsumerStep<T>, Builder
}
@Override
public BuilderDestinationStep<T> setConsumer(Consumer<T> consumer) {
public BuilderDestinationStep setConsumer(Consumer<T> consumer) {
this.consumer = consumer;
return this;
}
@Override
public ConsumerSpecificClass<T> build() {
return this;
}
}