SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reduced visibility of new classes(for now)

Browse Source 
minor polishing
This commit is contained in:
Oleg Zhurakousky
2018-08-14 12:58:00 +02:00
parent 9d1818839e
commit fffe67cdcf
3 changed files with 22 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/source/SimpleRequestBuilder.java
View File

@@ -28,13 +28,13 @@ import org.springframework.http.HttpHeaders;
* @author Dave Syer * @author Dave Syer
* *
*/ */
public class SimpleRequestBuilder implements RequestBuilder { class SimpleRequestBuilder implements RequestBuilder {
private String baseUrl = "http://${destination}"; private String baseUrl = "http://${destination}";
private Map<String, String> headers = new LinkedHashMap<>(); private Map<String, String> headers = new LinkedHashMap<>();
private Environment environment; private Environment environment;
public SimpleRequestBuilder(Environment environment) { SimpleRequestBuilder(Environment environment) {
this.environment = environment; this.environment = environment;
} }

4
spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/source/SupplierAutoConfiguration.java
View File

@@ -39,10 +39,9 @@ import org.springframework.web.reactive.function.client.WebClient;
@Conditional(SourceActiveCondition.class) @Conditional(SourceActiveCondition.class)
@EnableConfigurationProperties(SupplierProperties.class) @EnableConfigurationProperties(SupplierProperties.class)
@ConditionalOnProperty(prefix = "spring.cloud.function.web.supplier", name = "enabled", matchIfMissing = true) @ConditionalOnProperty(prefix = "spring.cloud.function.web.supplier", name = "enabled", matchIfMissing = true)
public class SupplierAutoConfiguration { class SupplierAutoConfiguration {
@Bean @Bean
@ConditionalOnMissingBean
public SupplierExporter sourceForwarder(RequestBuilder requestBuilder, public SupplierExporter sourceForwarder(RequestBuilder requestBuilder,
DestinationResolver destinationResolver, FunctionCatalog catalog, DestinationResolver destinationResolver, FunctionCatalog catalog,
WebClient.Builder builder, SupplierProperties props) { WebClient.Builder builder, SupplierProperties props) {
@@ -51,7 +50,6 @@ public class SupplierAutoConfiguration {
} }
@Bean @Bean
@ConditionalOnMissingBean
public RequestBuilder simpleRequestBuilder(SupplierProperties props, public RequestBuilder simpleRequestBuilder(SupplierProperties props,
Environment environment) { Environment environment) {
SimpleRequestBuilder builder = new SimpleRequestBuilder(environment); SimpleRequestBuilder builder = new SimpleRequestBuilder(environment);

31
spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/source/SupplierExporter.java
View File

@@ -36,23 +36,31 @@ import reactor.core.scheduler.Schedulers;
/** /**
* Forwards items obtained from a {@link Supplier} or set of suppliers to an external HTTP * Forwards items obtained from a {@link Supplier} or set of suppliers to an external HTTP
* endpoint. * endpoint.
* *
* @author Dave Syer * @author Dave Syer
* *
*/ */
public class SupplierExporter implements SmartLifecycle { class SupplierExporter implements SmartLifecycle {
private final FunctionCatalog catalog;
private final WebClient client;
private final DestinationResolver destinationResolver;
private final RequestBuilder requestBuilder;
private final String supplier;
private FunctionCatalog catalog;
private WebClient client;
private volatile boolean running; private volatile boolean running;
private volatile boolean ok = true;
private boolean autoStartup = true;
private boolean debug = true;
private String supplier;
private volatile Disposable subscription;
private DestinationResolver destinationResolver; private volatile boolean ok = true;
private RequestBuilder requestBuilder;
private boolean autoStartup = true;
private boolean debug = true;
private volatile Disposable subscription;
public SupplierExporter(RequestBuilder requestBuilder, public SupplierExporter(RequestBuilder requestBuilder,
DestinationResolver destinationResolver, FunctionCatalog catalog, DestinationResolver destinationResolver, FunctionCatalog catalog,
@@ -68,7 +76,6 @@ public class SupplierExporter implements SmartLifecycle {
@Override @Override
public void start() { public void start() {
if (this.running) { if (this.running) {
return; return;
} }