Commit Graph

33 Commits

Author SHA1 Message Date
Marius Bogoevici
deecae93a6 Allow configuration of Kafka embedded headers in the bus 2015-09-29 20:50:19 -04:00
Marius Bogoevici
9ab7f24f2c Basic support for Kafka on Lattice 2015-09-14 10:02:53 -04:00
bamboo
e630998101 [artifactory-release] Next development version 2015-09-11 19:53:41 +00:00
bamboo
83f762a31e [artifactory-release] Release version 1.0.0.BUILD 2015-09-11 19:53:39 +00:00
Mark Pollack
edd36c4990 Update snapshot deps to milestone deps 2015-09-11 10:36:04 -04:00
Marius Bogoevici
f4f6cb509d Add per-binding configuration for partitioning
- consumer and producer partitioning properties are defined per-binding
- unit tests
- Kafka binding fixes for partitioning
2015-09-09 21:09:49 -07:00
Dave Syer
94639cb72e Some javadocs for clarifying meaning of properties 2015-09-05 10:34:28 +01:00
Mark Fisher
b39c609fb0 renamed port properties 2015-09-04 09:47:50 -04:00
Marius Bogoevici
e82bfe6c91 Add support for Kafka in Cloud Foundry
- use the VCAP properties to find brokers and ports

Corrections to pom, renamed zkAddress to zkNodes
2015-09-04 09:47:47 -04:00
Marius Bogoevici
bd47560bd5 Add support for direct binding
and refactor channel proxy behaviour

- Remove DirectChannelProxyFactory;
- Proxies create channels as necessary, including support for PollableChannels;
- Channel beans are using the bean factory methods for the proxies;
- Coordinate bind/unbind across a context through the internal Bindable interface;
- Add support for embedding modules as independent child contexts of the main module, wrapped in a Bindable interface;
- Add support for channel name namespacing;
- Use a shared channel registry (consulted by the proxies) to create direct bindings;

Restrict the use of SharedChannelRegistry to aggregation

Fixed copyrights

Polishing based on comments from the previous branch

Tweaks

- namespacing takes into account module index, so multiple modules with the same class can partiticipate
- fix how properties are passes to parent/child
- Split ChannelBindingLifecycle from ChannelBindingAdapter and register it with each child;

Javadoc updates

Pass only  prefixed properties

Actually use the filtering method

Lifecycle simplifications

- Removing BindableChannelWrapper and UnbindOnCloseApplicationListener and relying on ChannelBindingListener solely;
- Some code cleanup

Further simplifications

More cleanup

Remove BindableUtils, rename ChannelBindingAdapter

Minor improvements

Addressing some comments, renaming, etc

More polishing
2015-09-02 15:52:19 -04:00
Marius Bogoevici
3eeeaec160 XD-3445 Fix Kafka Binder
- add autoconfiguration support and missing configuration properties
- add version in pom.xml
- fix dependency on spring-cloud-stream-binder-test
2015-08-31 22:37:45 -04:00
Dave Syer
610cf5608d Apply same autoconfig rules for redis as rabbit 2015-08-29 10:49:20 +01:00
Dave Syer
9b4c12b517 Fix ordering for rabbit autoconfig 2015-08-29 10:44:03 +01:00
Ilayaperumal Gopinathan
b60ccd1427 Re-add bean conditions for cloud config
- Re-add `@ConditionalOnMissingBean` to connection factory beans in cloud configurations
 - This is needed at least for CF case where auto-reconfiguration sets up connection factory beans
2015-08-28 12:33:09 -07:00
Mark Fisher
6de7f7cb33 avoid dots in producer property keys 2015-08-25 13:57:59 -04:00
Eric Bottard
1ce40497c9 Fix copyrights 2015-08-23 15:19:09 +02:00
Ilayaperumal Gopinathan
1e8989a45a Remove cloud connector dependencies from S-C-S
- Remove lattice and cf connector dependencies from core S-C-S and binder
  - The idea is to have these dependencies defined in s-c-s-modules so that they
are specified in one place and make the module run on local/cloud environment in a
self contained manner
  - Keep the `spring-cloud-core` dependency to binder so that the Cloud configuration
is used to get the appropriate services for the redis/rabbit binder
2015-08-22 12:40:38 -04:00
Ilayaperumal Gopinathan
b3bc9c9673 Fix RedisService cloud configuration
- Remove `@ConditionalOnMissingBean` on RedisConnectionFactory
2015-08-22 00:17:24 -07:00
Ilayaperumal Gopinathan
56469353b3 Autoconfigure rabbitCloud before rabbit auto-config
- This ordering is required to avoid having 2 beans created for rabbit `ConnectionFactory`
2015-08-21 07:59:23 -07:00
Ilayaperumal Gopinathan
44bf181ff0 AutoConfigure redisCloud before redis auto-config 2015-08-20 17:48:49 -07:00
Ilayaperumal Gopinathan
55591889e1 Add auto-config for Local binder
- Make `local` binder compile dependency as optional
 - Add `local` binder auto configuration
    - This imports local binder properties and binder
 - Add `spring.factories` to enable auto configuration when this archive
is on the classpath
2015-08-20 15:08:17 +02:00
Dave Syer
6d01a2ef79 Add getter to array property for binding
@ConfigurationProperties cannot bind to an array without a getter
2015-08-16 08:17:29 +01:00
Dave Syer
dafa0fdf40 Fix dependencies
In order to join the Spring Cloud release train we have to align the
dependencies and (more importantly) the dependency management strategy.
The strategy is to not put version  ids in <dependencies> (only
in <dependencyManagement>) where possible. And more importantly
we cannot use the releae train itself (creates a cycle).

This change achieves most of that (and mkae it possible for client
apps to use spring-cloud-starter-parent:Brixton.BUILD-SNAPSHOT)

Add spring-integration bom
2015-08-13 13:22:46 -04:00
David Turanski
05e12efb84 replaced CodecConfiguration with spring.factories
add new line
2015-08-12 12:43:52 -07:00
Dave Syer
818ad6e3e8 Add configuration processor as an optional dependency 2015-08-10 10:52:44 -04:00
David Turanski
770dafc577 renamed defaultPrefix .xdbus->.binder 2015-08-10 10:48:57 -04:00
Eric Bottard
38cf0cd738 XD-3380: Use AutoConfiguration for Binder Configurations 2015-08-10 10:44:31 -04:00
Mark Fisher
476664e38d removed redundant dependency 2015-08-10 08:46:44 -04:00
Eric Bottard
53c228239b Propagate Exception 2015-08-09 20:48:23 -04:00
David Turanski
0a84afd6ea Refactored Binder and Codec configuration
- replaced XML-based configuration with Java configuration
- removed optional on spring-cloud-stream-codec
- removed unnecessary test
2015-08-09 20:11:52 -04:00
David Turanski
93f278e839 Cleanup after Binder renaming
one more...

one more comment change
2015-07-21 17:47:38 -04:00
Ilayaperumal Gopinathan
46100b2f8f Rename kafka binder classes
- Move pkg name to `org.springframework.cloud.stream.binder.kafka`
2015-07-21 17:33:15 -04:00
David Turanski
35b74b00b3 Renamed MessageBus to Binder
- Renamed MessageBus to Binder
- Parameterized Binder interface
- Restored exclusion of spring-xd-codec
2015-07-21 15:34:29 -04:00