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
* Add `Spec` implementations for `JmsChannel`s
* Fix the bug around `SourcePollingChannelAdapterFactoryBean` named bean registration
* Remove unused classes
* Add test for `Jms.pollableChannel`
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
* 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
* 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`
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.