- Remove conditionalOnMissingBean check on the necessary beans that are required for exernal bindings of the child application
- Add test to verify
Resolves#816
`@StreamListener` has support for a `condition` parameter,
that contains a SpEL expression that is evaluated before the
method is invoked.
Fix#682
Move StreamListenerMessageHandler as a top level class
Use dispatching and add test
Refactor dispatching mechanism
Throw error when conditions are used in declarative mode
Make StreamListenerAnnotationBeanPostProcessor overridable
Remove unused field in test
Address some PR comments
Add placeholder resolution
Update how multiple matches work with return values
- Methods with return values are not allowed to specify conditions
- If multiple matches are detected (e.g. multiple methods without
conditions, or a mix of methods with and without conditions)
checks that all of them have no return value;
- The aggregate parent configuration now imports the required auto configuration classes such as ChannelBindingAutoConfiguration and EndpointAutoConfiguration
while `@EnableBinding` is still at the parent configuration to be able to share the binding configuration among the child applications
- Add `ConditionalOnMissingBean` in spring cloud stream auto configuration classes so that if `EnableAutoConfiguration` is enabled at child application classes
they don't get instantiated again
- Conditionally import EmbeddedServlet auto-configuration when web environment is enabled for parent
- Add test
Resolves#737
- The PartitionHandler has per-binding partition properties derived from the producer properties for the binding
- These partition properties (especially PartitionKeyExtractorStrategy and PartitionSelectorStrategy) need not be initialized when the messages are processed; instead they can be set during the PartitionHandler instantiation
- Add tests
This resolves#772
Refactor PartitionHandler
- Provide an API for provisioning middleware specific concerns independent of the binder
- Make the corresponding changes in AbstractMessageChannelBinder
Fixes#745
Addressing PR review comments
Adding ProvisioningException to the SPI for provisioning
Addressing PR review comments
- Overload extractHeaders method to accept bytes payload
- This will help avoiding unnessary message creation during ad-hoc extractHeader invocation
- add test
- Log all the exception messages at the deserialization (especially at the codec's decode process)
- Combine all the exception catches into Exception as the exception messages are almost same and redundant.
Resolves#497
removing duplicate declaration of logger
- Prevent new reflection calls to channels
for Sources, Sinks and Processors, cache bound target
if it's found and try to use it next time as target
should not change.
- One test for checking caching.
- Fixes#759
Fixes#751
- Use Reactor 3.0.4.RELEASE
- Remove Scheduler implementations that were introduced for fixes
- Shade `io.reactivex:rxjava-reactive-streams` classes to replace removed RxJava1 adapter support
Signed-off-by: Marius Bogoevici <mbogoevici@pivotal.io>
