511 Commits

Author SHA1 Message Date
Artem Bilan
a35db31e61 DSL: Add Jms.inboundGateway() infrastructure 2014-06-12 18:16:43 +03:00
Olivier Lamy
49538abbe6 INTEXT-105: Fix "index" property according to the schema
JIRA: https://jira.spring.io/browse/INTEXT-105

Previously the `SplunkIndexWriter` has property `indexName`,
however the XSD for `<int-splunk:index-writer/>` provides the `index` attribute

Rename the property and add parser test
2014-06-12 14:09:28 +03:00
Artem Bilan
b42e6e1503 DSL: JMS in/out adapters, outbound gateway
* Others fixes, improvements and refactoring
2014-06-11 19:16:57 +03:00
Artem Bilan
7394516a2d DSL: Add Jms factory
* Add `Spec` implementations for `JmsChannel`s
* Fix the bug around `SourcePollingChannelAdapterFactoryBean` named bean registration
* Remove unused classes
* Add test for `Jms.pollableChannel`
2014-06-10 18:42:23 +03:00
Artem Bilan
36063ec8f2 DSL: Add Amqp.*channel() support
* Upgrade to the latest Boot snapshot
* Polishing and workarounds for `Proxy` beans. Caused by `@EnableJmx`
2014-06-09 13:54:40 +03:00
Artem Bilan
bb85518449 INTEXT-94: Fix Auth bug for Splunk 6.x
JIRA: https://jira.spring.io/browse/INTEXT-94

* Upgrade to Splunk Client 1.3
2014-06-06 17:35:29 +03:00
Olivier Lamy
198205058c Splunk: Servers failover
upgrade versions

Conflicts:
	spring-integration-splunk/gradle.properties

upgrade gradle version

revert spring integration upgrade version

Add a feature to be able to declare more than one splunk server.
It's a simple failover mechanism with any pooling.
Before give back the Service instance, the framework just try a getInfo call.
To preserve backward compat this check it's not activated per default but only
if the splunk server instance is marked with testOnBorrow.

Sample:
````xml
  <int-splunk:server id="splunkServer" host="${splunk.server.host}" port="${splunk.server.port}"
                     username="${splunk.server.username}" password="${splunk.server.password}"
                     owner="${splunk.server.owner}" scheme="${splunk.server.scheme}" testOnBorrow="true" />

  <int-splunk:server id="splunkServerBackup" host="localhost" port="9999"
                     username="${splunk.server.username}" password="${splunk.server.password}"
                     owner="${splunk.server.owner}" scheme="${splunk.server.scheme}" testOnBorrow="true" />

  <util:list id="splunkServersList">
    <ref bean="splunkServer" />
    <ref bean="splunkServerBackup" />
  </util:list>

  <bean id="splunkServiceFactory" class="org.springframework.integration.splunk.support.SplunkServiceFactory">
    <constructor-arg ref="splunkServersList"/>
  </bean>

  <int-splunk:inbound-channel-adapter id="splunk-notify-order-status-change-channel"
                                      auto-startup="true"
                                      search=""
                                      splunk-server-ref="splunkServer;splunkServerBackup"
                                      channel="notify-order-status-change-input"
                                      mode="BLOCKING"
                                      init-earliest-time="${splunk.order-status-change.init-earliest-time}"
                                      >
    <int:poller fixed-rate="${splunk.order-status-change.pooling.rate.time}" time-unit="SECONDS"/>
  </int-splunk:inbound-channel-adapter>
````

some changes due to pr comments

Conflicts:
	spring-integration-splunk/gradle.properties

formatting: tabs instead of spaces.....

fix documentation with failover mechanism

formatting

formatting

upgrade versions

some changes due to pr comments

fix javadoc issues

1.1 xsd file

Polishing and upgrading
2014-06-06 13:49:32 +03:00
Artem Bilan
dd085c8945 DSL: Fix @Autowired issue for IntegrationFlows
* Move DSL parser logic from `BFPP` to `BPP` as soon as the DSL doesn't populate any `BeanDefinition` - just real objects,
which can be registered with `this.beanFactory.registerSingleton(beanName, component);`
* Add more DSL for `Amqp` 'Namespace' factory and provide tests on the matter
* Comment out `spring-integration-jdbc` and `spring-integration-jpa` dependecies because the provide `spring-jdbc` dependency,
but it causes an issue in Boot: https://github.com/spring-projects/spring-boot/issues/1041
2014-06-06 00:38:21 +03:00
Gary Russell
5bf98b033b Remove spring-integration-mqtt from master 2014-06-02 15:27:31 -04:00
Spring Buildmaster
c8ed4a5036 [artifactory-release] Splunk Next development version 2014-06-02 17:24:04 +03:00
Spring Buildmaster
4adcd74534 [artifactory-release] Splunk Release version 1.1.0.M2 2014-06-02 17:24:03 +03:00
Glenn Renfro
3ba75060eb XD-1170 updted import for MessageHandlingException 2014-06-02 17:24:03 +03:00
Spring Buildmaster
cce7bb94b3 [artifactory-release] Next development version 2014-06-02 17:24:03 +03:00
Spring Buildmaster
57469b3977 [artifactory-release] Release version 1.1.0.M1 2014-06-02 17:24:03 +03:00
Glenn Renfro
aafda12a5f Uses Spring 4.0 dependencies
Updated the buid version 1.1.0
2014-06-02 17:24:03 +03:00
Spring Buildmaster
ae579c6686 [artifactory-release] Next development version 2014-06-02 17:24:03 +03:00
Spring Buildmaster
9dad1a01c5 [artifactory-release] Release version 4.0.0.M2 2014-06-02 17:24:03 +03:00
Gary Russell
cca2fbcc74 MQTT Update to SI 4.0.0.M2, SPR 4.0.0.RELEASE
Conflicts:
	spring-integration-mqtt/build.gradle
2014-06-02 17:24:03 +03:00
Glenn Renfro
e2af9fb629 Updated MQTTMessageConverter to use new classpath
Conflicts:
	spring-integration-mqtt/build.gradle
2014-06-02 17:24:03 +03:00
Spring Buildmaster
b1b4517f9b [artifactory-release] Next development version 2014-06-02 17:24:03 +03:00
Spring Buildmaster
b3f995967d [artifactory-release] Release version mqtt 4.0.0.M1 2014-06-02 17:24:03 +03:00
Gary Russell
b22a130a87 MQTT - Update to Spring Integration 4.0.0.M1
Conflicts:
	spring-integration-mqtt/build.gradle
2014-06-02 17:24:03 +03:00
Gary Russell
46cf219b44 MQTT - Use INT/SPR 4.0.0
Conflicts:
	spring-integration-mqtt/build.gradle
2014-06-02 17:24:03 +03:00
Artem Bilan
2dd27c5df9 DSL: Clean up some IntegrationFlowBuilder API 2014-06-02 16:57:33 +03:00
Artem Bilan
f7529453b4 DSL: Tests for @Autowired handlers 2014-05-29 16:04:51 +03:00
Artem Bilan
71dd35c0e7 SMPP: Fix typo in README
PR: https://github.com/spring-projects/spring-integration-extensions/pull/71
2014-05-29 07:57:08 +03:00
Artem Bilan
7fe2845cd0 DSL: Add @Autowired @Lazy test 2014-05-28 08:46:55 +03:00
Artem Bilan
3c5db06ed7 DSL: Add LambdaMessageProcessor 2014-05-26 18:33:12 +03:00
Artem Bilan
2a25a1960f DSL: add gateway() EIP-method
* Upgrade dependencies
* Polishing `Transformers`
2014-05-22 20:43:38 +03:00
Artem Bilan
77026e8261 DSL: Add IntegrationFlows.from(MGSupport)
* Introduce `Amqp` components factory
* Add `AmqpInboundGatewaySpec` builder
2014-05-19 20:52:51 +03:00
Artem Bilan
38269df437 DSL: Add fluent Transformers factory 2014-05-15 23:06:56 +03:00
Artem Bilan
61275dbc7e DSL: Add MessageProducer support 2014-05-11 22:57:38 +03:00
Spring Buildmaster
54f8cd306d [artifactory-release] Next development version 2014-05-08 11:07:21 -07:00
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