SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
55 Commits 28 Branches 0 Tags
35fd979fc64ba125eaa82e29a0f909036f3bb322
Commit Graph

55 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Dave Syer
35fd979fc6 Move lattice dependency to profile 2015-07-10 07:43:36 +01:00
Dave Syer
4d53ca9dc4 Add travis build 2015-07-10 07:08:11 +01:00
Dave Syer
1823f32569 Add docs and travis config 2015-07-10 07:08:11 +01:00
Ilayaperumal Gopinathan
e3b3bd82fc Rename vanilla-samples 
- Change the name to spring-cloud-streams-samples which is already used in pom.xml
 2015-07-09 19:05:02 -04:00
Ilayaperumal Gopinathan
e4cc9e5222 Fix source configuration in the sample 2015-07-09 18:52:29 -04:00
Ilayaperumal Gopinathan
a1ca7e8963 Remove SearchStrategy.CURRENT 
This was set on the ChannelBindingProperties bean. However, since the ModuleProperties
(which is of type ChannelBindingProperties) might have been initialized by the initializer,
the search strategy for the conditional bean needs to look at the hierarchy.

Added a TODO comment indicating this can be set to CURRENT once the initializer is removed.
 2015-07-09 18:11:26 -04:00
Dave Syer
6e33369318 Add aggregate builder and sample applications 
No need to specify channel names (just spring.cloud.streams.name). Example
app:

@SpringBootApplication
@EnableChannelBinding
public class ExtendedApplication implements AggregateConfigurer {

	@Override
	public void configure(AggregateBuilder builder) {
		builder
		.from(TimeSource.class).as("source")
		.via(LoggingTransformer.class)
		.via(LoggingTransformer.class).profiles("other")
		.to(LogSink.class);
	}
}

Fixes gh-2
 2015-07-09 17:42:12 +01:00
David Turanski
0c82a37360 XD-3242 created spring-cloud-streams-codec 
Fixes gh-3
 2015-07-09 17:39:53 +01:00
Dave Syer
e6962c514f Add vanilla-samples 
The aim is that these will converge over time with the XD samples
 2015-07-09 14:04:17 +01:00
Dave Syer
671b57bdc0 Add scm tag to parent pom 2015-07-09 13:46:00 +01:00
Dave Syer
926d6be531 Add parent pom so deployment works OOTB 2015-07-09 13:44:11 +01:00
Dave Syer
fc2397b11d Check simple XD samples are working 2015-07-09 10:01:07 +01:00
Dave Syer
531de2d41e Tidy up readme 2015-07-09 09:40:44 +01:00
Dave Syer
f858c52103 More Bus->Streams name updates 2015-07-09 09:02:32 +01:00
David Turanski
3218c39d47 removed spring-xd-dirt dependencies 2015-07-08 16:00:44 -04:00
Ilayaperumal Gopinathan
498d9f5c64 Merge change from spring-bus 2015-07-08 18:15:37 +01:00
Dave Syer
2096a33d8a Split out XD specific bits into spring-xd-runner 2015-07-08 17:58:33 +01:00
Dave Syer
f6b079f62c Remove discovery fetaures 2015-07-08 17:08:07 +01:00
Dave Syer
39d7e244b9 Change package names 2015-07-08 17:05:33 +01:00
Dave Syer
997356cbe5 Switch to spring-cloud-streams naming 2015-07-08 17:02:44 +01:00
Ilayaperumal Gopinathan
71e53321dc DefaultOptions resolver does not create a new CL 
- This will make sure the options metadata classes are loaded from the jars provided in the current classloader instead of a new ParentLastURLClassLoader created in XD.
 2015-06-28 12:07:18 -04:00
Glenn Renfro
6ab7c566ad Readme.md now contains build directions 2015-06-28 11:06:43 -04:00
Dave Syer
38a744e915 Remove scala dependency 2015-06-17 16:21:14 +01:00
Dave Syer
f68c4de6f6 Tick off rebind channels 2015-06-12 17:15:26 +01:00
Mark Fisher
71d38c46ec renamed Up/Downstream annotations to In/Output 2015-06-11 08:40:18 -04:00
Mark Fisher
444c3822e4 renamed channel "specs" to channel "bindings" 2015-06-11 08:21:26 -04:00
Mark Fisher
b4b8d7f748 lattice cloud connector for source/sink samples 2015-06-09 09:19:57 -04:00
Ilayaperumal Gopinathan
e89bd9e214 Handle null values for moduleDefaults 
- If the moduleDefaults have `null` values then skip.
Otherwise, the `EnvironmentDecryptApplicationInitializer` breaks
 2015-06-08 21:56:02 -04:00
Dave Syer
c3ae17eb12 Detect changes in service registry and rebind channels if possible 2015-06-07 12:12:12 +01:00
Dave Syer
19e5bf04bc Tick off discovery 2015-06-05 17:15:42 +01:00
Dave Syer
cee7917c49 Make discovery work for channels 
Here's how it works. User adds a bean of type ChannelLocator
qualified as @InputChannel (or @OutputChannel) and it gets
used instead of the default. The discovery version needs a
service id. What it does is invert the naming convention in
channel binding - "input" locally requires "output" remotely,
"input.topic:foo" requires "output.topic:foo" remotely etc.
 2015-06-05 16:58:45 +01:00
Dave Syer
538083b656 Add extra abstraction for looking up channel names 
ChannelLocator translates local (bean) names to bus names. There's a
local (Default*) implementation and one based on service discovery.
 2015-06-04 14:46:25 +01:00
Mark Fisher
8c8fcb7597 added channel-level partitioning props to roadmap 2015-06-04 09:39:45 -04:00
Mark Fisher
534ba30335 resource path change to enable java -jar launching 2015-06-04 09:34:00 -04:00
Mark Fisher
a172651fc1 fix start-class in sample poms 2015-06-04 09:31:58 -04:00
Mark Fisher
0153c27e8a partitioning example 
added commented-out properties with an explanation in the
bootstrap.yml files for the source and sink sample apps
 2015-06-04 09:24:33 -04:00
Dave Syer
3664d02e8d Lazily initialize the MessageBus in BeanPostProcessor 
Otherwise bad things happen when the MessageBus is not decorated
by other BPPs (especially the @EnableIntegration one).
 2015-06-04 09:01:55 +01:00
Mark Fisher
a239294d9c added inputType/outputType properties to roadmap 2015-06-02 10:41:27 -04:00
Dave Syer
17df347b1b Add localName property to channel specs (read only) 
/channels/taps responds to the local name as well as the "channel"
name.

Also includes a change to allow the default channel name to be
output_topic: or input_topic: (for pubsub but no particular name).

And also adds autoStartup to module properties.
 2015-06-02 13:27:49 +01:00
Dave Syer
9f70a62bc6 Fix cloud profile so it works on cloud foundry 2015-06-02 12:06:49 +01:00
Dave Syer
6fa01a85bf Re-org pom.xml to allow Spring Boot 1.3.0 to be used 
User can use this pom as a parent and set spring-boot.version.

Also permits "_" as channel name separator.
 2015-05-30 11:36:11 +01:00
Dave Syer
d11f52170f Add /channels/taps MVC endpoint 2015-05-29 16:59:54 +01:00
Dave Syer
147875540d Regularize and test tap channel names 2015-05-29 16:07:41 +01:00
Dave Syer
3b4834a2b0 Switch from Map to Collection for *ChannelSpecs 2015-05-29 15:32:07 +01:00
Dave Syer
f671737f71 Add @PropertySources for default bus properties 2015-05-29 10:24:56 +01:00
Dave Syer
c0a4b0bdd6 Add some tests for channel name resolution 2015-05-29 07:29:53 +01:00
Mark Fisher
41b5370728 minor roadmap edits 2015-05-28 13:49:28 -04:00
Dave Syer
3fae88490a Remove unused channel fields 2015-05-28 18:39:29 +01:00
Dave Syer
bb32ce39c8 Document briefly support for multiple channels 2015-05-28 18:27:07 +01:00
Dave Syer
5121c37e30 Add support for multiple channels 2015-05-28 18:10:46 +01:00