change helper visibility on spring
default empty string for @Selector
Add MetaProperties to ReactorBuilder
@ReplyTo should let header v
tweak selector test to check uriSelector
add findByExtension method in groovyEnvironment
add routingStrategy
inherit reactorBuilder config
fix typo and add ReactorBuilder.linked to the properties clones in child nodes
fix groovy scoping issue
expose eventRouter configuration
complete EventRoutingSpec with eventRouter, consumerInvoker and filter
add copy() method to Event for soft copy
remove final modifier on ConsumerFilteringEventRouter
fix #179 :
add filter(predicate, rejectedStream)
add Reactor.ReplyToEvent.copy to produce a proper ReplyToEvent copy
add CallbackEvent to attach consumer callback on an event
add Deferred.accept(value, callback) to call the downstream Composable with a CallbackEvent
add Stream.callback() operation to define callback point, testing if the event is of type CallbackEvent and triggering its callback
modify Stream,Deferred and Composable to correctly handle events, rehydrating event headers and replyTo if necessary
fixed #179: rename end() to callback() to avoid confusion with a stream stop instruction
Add DSL support for Streaming router, allowing intercepting event in a Stream
#169 fixed compilation change
refactor ConsumerBeanPostProcessor to allow extensions. Use method name as default selector and use replyTo header.
fix build and remove some debug instructions
fix build and remove some debug instructions
fixes!
open ConsumerFilter for reuse