Commit Graph

178 Commits

Author SHA1 Message Date
Spring Buildmaster
a779d7f8ff [artifactory-release] Release version 1.0.0.M1 2014-05-08 11:07:12 -07:00
Artem Bilan
4aefd9129f DSL: Clean up README.md 2014-05-08 14:15:15 +03:00
Artem Bilan
6664d413d4 DSL: Upgrade to SI 4.0. RELEASE 2014-04-30 17:32:21 +03:00
Gary Russell
34efe4b262 MQTT: Add README note: Moved to Spring Integration 2014-04-25 09:25:58 -04:00
Artem Bilan
2d9f01464b Replace LiteralExpression to ValueExpression 2014-04-17 14:22:07 +03:00
Artem Bilan
305504196b Upgrade to SI 4.0
* Add new correlation endpoint options
* Add `messageStore` to the `PriorityChannelSpec`
* Add generic to `EnricherSpec#property`
* Remove `type` from `EnricherSpec.headerExpression`
* Add `initialDelay` for `PeriodicTriggerSpec`
* Fix `IntegrationFlowBuilder` bugs, when there is no relevant the end of the flow
* Add embedded MongoDb support for tests
* Add `priority` test with `MongoDbChannelMessageStore`
2014-04-16 15:22:55 +03:00
Artem Bilan
69bc8d602a Add @GlobalChannelInterceptor test 2014-03-30 16:31:34 +03:00
Gary Russell
ec27ef2344 MQTT Reset Barrier At Start of Tests
- Also remove ...java~ file.
2014-03-24 12:17:35 -04:00
Artem Bilan
a7fd45c7eb Add claimCheckIn(), claimCheckOut EIP-methods 2014-03-24 14:57:22 +02:00
Gary Russell
59a2a37813 Update README.md
Add a note about the move to the main Spring Integration project.
2014-03-24 14:55:00 +02:00
Gary Russell
369dca42f3 MQTT Update Spring, SI Versions 2014-03-24 14:55:00 +02:00
Spring Buildmaster
6f322f0a57 [artifactory-release] Next development version 2014-03-24 14:55:00 +02:00
Spring Buildmaster
012ad70fc5 [artifactory-release] MQTT Release 1.0.0.RC1 2014-03-24 14:55:00 +02:00
Gary Russell
592bf68086 INT-3336 Add error-channel to MQTT m-d-c-a
JIRA: https://jira.spring.io/browse/INT-3336

Previously exceptions thrown in a flow downstream of a
message-driven-channel-adapter were not logged and thrown
back to the client, causing the connection to drop and
reconnect.

Add `error-channel` to the adapter to allow normal
error handling. If no error channel, catch and log
the unhandled exception.

Add `adapter.stop();` in the end of 'real' tests to close the mqtt-connection.

Disconnect the client after verifying the broker is available.
Change the rule to a class level rule in DownstreamExceptionTests.
2014-03-24 14:55:00 +02:00
Artem Bilan
c583351bff Add some JavaDocs 2014-03-14 22:56:33 +02:00
Artem Bilan
1b9076ca26 Polishing to MessageChannelSpec 2014-03-14 21:50:04 +02:00
Artem Bilan
4cf18e71c8 Add route(), recipientListRoute() EIP-methods 2014-03-14 13:39:38 +02:00
Artem Bilan
53b25dbdcf Add controlBus() EIP-method 2014-03-12 22:32:42 +02:00
Artem Bilan
e738864125 Add resequence(),aggregate(),headerFilter()
Polishing for `@Copyright`
2014-03-12 17:57:03 +02:00
Artem Bilan
eee9dc4163 Add split() and enrichHeaders() EIP-methods 2014-03-10 20:54:26 +02:00
Artem Bilan
3d0cec9544 Add support for FixedSubscriberChannel 2014-03-06 16:47:47 +02:00
Artem Bilan
feb610d92b Add enrich() and channel names option 2014-03-05 20:36:51 +02:00
Artem Bilan
83fb344bd3 Add delay() EIP-method 2014-02-22 16:49:50 +02:00
Artem Bilan
abab1af3d5 Support @Autowired for Configurations with DSL 2014-02-19 11:26:52 +02:00
Artem Bilan
c161210c3e Introduce method-invoking handle
* Add generic argument to `GenericEndpointSpec`.
Since `EndpointSpec#get()` returns `Tuple` with `EndpointFactoryBean` and `MessageHandler` objects
it is useful to get deal with specific generic for further `MessageHandler` configuration within `EndpointConfigurer` lambda
* Change DSL-methods to get deal deal with those generics.
* Add `FileWritingMessageHandler` test to demonstrate it.
* Fix bug around double `MessageHandler` bean registration from `DslIntegrationConfigurationInitializer`, when handler is a reference
to existing bean.
2014-02-17 17:11:41 +02:00
Artem Bilan
ac46625a83 Introduce EIP-methods handle() and bridge()
* Remove generic argument from `GenericEndpointSpec`: it isn't necessary
* Add check for `one-way` flow in case the last component isn't `MessageProducer`
2014-02-14 19:41:39 +02:00
Artem Bilan
70d0e35806 IntegrationComponentSpec refactoring
Introduce `Tuple`
Apply `EndpointConfigurer` for `MessageSource<>` DSL-method
2014-02-14 16:24:11 +02:00
Artem Bilan
0baeb52b3f Revert IntegrationFlow processing to BFPP
Add test case for `@MessageEndpoint` to et deal with channel from `IntegrationFlow`
As far as `AbstractMethodAnnotationPostProcessor` tries to resolve `channel` on endpoint creation,
the `IntegrationFlow` processing can't be done in the `BPP`, because `MessagingAnnotationPostProcessor` may parse
annotations for bean before `IntegrationFlowBeanPostProcessor` will do its stuff.
2014-02-14 12:08:28 +02:00
Artem Bilan
1e6d50d33c Spec<?, ?> improvements
* Provide `id`-aware DSL methods for `MessageChannelSpec`
* Rework `DslIntegrationConfigurationInitializer` to delegate to `IntegrationFlowBeanPostProcessor`
to allow to use components from `IntegrationFlowBuilder` via `@Autowired`
2014-02-13 21:44:48 +02:00
Artem Bilan
ae349bd5d8 Provide Copyright for classes 2014-02-12 12:35:18 +02:00
Gary Russell
e91b6de83c Make gradlew Executable 2014-02-11 18:12:55 -05:00
Artem Bilan
eca4680f0e INTEXT-96: The Java DSL initial implementation
JIRA: https://jira.springsource.org/browse/INTEXT-96

* `MessageChannels` Builder
* Configuration infrastructure
* `Pollers` Builder
* Initial `IntegrationFlows` Builder
* `EndpointConfigurer` Specs
* EIP-methods `from(MessageSource)`, `from(MessageChannel)`, `transform`, `filter`
2014-02-12 00:40:58 +02:00
Artem Bilan
b0cc426d98 INTEXT-95: Create SI Java DSL Project
JIRA: https://jira.springsource.org/browse/INTEXT-95
2014-02-04 21:34:29 +02:00
Rajasekar Elango
b4a51d4cf5 INTEXT-92 Kafka: Add support for specifying any producer/consumer property
* Update README.md for producer and consumer properties usage
2013-11-19 17:12:13 -05:00
Gunnar Hillert
ab3b62e0aa Merge pull request #58 from relango/merge-master-kafka-topic-filter
* relango-merge-master-kafka-topic-filter:
  INTEXT-77 Add Kafka topic filter support for producer + consumer
2013-10-28 17:08:47 -04:00
Rajasekar Elango
3e7b7d1331 INTEXT-77 Add Kafka topic filter support for producer + consumer
* Add tests
* Add samples
* Update readme

Jira: https://jira.springsource.org/browse/INTEXT-77
2013-10-28 17:06:52 -04:00
Gary Russell
b588aa4667 INTEXT-90 Update Paho Client to 0.4.0
Add eclipse paho repo.
2013-10-02 14:15:00 -04:00
Gary Russell
76c65ec6db INTEXT-89 Fix Inbound Stop When No Server
The reconnection task was not canceled in doStop().
2013-10-02 13:44:52 -04:00
Gunnar Hillert
9fe0d02ef8 Merge pull request #56 from sobychacko/INTEXT-84
* sobychacko-INTEXT-84:
  INTEXT-84 Kafka: Enhance Avro serialization support
2013-08-01 16:23:26 -04:00
Soby Chacko
b28bf4b06c INTEXT-84 Kafka: Enhance Avro serialization support 2013-08-01 16:20:24 -04:00
Gunnar Hillert
d99de8c740 Merge pull request #55 from ghillert/INTEXT-83
INTEXT-83 Update to Kafka 0.8.0-beta1
2013-07-16 14:06:12 -07:00
Gunnar Hillert
bd173c8197 INTEXT-83 Update to Kafka 0.8.0-beta1 2013-07-16 16:58:04 -04:00
Gunnar Hillert
9bfee92743 Merge pull request #43 from kcrimson/master
* kcrimson-master:
  INTEXT-65 Add JGroups Extension
2013-07-15 17:41:10 -04:00
jpalka
3931ae5826 INTEXT-65 Add JGroups Extension 2013-07-15 17:39:20 -04:00
Gunnar Hillert
4ffdabdee6 Merge pull request #52 from bellwethr/master
* bellwethr-master:
  INTEXT-81 Add unit tests
  INTEXT-81 Fixing bug in decoding message streams * adding a null check on the key decoder
2013-07-15 12:45:42 -04:00
Gunnar Hillert
7d0806c773 INTEXT-81 Add unit tests 2013-07-15 12:44:08 -04:00
Kevin Eustice
86be5e1b78 INTEXT-81 Fixing bug in decoding message streams
* adding a null check on the key decoder

https://jira.springsource.org/browse/INTEXT-81
2013-07-15 12:43:04 -04:00
Gunnar Hillert
e1f400e2cf Update README.md 2013-07-15 10:04:58 -04:00
Gunnar Hillert
9b7fba196d Updated list of available modules 2013-07-15 10:02:23 -04:00
Gunnar Hillert
d9bcbdc14b Moved Kafka Test Context Files 2013-06-03 15:29:43 -04:00