org.springframework.cloud.stream.aggregate

Class AggregateApplicationBuilder

java.lang.Object

org.springframework.cloud.stream.aggregate.AggregateApplicationBuilder

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.SmartInitializingSingleton, AggregateApplication, org.springframework.context.ApplicationContextAware

@EnableBinding
public class AggregateApplicationBuilder
extends Object
implements AggregateApplication, org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.SmartInitializingSingleton

Application builder for AggregateApplication.

Author:

Dave Syer, Ilayaperumal Gopinathan, Marius Bogoevici, Venil Noronha

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AggregateApplicationBuilder.AppConfigurer<T extends AggregateApplicationBuilder.AppConfigurer<T>>
static class	AggregateApplicationBuilder.ParentConfiguration
class	AggregateApplicationBuilder.ProcessorConfigurer
class	AggregateApplicationBuilder.SinkConfigurer
class	AggregateApplicationBuilder.SourceConfigurer

Constructor Summary

Constructors

Constructor and Description
AggregateApplicationBuilder(Object[] sources, String[] args)
AggregateApplicationBuilder(Object source, String... args)
AggregateApplicationBuilder(String... args)

Method Summary

Modifier and Type	Method and Description
void	afterSingletonsInstantiated()
AggregateApplicationBuilder.SourceConfigurer	from(Class<?> app)
<T> T	getBinding(Class<T> bindableType, String namespace) Retrieves the bindable proxy instance (e.g.
AggregateApplicationBuilder	headless(boolean headless) Configures the headless attribute of the build application.
AggregateApplicationBuilder	parent(Object[] sources, String[] args)
AggregateApplicationBuilder	parent(Object source, String... args)
org.springframework.context.ConfigurableApplicationContext	run(String... parentArgs)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
AggregateApplicationBuilder	web(boolean webEnvironment) Flag to explicitly request a web or non-web environment.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AggregateApplicationBuilder

public AggregateApplicationBuilder(String... args)

AggregateApplicationBuilder

public AggregateApplicationBuilder(Object source,
                                   String... args)

AggregateApplicationBuilder

public AggregateApplicationBuilder(Object[] sources,
                                   String[] args)

Method Detail

parent

public AggregateApplicationBuilder parent(Object source,
                                          String... args)

parent

public AggregateApplicationBuilder parent(Object[] sources,
                                          String[] args)

web

public AggregateApplicationBuilder web(boolean webEnvironment)

Flag to explicitly request a web or non-web environment.

Parameters:

webEnvironment - true if the application has a web environment

Returns:

the AggregateApplicationBuilder being constructed

See Also:

SpringApplicationBuilder.web(boolean)

headless

public AggregateApplicationBuilder headless(boolean headless)

Configures the headless attribute of the build application.

Parameters:

headless - true if the application is headless

Returns:

the AggregateApplicationBuilder being constructed

See Also:

SpringApplicationBuilder.headless(boolean)

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface org.springframework.beans.factory.SmartInitializingSingleton

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

getBinding

public <T> T getBinding(Class<T> bindableType,
                        String namespace)

Description copied from interface: AggregateApplication

Retrieves the bindable proxy instance (e.g. Processor, Source, Sink or custom interface) from the given namespace.

Specified by:

getBinding in interface AggregateApplication

Parameters:

bindableType - the bindable type

namespace - the namespace

Returns:

from

public AggregateApplicationBuilder.SourceConfigurer from(Class<?> app)

run

public org.springframework.context.ConfigurableApplicationContext run(String... parentArgs)