gateway fix

This commit is contained in:
akulikov 2023-05-29 11:27:49 +03:00
parent 99004e0c47
commit ad73909774

View file

@ -7,6 +7,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.InitializingBean;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;
import ru.spcex.clearing.gatewayapi.config.GatewayApiSettings;
import ru.spcex.clearing.gatewayapi.config.InboundServerSettings; import ru.spcex.clearing.gatewayapi.config.InboundServerSettings;
import ru.spcex.clearing.platform.messaging.domain.BaseRequest; import ru.spcex.clearing.platform.messaging.domain.BaseRequest;
import ru.spcex.clearing.platform.messaging.domain.cud.gateway.GatewayTaskRequest; import ru.spcex.clearing.platform.messaging.domain.cud.gateway.GatewayTaskRequest;
@ -27,11 +28,11 @@ public class GatewayService extends QueueConsumer implements InitializingBean {
Producer<String, Object> kafkaProducer, Producer<String, Object> kafkaProducer,
RestTemplate restTemplate, RestTemplate restTemplate,
UserRoleVerification userRoleVerification, UserRoleVerification userRoleVerification,
InboundServerSettings inboundServerSettings) { GatewayApiSettings gatewayApiSettings) {
super(kafkaQueue, kafkaProducer); super(kafkaQueue, kafkaProducer);
this.restTemplate = restTemplate; this.restTemplate = restTemplate;
this.userRoleVerification = userRoleVerification; this.userRoleVerification = userRoleVerification;
this.inboundServerSettings = inboundServerSettings; this.inboundServerSettings = gatewayApiSettings.getInboundServer();
} }
@Override @Override