50 Commits

Author SHA1 Message Date
Artem Bilan
54aecf7db7 Fix typos in Hazelcast module README 2025-02-27 11:26:30 -05:00
Artem Bilan
86b4df68c6 Migrate the latest source code of spring-integration-hazelcast
* Mention in the README.md why it was deprecated in Spring Integration
2025-02-27 11:24:07 -05:00
Artem Bilan
554ec349fd Note about migration HZ extension to SI project 2022-07-13 17:46:10 -04:00
Robert Höglund
e11e65e3f5 GH-259: Ensure lock after HZ cluster shutdown
Fixes https://github.com/spring-projects/spring-integration-extensions/issues/259

This will ensure that, if a HZ cluster is totally shut down and then restarted
the leader state will be reset if the client still possess/regain the lock.
2022-05-18 16:31:11 -04:00
Artem Bilan
68c842bdbd GH-248: Use keySet() for HazelcastMS to list keys
Fixes https://github.com/spring-projects/spring-integration-extensions/issues/248

The `HazelcastMessageStore.doListKeys()` uses `this.map.values()`
by mistake.

* Fix `HazelcastMessageStore.doListKeys()` to use a `keySet()` for a proper filtering
and result inferring
* Add unit test to cover an iteration functionality for message groups in the store
2021-11-18 10:05:50 -05:00
al81-ru
8daf84e074 Refactor Hazelcast leader initiator yielding
* refactor yielding and fix warn messages
2020-12-14 09:56:03 -05:00
Artem Bilan
eac77e8b84 Adjust repositories in build.gradle 2020-11-25 14:34:17 -05:00
al81-ru
946f0c4cd2 GH-237: Implement getRole() for HazelcastContext
Fixes https://github.com/spring-projects/spring-integration-extensions/issues/237
2020-11-25 14:23:32 -05:00
Spring Buildmaster
9a8c3a2e89 [artifactory-release] Next development version 2020-10-29 18:11:42 +00:00
Spring Buildmaster
2ea73db449 [artifactory-release] Release version 3.0.0 2020-10-29 18:11:38 +00:00
Artem Bilan
43ae2d630b Prepare project for release
* Upgrade to the latest dependencies
* Migrate assertions in tests to AssertJ
* Optimize tests to use unsafe mode for CP-subsystem
for better test execution performance
2020-10-29 14:01:29 -04:00
Mael Le Guével
b568662cdb GH-235: Fix a memory leak in HZ LeaderInitiator
Fixes https://github.com/spring-projects/spring-integration-extensions/issues/235

According to the hazelcast team:
"The logic assumes that locks are generally acquired
& released in a fairly short time or hold a very long time without unlocking.
But in this case, is a bit different, it holds the lock for a long time,
but also does lock/unlock very frequently".

The previous implementation used the described logic,
first acquiring a lock and then doing frequent `tryLock/unlock`.
Doing this leads to
`com.hazelcast.cp.internal.datastructures.lockLock#ownerInvocationRefUids`
to grow without ever being cleaned thus leading to an `OutOfMemoryError` eventually.

* Rely on the `FencedLock.isLocked()` instead of frequent `tryLock/unlock`
* Fix `LeaderInitiatorTests` not to spawn 3 CP members since an unsafe mode is
enough to test the feature
2020-10-19 11:52:29 -04:00
Artem Bilan
00042c12e6 Start version 3.0.0
* Upgrade dependencies
* Fix deprecations; logic according new Hazelcast
* Upgrade Gradle
2020-10-06 12:50:02 -04:00
Spring Buildmaster
668f31b97e [artifactory-release] Next development version 2019-11-05 20:17:45 +00:00
Spring Buildmaster
50f96f6ed2 [artifactory-release] Release version Hazelcast 2.0.0.RELEASE 2019-11-05 20:17:41 +00:00
Artem Bilan
fe6ffee60c Start version 2.0.0
Fixes https://github.com/spring-projects/spring-integration-extensions/issues/197

* Upgrade dependencies
* Fix deprecations; logic according new Hazelcast
* Fix tests for CP Subsystem
* Upgrade Gradle
* Prepare for release
2019-11-05 14:50:30 -05:00
Artem Bilan
220971e6da Add HTTPS entries for XSD into spring.schemas
Related to spring-projects/spring-integration#2987
2019-07-18 13:37:00 -04:00
Artem Bilan
804e0e9ccf URL Cleanup
This commit updates URLs to prefer the https protocol.
Redirects are not followed to avoid accidentally expanding intentionally
shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed But Review Recommended
These URLs were fixed, but the https status was not OK.
However, the https status was the same as the http request or http redirected to an https URL, so they were migrated.
Your review is recommended.

* [ ] http://developer.marklogic.com/express (301) with 1 occurrences migrated to:
  /free-developer ([https](https://developer.marklogic.com/express) result IllegalArgumentException).
* [ ] http://opensmpp.logica.com/CommonPart/Download/download2.html (301) with 1 occurrences migrated to:
  https://public.cgi.com/CommonPart/Download/download2.html ([https](https://opensmpp.logica.com/CommonPart/Download/download2.html) result SSLHandshakeException).
* [ ] http://0.0.0.0:2379 (AnnotatedConnectException) with 2 occurrences migrated to:
  https://0.0.0.0:2379 ([https](https://0.0.0.0:2379) result AnnotatedConnectException).
* [ ] http://en.wikipedia.org/wiki/Zip_%28file_format%29 (301) with 1 occurrences migrated to:
  https://en.wikipedia.org/wiki/Zip_%2528file_format%2529 ([https](https://en.wikipedia.org/wiki/Zip_%28file_format%29) result 400).
* [ ] http://build.spring.io/plugins/servlet/buildStatusImage/INTEXT-ZIP (301) with 1 occurrences migrated to:
  https://build.spring.io/plugins/servlet/buildStatusImage/INTEXT-ZIP ([https](https://build.spring.io/plugins/servlet/buildStatusImage/INTEXT-ZIP) result 404).
* [ ] http://docs.hazelcast.org/docs/latest/manual/html/continuousquery.html (301) with 1 occurrences migrated to:
  https://docs.hazelcast.org/docs/latest/manual/html/continuousquery.html ([https](https://docs.hazelcast.org/docs/latest/manual/html/continuousquery.html) result 404).
* [ ] http://docs.hazelcast.org/docs/latest/manual/html/distributed-data-structures.html (301) with 1 occurrences migrated to:
  https://docs.hazelcast.org/docs/latest/manual/html/distributed-data-structures.html ([https](https://docs.hazelcast.org/docs/latest/manual/html/distributed-data-structures.html) result 404).
* [ ] http://docs.hazelcast.org/docs/latest/manual/html/distributedevents.html (301) with 1 occurrences migrated to:
  https://docs.hazelcast.org/docs/latest/manual/html/distributedevents.html ([https](https://docs.hazelcast.org/docs/latest/manual/html/distributedevents.html) result 404).
* [ ] http://docs.hazelcast.org/docs/latest/manual/html/distributedquery.html (301) with 1 occurrences migrated to:
  https://docs.hazelcast.org/docs/latest/manual/html/distributedquery.html ([https](https://docs.hazelcast.org/docs/latest/manual/html/distributedquery.html) result 404).
* [ ] http://docs.spring.io/spring-integration/reference/html/system-management-chapter.html (301) with 3 occurrences migrated to:
  https://docs.spring.io/spring-integration/reference/html/system-management-chapter.html ([https](https://docs.spring.io/spring-integration/reference/html/system-management-chapter.html) result 404).
* [ ] http://docs.spring.io/spring-integration/reference/html/xmpp.html (301) with 1 occurrences migrated to:
  https://docs.spring.io/spring-integration/reference/html/xmpp.html ([https](https://docs.spring.io/spring-integration/reference/html/xmpp.html) result 404).
* [ ] http://help.github.com/send-pull-requests (404) with 1 occurrences migrated to:
  https://help.github.com/send-pull-requests ([https](https://help.github.com/send-pull-requests) result 404).
* [ ] http://www.springframework.org/schema/integration/hazelcast/spring-integration-hazelcast.xsd (404) with 1 occurrences migrated to:
  https://www.springframework.org/schema/integration/hazelcast/spring-integration-hazelcast.xsd ([https](https://www.springframework.org/schema/integration/hazelcast/spring-integration-hazelcast.xsd) result 404).
* [ ] http://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd (404) with 3 occurrences migrated to:
  https://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd ([https](https://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd) result 404).
* [ ] http://www.springframework.org/schema/integration/print/spring-integration-print.xsd (404) with 1 occurrences migrated to:
  https://www.springframework.org/schema/integration/print/spring-integration-print.xsd ([https](https://www.springframework.org/schema/integration/print/spring-integration-print.xsd) result 404).
* [ ] http://www.springframework.org/schema/integration/twitter/spring-integration-social-twitter.xsd (404) with 1 occurrences migrated to:
  https://www.springframework.org/schema/integration/twitter/spring-integration-social-twitter.xsd ([https](https://www.springframework.org/schema/integration/twitter/spring-integration-social-twitter.xsd) result 404).
* [ ] http://www.springframework.org/schema/integration/voldemort/spring-integration-voldemort.xsd (404) with 2 occurrences migrated to:
  https://www.springframework.org/schema/integration/voldemort/spring-integration-voldemort.xsd ([https](https://www.springframework.org/schema/integration/voldemort/spring-integration-voldemort.xsd) result 404).
* [ ] http://search.twitter.com/operators (410) with 1 occurrences migrated to:
  https://search.twitter.com/operators ([https](https://search.twitter.com/operators) result 410).

## Fixed Success
These URLs were switched to an https URL with a 2xx status.
While the status was successful, your review is still recommended.

* [ ] http://aws.amazon.com/ with 1 occurrences migrated to:
  https://aws.amazon.com/ ([https](https://aws.amazon.com/) result 200).
* [ ] http://aws.amazon.com/s3/ with 1 occurrences migrated to:
  https://aws.amazon.com/s3/ ([https](https://aws.amazon.com/s3/) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/api/javax/print/DocFlavor.html with 3 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/api/javax/print/DocFlavor.html ([https](https://docs.oracle.com/javase/6/docs/api/javax/print/DocFlavor.html) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/api/javax/print/PrintService.html with 1 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/api/javax/print/PrintService.html ([https](https://docs.oracle.com/javase/6/docs/api/javax/print/PrintService.html) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/api/javax/print/attribute/Attribute.html with 1 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/Attribute.html ([https](https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/Attribute.html) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Chromaticity.html with 1 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Chromaticity.html ([https](https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Chromaticity.html) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Copies.html with 1 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Copies.html ([https](https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Copies.html) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/MediaSizeName.html with 1 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/MediaSizeName.html ([https](https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/MediaSizeName.html) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/MediaTray.html with 1 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/MediaTray.html ([https](https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/MediaTray.html) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Sides.html with 1 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Sides.html ([https](https://docs.oracle.com/javase/6/docs/api/javax/print/attribute/standard/Sides.html) result 200).
* [ ] http://docs.oracle.com/javase/6/docs/technotes/guides/jps/index.html with 2 occurrences migrated to:
  https://docs.oracle.com/javase/6/docs/technotes/guides/jps/index.html ([https](https://docs.oracle.com/javase/6/docs/technotes/guides/jps/index.html) result 200).
* [ ] http://docs.splunk.com/Documentation/Splunk/latest/Data/Monitornetworkports with 1 occurrences migrated to:
  https://docs.splunk.com/Documentation/Splunk/latest/Data/Monitornetworkports ([https](https://docs.splunk.com/Documentation/Splunk/latest/Data/Monitornetworkports) result 200).
* [ ] http://docs.spring.io/spring-integration/reference/ with 4 occurrences migrated to:
  https://docs.spring.io/spring-integration/reference/ ([https](https://docs.spring.io/spring-integration/reference/) result 200).
* [ ] http://docs.spring.io/spring-integration/reference/html/ with 1 occurrences migrated to:
  https://docs.spring.io/spring-integration/reference/html/ ([https](https://docs.spring.io/spring-integration/reference/html/) result 200).
* [ ] http://en.wikipedia.org/wiki/Server_Message_Block with 4 occurrences migrated to:
  https://en.wikipedia.org/wiki/Server_Message_Block ([https](https://en.wikipedia.org/wiki/Server_Message_Block) result 200).
* [ ] http://en.wikipedia.org/wiki/Short_Message_Peer-to-Peer with 2 occurrences migrated to:
  https://en.wikipedia.org/wiki/Short_Message_Peer-to-Peer ([https](https://en.wikipedia.org/wiki/Short_Message_Peer-to-Peer) result 200).
* [ ] http://en.wikipedia.org/wiki/Short_Message_Service with 1 occurrences migrated to:
  https://en.wikipedia.org/wiki/Short_Message_Service ([https](https://en.wikipedia.org/wiki/Short_Message_Service) result 200).
* [ ] http://en.wikipedia.org/wiki/Short_message_service_center with 1 occurrences migrated to:
  https://en.wikipedia.org/wiki/Short_message_service_center ([https](https://en.wikipedia.org/wiki/Short_message_service_center) result 200).
* [ ] http://en.wikipedia.org/wiki/XML_database with 1 occurrences migrated to:
  https://en.wikipedia.org/wiki/XML_database ([https](https://en.wikipedia.org/wiki/XML_database) result 200).
* [ ] http://en.wikipedia.org/wiki/XPath_2.0 with 1 occurrences migrated to:
  https://en.wikipedia.org/wiki/XPath_2.0 ([https](https://en.wikipedia.org/wiki/XPath_2.0) result 200).
* [ ] http://en.wikipedia.org/wiki/XQuery with 3 occurrences migrated to:
  https://en.wikipedia.org/wiki/XQuery ([https](https://en.wikipedia.org/wiki/XQuery) result 200).
* [ ] http://en.wikipedia.org/wiki/XQuery_API_for_Java with 1 occurrences migrated to:
  https://en.wikipedia.org/wiki/XQuery_API_for_Java ([https](https://en.wikipedia.org/wiki/XQuery_API_for_Java) result 200).
* [ ] http://gradle.org with 1 occurrences migrated to:
  https://gradle.org ([https](https://gradle.org) result 200).
* [ ] http://hazelcast.org/ with 1 occurrences migrated to:
  https://hazelcast.org/ ([https](https://hazelcast.org/) result 200).
* [ ] http://hillert.blogspot.com/2011/12/java-print-service-frustrations.html with 1 occurrences migrated to:
  https://hillert.blogspot.com/2011/12/java-print-service-frustrations.html ([https](https://hillert.blogspot.com/2011/12/java-print-service-frustrations.html) result 200).
* [ ] http://jcp.org/aboutJava/communityprocess/final/jsr225/index.html with 1 occurrences migrated to:
  https://jcp.org/aboutJava/communityprocess/final/jsr225/index.html ([https](https://jcp.org/aboutJava/communityprocess/final/jsr225/index.html) result 200).
* [ ] http://kafka.apache.org/ with 1 occurrences migrated to:
  https://kafka.apache.org/ ([https](https://kafka.apache.org/) result 200).
* [ ] http://maven.apache.org/ with 2 occurrences migrated to:
  https://maven.apache.org/ ([https](https://maven.apache.org/) result 200).
* [ ] http://mqtt.org/ with 2 occurrences migrated to:
  https://mqtt.org/ ([https](https://mqtt.org/) result 200).
* [ ] http://oauth.net with 2 occurrences migrated to:
  https://oauth.net ([https](https://oauth.net) result 200).
* [ ] http://projects.spring.io/spring-social-twitter/ with 2 occurrences migrated to:
  https://projects.spring.io/spring-social-twitter/ ([https](https://projects.spring.io/spring-social-twitter/) result 200).
* [ ] http://spring.io with 4 occurrences migrated to:
  https://spring.io ([https](https://spring.io) result 200).
* [ ] http://spring.io/ with 4 occurrences migrated to:
  https://spring.io/ ([https](https://spring.io/) result 200).
* [ ] http://stackoverflow.com/faq with 2 occurrences migrated to:
  https://stackoverflow.com/faq ([https](https://stackoverflow.com/faq) result 200).
* [ ] http://stackoverflow.com/questions/3725662/what-is-the-earliest-timestamp-value-that-is-supported-in-zip-file-format with 2 occurrences migrated to:
  https://stackoverflow.com/questions/3725662/what-is-the-earliest-timestamp-value-that-is-supported-in-zip-file-format ([https](https://stackoverflow.com/questions/3725662/what-is-the-earliest-timestamp-value-that-is-supported-in-zip-file-format) result 200).
* [ ] http://stackoverflow.com/questions/tagged/spring-integration with 2 occurrences migrated to:
  https://stackoverflow.com/questions/tagged/spring-integration ([https](https://stackoverflow.com/questions/tagged/spring-integration) result 200).
* [ ] http://vimeo.com/34436402 with 1 occurrences migrated to:
  https://vimeo.com/34436402 ([https](https://vimeo.com/34436402) result 200).
* [ ] http://wiki.apache.org/cassandra/HintedHandoff with 1 occurrences migrated to:
  https://wiki.apache.org/cassandra/HintedHandoff ([https](https://wiki.apache.org/cassandra/HintedHandoff) result 200).
* [ ] http://wiki.apache.org/cassandra/Operations with 3 occurrences migrated to:
  https://wiki.apache.org/cassandra/Operations ([https](https://wiki.apache.org/cassandra/Operations) result 200).
* [ ] http://wiki.apache.org/cassandra/StorageConfiguration with 1 occurrences migrated to:
  https://wiki.apache.org/cassandra/StorageConfiguration ([https](https://wiki.apache.org/cassandra/StorageConfiguration) result 200).
* [ ] http://www.apache.org with 11 occurrences migrated to:
  https://www.apache.org ([https](https://www.apache.org) result 200).
* [ ] http://www.html5rocks.com/en/tutorials/websockets/basics/ with 1 occurrences migrated to:
  https://www.html5rocks.com/en/tutorials/websockets/basics/ ([https](https://www.html5rocks.com/en/tutorials/websockets/basics/) result 200).
* [ ] http://www.nowsms.com/long-sms-text-messages-and-the-160-character-limit with 1 occurrences migrated to:
  https://www.nowsms.com/long-sms-text-messages-and-the-160-character-limit ([https](https://www.nowsms.com/long-sms-text-messages-and-the-160-character-limit) result 200).
* [ ] http://www.nowsms.com/smpp-information with 1 occurrences migrated to:
  https://www.nowsms.com/smpp-information ([https](https://www.nowsms.com/smpp-information) result 200).
* [ ] http://www.project-voldemort.com/ with 1 occurrences migrated to:
  https://www.project-voldemort.com/ ([https](https://www.project-voldemort.com/) result 200).
* [ ] http://www.project-voldemort.com/voldemort/ with 1 occurrences migrated to:
  https://www.project-voldemort.com/voldemort/ ([https](https://www.project-voldemort.com/voldemort/) result 200).
* [ ] http://www.sedna.org/ with 2 occurrences migrated to:
  https://www.sedna.org/ ([https](https://www.sedna.org/) result 200).
* [ ] http://www.splunk.com/ with 2 occurrences migrated to:
  https://www.splunk.com/ ([https](https://www.splunk.com/) result 200).
* [ ] http://www.springframework.org/schema/beans/spring-beans.xsd with 6 occurrences migrated to:
  https://www.springframework.org/schema/beans/spring-beans.xsd ([https](https://www.springframework.org/schema/beans/spring-beans.xsd) result 200).
* [ ] http://www.springframework.org/schema/integration/spring-integration-2.2.xsd with 6 occurrences migrated to:
  https://www.springframework.org/schema/integration/spring-integration-2.2.xsd ([https](https://www.springframework.org/schema/integration/spring-integration-2.2.xsd) result 200).
* [ ] http://www.springframework.org/schema/integration/spring-integration-4.2.xsd with 1 occurrences migrated to:
  https://www.springframework.org/schema/integration/spring-integration-4.2.xsd ([https](https://www.springframework.org/schema/integration/spring-integration-4.2.xsd) result 200).
* [ ] http://www.springframework.org/schema/integration/spring-integration-5.1.xsd with 1 occurrences migrated to:
  https://www.springframework.org/schema/integration/spring-integration-5.1.xsd ([https](https://www.springframework.org/schema/integration/spring-integration-5.1.xsd) result 200).
* [ ] http://www.springframework.org/schema/integration/spring-integration.xsd with 9 occurrences migrated to:
  https://www.springframework.org/schema/integration/spring-integration.xsd ([https](https://www.springframework.org/schema/integration/spring-integration.xsd) result 200).
* [ ] http://www.techdive.in/java/send-sms-using-jsmpp with 1 occurrences migrated to:
  https://www.techdive.in/java/send-sms-using-jsmpp ([https](https://www.techdive.in/java/send-sms-using-jsmpp) result 200).
* [ ] http://contributor-covenant.org with 1 occurrences migrated to:
  https://contributor-covenant.org ([https](https://contributor-covenant.org) result 301).
* [ ] http://contributor-covenant.org/version/1/3/0/ with 1 occurrences migrated to:
  https://contributor-covenant.org/version/1/3/0/ ([https](https://contributor-covenant.org/version/1/3/0/) result 301).
* [ ] http://static.springsource.org/spring-integration/reference (301) with 5 occurrences migrated to:
  https://docs.spring.io/spring-integration/reference ([https](https://static.springsource.org/spring-integration/reference) result 301).
* [ ] http://docs.spring.io/spring-integration/reference/html with 1 occurrences migrated to:
  https://docs.spring.io/spring-integration/reference/html ([https](https://docs.spring.io/spring-integration/reference/html) result 301).
* [ ] http://docs.spring.io/spring/docs/current/spring-framework-reference/html/expressions.html with 1 occurrences migrated to:
  https://docs.spring.io/spring/docs/current/spring-framework-reference/html/expressions.html ([https](https://docs.spring.io/spring/docs/current/spring-framework-reference/html/expressions.html) result 301).
* [ ] http://forum.springsource.org/forumdisplay.php?42-Integration (301) with 1 occurrences migrated to:
  https://forum.spring.io/forumdisplay.php?42-Integration ([https](https://forum.springsource.org/forumdisplay.php?42-Integration) result 301).
* [ ] http://help.github.com/set-up-git-redirect with 1 occurrences migrated to:
  https://help.github.com/set-up-git-redirect ([https](https://help.github.com/set-up-git-redirect) result 301).
* [ ] http://jira.springsource.org/browse/INTEXT with 1 occurrences migrated to:
  https://jira.springsource.org/browse/INTEXT ([https](https://jira.springsource.org/browse/INTEXT) result 301).
* [ ] http://projects.spring.io/spring-social with 1 occurrences migrated to:
  https://projects.spring.io/spring-social ([https](https://projects.spring.io/spring-social) result 301).
* [ ] http://support.twitter.com/articles/119138-types-of-tweets-and-where-they-appear with 1 occurrences migrated to:
  https://support.twitter.com/articles/119138-types-of-tweets-and-where-they-appear ([https](https://support.twitter.com/articles/119138-types-of-tweets-and-where-they-appear) result 301).
* [ ] http://www.linkedin.com/answers/technology/information-technology/telecommunications/TCH_ITS_TCI/461130-44316394 with 1 occurrences migrated to:
  https://www.linkedin.com/answers/technology/information-technology/telecommunications/TCH_ITS_TCI/461130-44316394 ([https](https://www.linkedin.com/answers/technology/information-technology/telecommunications/TCH_ITS_TCI/461130-44316394) result 301).
* [ ] http://www.splunk.com/download with 1 occurrences migrated to:
  https://www.splunk.com/download ([https](https://www.splunk.com/download) result 301).
* [ ] http://www.spring.io with 5 occurrences migrated to:
  https://www.spring.io ([https](https://www.spring.io) result 301).
* [ ] http://www.springframework.org with 6 occurrences migrated to:
  https://www.springframework.org ([https](https://www.springframework.org) result 301).
* [ ] http://www.springsource.com with 10 occurrences migrated to:
  https://www.springsource.com ([https](https://www.springsource.com) result 301).
* [ ] http://www.springsource.org/spring-integration with 18 occurrences migrated to:
  https://www.springsource.org/spring-integration ([https](https://www.springsource.org/spring-integration) result 301).
* [ ] http://www.springintegration.org/ (301) with 2 occurrences migrated to:
  https://www.springsource.org/spring-integration/ ([https](https://www.springintegration.org/) result 301).
* [ ] http://www.springsource.org/sts with 1 occurrences migrated to:
  https://www.springsource.org/sts ([https](https://www.springsource.org/sts) result 301).
* [ ] http://dev.twitter.com with 2 occurrences migrated to:
  https://dev.twitter.com ([https](https://dev.twitter.com) result 302).
* [ ] http://dev.twitter.com/pages/oauth_faq with 1 occurrences migrated to:
  https://dev.twitter.com/pages/oauth_faq ([https](https://dev.twitter.com/pages/oauth_faq) result 302).
* [ ] http://download.oracle.com/javase/6/docs/technotes/guides/security/jsse/JSSERefGuide.html with 1 occurrences migrated to:
  https://download.oracle.com/javase/6/docs/technotes/guides/security/jsse/JSSERefGuide.html ([https](https://download.oracle.com/javase/6/docs/technotes/guides/security/jsse/JSSERefGuide.html) result 302).
* [ ] http://hueniverse.com/oauth with 2 occurrences migrated to:
  https://hueniverse.com/oauth ([https](https://hueniverse.com/oauth) result 302).
* [ ] http://spring.io/spring-integration with 1 occurrences migrated to:
  https://spring.io/spring-integration ([https](https://spring.io/spring-integration) result 302).
* [ ] http://springsource.com/support/springsupport with 1 occurrences migrated to:
  https://springsource.com/support/springsupport ([https](https://springsource.com/support/springsupport) result 302).
* [ ] http://www.exist-db.org/ with 1 occurrences migrated to:
  https://www.exist-db.org/ ([https](https://www.exist-db.org/) result 302).

# Ignored
These URLs were intentionally ignored.

* http://www.springframework.org/schema/beans with 30 occurrences
* http://www.springframework.org/schema/integration with 34 occurrences
* http://www.springframework.org/schema/integration/cassandra with 2 occurrences
* http://www.springframework.org/schema/integration/hazelcast with 4 occurrences
* http://www.springframework.org/schema/integration/jgroups with 8 occurrences
* http://www.springframework.org/schema/integration/jt400 with 2 occurrences
* http://www.springframework.org/schema/integration/print with 4 occurrences
* http://www.springframework.org/schema/integration/smb with 3 occurrences
* http://www.springframework.org/schema/integration/smpp with 2 occurrences
* http://www.springframework.org/schema/integration/twitter with 4 occurrences
* http://www.springframework.org/schema/integration/voldemort with 6 occurrences
* http://www.springframework.org/schema/integration/xmpp with 2 occurrences
* http://www.springframework.org/schema/integration/xquery with 2 occurrences
* http://www.springframework.org/schema/integration/zip with 2 occurrences
* http://www.springframework.org/schema/tool with 24 occurrences
* http://www.w3.org/2001/XMLSchema with 12 occurrences
* http://www.w3.org/2001/XMLSchema-instance with 4 occurrences
2019-03-22 14:49:23 -04:00
Spring Operator
306eec5f5e URL Cleanup
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed Success
These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

* [ ] http://www.apache.org/licenses/ with 12 occurrences migrated to:
  https://www.apache.org/licenses/ ([https](https://www.apache.org/licenses/) result 200).
* [ ] http://www.apache.org/licenses/LICENSE-2.0 with 345 occurrences migrated to:
  https://www.apache.org/licenses/LICENSE-2.0 ([https](https://www.apache.org/licenses/LICENSE-2.0) result 200).
2019-03-22 13:41:58 -04:00
Artem Bilan
6e1de98d81 Upgrade to SF versions to resolve HTTPS for XSDs
* Fix the link to SI Reference in the Voldemort sample config
2019-03-20 16:15:52 -04:00
Spring Operator
4a3a088881 URL Cleanup
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed But Review Recommended
These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended.

* http://opensmpp.logica.com/CommonPart/Introduction/Introduction.htm (301) with 1 occurrences migrated to:
  https://public.cgi.com/CommonPart/Introduction/Introduction.htm ([https](https://opensmpp.logica.com/CommonPart/Introduction/Introduction.htm) result SSLHandshakeException).
* http://static.springsource.org/spring-integration/reference/htmlsingle/ (301) with 1 occurrences migrated to:
  https://docs.spring.io/spring-integration/reference/htmlsingle/ ([https](https://static.springsource.org/spring-integration/reference/htmlsingle/) result 404).
* http://www.puppycrawl.com/dtds/configuration_1_2.dtd (404) with 4 occurrences migrated to:
  https://www.puppycrawl.com/dtds/configuration_1_2.dtd ([https](https://www.puppycrawl.com/dtds/configuration_1_2.dtd) result 404).
* http://www.puppycrawl.com/dtds/suppressions_1_1.dtd (404) with 4 occurrences migrated to:
  https://www.puppycrawl.com/dtds/suppressions_1_1.dtd ([https](https://www.puppycrawl.com/dtds/suppressions_1_1.dtd) result 404).
* http://www.springframework.org/schema/integration/aws/spring-integration-aws.xsd (404) with 2 occurrences migrated to:
  https://www.springframework.org/schema/integration/aws/spring-integration-aws.xsd ([https](https://www.springframework.org/schema/integration/aws/spring-integration-aws.xsd) result 404).
* http://www.springframework.org/schema/integration/cassandra/spring-integration-cassandra.xsd (404) with 2 occurrences migrated to:
  https://www.springframework.org/schema/integration/cassandra/spring-integration-cassandra.xsd ([https](https://www.springframework.org/schema/integration/cassandra/spring-integration-cassandra.xsd) result 404).
* http://www.springframework.org/schema/integration/hazelcast/spring-integration-hazelcast.xsd (404) with 11 occurrences migrated to:
  https://www.springframework.org/schema/integration/hazelcast/spring-integration-hazelcast.xsd ([https](https://www.springframework.org/schema/integration/hazelcast/spring-integration-hazelcast.xsd) result 404).
* http://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd (404) with 4 occurrences migrated to:
  https://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd ([https](https://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd) result 404).
* http://www.springframework.org/schema/integration/print/spring-integration-print.xsd (404) with 2 occurrences migrated to:
  https://www.springframework.org/schema/integration/print/spring-integration-print.xsd ([https](https://www.springframework.org/schema/integration/print/spring-integration-print.xsd) result 404).
* http://www.springframework.org/schema/integration/smb/spring-integration-smb.xsd (404) with 8 occurrences migrated to:
  https://www.springframework.org/schema/integration/smb/spring-integration-smb.xsd ([https](https://www.springframework.org/schema/integration/smb/spring-integration-smb.xsd) result 404).
* http://www.springframework.org/schema/integration/smpp/spring-integration-smpp.xsd (404) with 10 occurrences migrated to:
  https://www.springframework.org/schema/integration/smpp/spring-integration-smpp.xsd ([https](https://www.springframework.org/schema/integration/smpp/spring-integration-smpp.xsd) result 404).
* http://www.springframework.org/schema/integration/splunk/spring-integration-splunk.xsd (404) with 11 occurrences migrated to:
  https://www.springframework.org/schema/integration/splunk/spring-integration-splunk.xsd ([https](https://www.springframework.org/schema/integration/splunk/spring-integration-splunk.xsd) result 404).
* http://www.springframework.org/schema/integration/twitter/spring-integration-social-twitter.xsd (404) with 11 occurrences migrated to:
  https://www.springframework.org/schema/integration/twitter/spring-integration-social-twitter.xsd ([https](https://www.springframework.org/schema/integration/twitter/spring-integration-social-twitter.xsd) result 404).
* http://www.springframework.org/schema/integration/voldemort/spring-integration-voldemort.xsd (404) with 5 occurrences migrated to:
  https://www.springframework.org/schema/integration/voldemort/spring-integration-voldemort.xsd ([https](https://www.springframework.org/schema/integration/voldemort/spring-integration-voldemort.xsd) result 404).
* http://www.springframework.org/schema/integration/xquery/spring-integration-xquery.xsd (404) with 3 occurrences migrated to:
  https://www.springframework.org/schema/integration/xquery/spring-integration-xquery.xsd ([https](https://www.springframework.org/schema/integration/xquery/spring-integration-xquery.xsd) result 404).
* http://www.springframework.org/schema/integration/zip/spring-integration-zip.xsd (404) with 7 occurrences migrated to:
  https://www.springframework.org/schema/integration/zip/spring-integration-zip.xsd ([https](https://www.springframework.org/schema/integration/zip/spring-integration-zip.xsd) result 404).

## Fixed Success
These URLs were switched to an https URL with a 2xx status. While the status was successful, your review is still recommended.

* http://en.wikipedia.org/wiki/Short_Message_Peer-to-Peer with 1 occurrences migrated to:
  https://en.wikipedia.org/wiki/Short_Message_Peer-to-Peer ([https](https://en.wikipedia.org/wiki/Short_Message_Peer-to-Peer) result 200).
* http://maven.apache.org/xsd/maven-4.0.0.xsd with 8 occurrences migrated to:
  https://maven.apache.org/xsd/maven-4.0.0.xsd ([https](https://maven.apache.org/xsd/maven-4.0.0.xsd) result 200).
* http://www.project-voldemort.com with 1 occurrences migrated to:
  https://www.project-voldemort.com ([https](https://www.project-voldemort.com) result 200).
* http://www.springframework.org/schema/beans/spring-beans.xsd with 103 occurrences migrated to:
  https://www.springframework.org/schema/beans/spring-beans.xsd ([https](https://www.springframework.org/schema/beans/spring-beans.xsd) result 200).
* http://www.springframework.org/schema/context/spring-context-3.1.xsd with 8 occurrences migrated to:
  https://www.springframework.org/schema/context/spring-context-3.1.xsd ([https](https://www.springframework.org/schema/context/spring-context-3.1.xsd) result 200).
* http://www.springframework.org/schema/context/spring-context.xsd with 31 occurrences migrated to:
  https://www.springframework.org/schema/context/spring-context.xsd ([https](https://www.springframework.org/schema/context/spring-context.xsd) result 200).
* http://www.springframework.org/schema/data/cassandra/spring-cassandra.xsd with 1 occurrences migrated to:
  https://www.springframework.org/schema/data/cassandra/spring-cassandra.xsd ([https](https://www.springframework.org/schema/data/cassandra/spring-cassandra.xsd) result 200).
* http://www.springframework.org/schema/integration/file/spring-integration-file.xsd with 7 occurrences migrated to:
  https://www.springframework.org/schema/integration/file/spring-integration-file.xsd ([https](https://www.springframework.org/schema/integration/file/spring-integration-file.xsd) result 200).
* http://www.springframework.org/schema/integration/jdbc/spring-integration-jdbc.xsd with 1 occurrences migrated to:
  https://www.springframework.org/schema/integration/jdbc/spring-integration-jdbc.xsd ([https](https://www.springframework.org/schema/integration/jdbc/spring-integration-jdbc.xsd) result 200).
* http://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd with 2 occurrences migrated to:
  https://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd ([https](https://www.springframework.org/schema/integration/kafka/spring-integration-kafka.xsd) result 200).
* http://www.springframework.org/schema/integration/mail/spring-integration-mail.xsd with 2 occurrences migrated to:
  https://www.springframework.org/schema/integration/mail/spring-integration-mail.xsd ([https](https://www.springframework.org/schema/integration/mail/spring-integration-mail.xsd) result 200).
* http://www.springframework.org/schema/integration/spring-integration-2.2.xsd with 4 occurrences migrated to:
  https://www.springframework.org/schema/integration/spring-integration-2.2.xsd ([https](https://www.springframework.org/schema/integration/spring-integration-2.2.xsd) result 200).
* http://www.springframework.org/schema/integration/spring-integration.xsd with 92 occurrences migrated to:
  https://www.springframework.org/schema/integration/spring-integration.xsd ([https](https://www.springframework.org/schema/integration/spring-integration.xsd) result 200).
* http://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd with 16 occurrences migrated to:
  https://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd ([https](https://www.springframework.org/schema/integration/stream/spring-integration-stream.xsd) result 200).
* http://www.springframework.org/schema/integration/xmpp/spring-integration-xmpp.xsd with 14 occurrences migrated to:
  https://www.springframework.org/schema/integration/xmpp/spring-integration-xmpp.xsd ([https](https://www.springframework.org/schema/integration/xmpp/spring-integration-xmpp.xsd) result 200).
* http://www.springframework.org/schema/jdbc/spring-jdbc.xsd with 1 occurrences migrated to:
  https://www.springframework.org/schema/jdbc/spring-jdbc.xsd ([https](https://www.springframework.org/schema/jdbc/spring-jdbc.xsd) result 200).
* http://www.springframework.org/schema/lang/spring-lang.xsd with 5 occurrences migrated to:
  https://www.springframework.org/schema/lang/spring-lang.xsd ([https](https://www.springframework.org/schema/lang/spring-lang.xsd) result 200).
* http://www.springframework.org/schema/task/spring-task.xsd with 1 occurrences migrated to:
  https://www.springframework.org/schema/task/spring-task.xsd ([https](https://www.springframework.org/schema/task/spring-task.xsd) result 200).
* http://www.springframework.org/schema/tool/spring-tool.xsd with 5 occurrences migrated to:
  https://www.springframework.org/schema/tool/spring-tool.xsd ([https](https://www.springframework.org/schema/tool/spring-tool.xsd) result 200).
* http://www.springframework.org/schema/util/spring-util.xsd with 8 occurrences migrated to:
  https://www.springframework.org/schema/util/spring-util.xsd ([https](https://www.springframework.org/schema/util/spring-util.xsd) result 200).
* http://code.google.com/p/jsmpp/ with 1 occurrences migrated to:
  https://code.google.com/p/jsmpp/ ([https](https://code.google.com/p/jsmpp/) result 301).
* http://www.eaipatterns.com/MessagingGateway.html (302) with 1 occurrences migrated to:
  https://www.enterpriseintegrationpatterns.com/MessagingGateway.html ([https](https://www.eaipatterns.com/MessagingGateway.html) result 301).
* http://www.springsource.org with 6 occurrences migrated to:
  https://www.springsource.org ([https](https://www.springsource.org) result 301).
* http://www.springsource.org/spring-integration with 3 occurrences migrated to:
  https://www.springsource.org/spring-integration ([https](https://www.springsource.org/spring-integration) result 301).

# Ignored
These URLs were intentionally ignored.

* http://docbook.org/ns/docbook with 15 occurrences
* http://jakarta.apache.org/log4j/ with 7 occurrences
* http://maven.apache.org/POM/4.0.0 with 16 occurrences
* http://www.springframework.org/schema/beans with 206 occurrences
* http://www.springframework.org/schema/context with 79 occurrences
* http://www.springframework.org/schema/data/cassandra with 2 occurrences
* http://www.springframework.org/schema/integration with 192 occurrences
* http://www.springframework.org/schema/integration/aws with 4 occurrences
* http://www.springframework.org/schema/integration/cassandra with 4 occurrences
* http://www.springframework.org/schema/integration/file with 14 occurrences
* http://www.springframework.org/schema/integration/hazelcast with 22 occurrences
* http://www.springframework.org/schema/integration/jdbc with 2 occurrences
* http://www.springframework.org/schema/integration/jgroups with 8 occurrences
* http://www.springframework.org/schema/integration/kafka with 4 occurrences
* http://www.springframework.org/schema/integration/mail with 4 occurrences
* http://www.springframework.org/schema/integration/print with 4 occurrences
* http://www.springframework.org/schema/integration/smb with 16 occurrences
* http://www.springframework.org/schema/integration/smpp with 20 occurrences
* http://www.springframework.org/schema/integration/splunk with 22 occurrences
* http://www.springframework.org/schema/integration/stream with 32 occurrences
* http://www.springframework.org/schema/integration/twitter with 22 occurrences
* http://www.springframework.org/schema/integration/voldemort with 10 occurrences
* http://www.springframework.org/schema/integration/xmpp with 28 occurrences
* http://www.springframework.org/schema/integration/xquery with 6 occurrences
* http://www.springframework.org/schema/integration/zip with 14 occurrences
* http://www.springframework.org/schema/jdbc with 2 occurrences
* http://www.springframework.org/schema/lang with 10 occurrences
* http://www.springframework.org/schema/p with 7 occurrences
* http://www.springframework.org/schema/task with 2 occurrences
* http://www.springframework.org/schema/tool with 10 occurrences
* http://www.springframework.org/schema/util with 16 occurrences
* http://www.w3.org/1999/xlink with 15 occurrences
* http://www.w3.org/2001/XInclude with 9 occurrences
* http://www.w3.org/2001/XMLSchema-instance with 111 occurrences
2019-03-20 15:56:18 -04:00
Spring Operator
86a589ccdb URL Cleanup
This commit updates URLs to prefer the https protocol. Redirects are not followed to avoid accidentally expanding intentionally shortened URLs (i.e. if using a URL shortener).

# Fixed URLs

## Fixed But Review Recommended
These URLs were fixed, but the https status was not OK. However, the https status was the same as the http request or http redirected to an https URL, so they were migrated. Your review is recommended.

* http://services.gradle.org/distributions/gradle- (404) migrated to:
  https://services.gradle.org/distributions/gradle- ([https](https://services.gradle.org/distributions/gradle-) result 404).

## Fixed Success
These URLs were fixed successfully.

* http://projects.spring.io/spring-integration/ migrated to:
  https://projects.spring.io/spring-integration/ ([https](https://projects.spring.io/spring-integration/) result 200).
* http://springsource.org (301) migrated to:
  https://spring.io ([https](https://springsource.org) result 200).
* http://spring.io migrated to:
  https://spring.io ([https](https://spring.io) result 200).
* http://www.apache.org/licenses/LICENSE-2.0.txt migrated to:
  https://www.apache.org/licenses/LICENSE-2.0.txt ([https](https://www.apache.org/licenses/LICENSE-2.0.txt) result 200).
* http://www.project-voldemort.com/voldemort/configuration.html migrated to:
  https://www.project-voldemort.com/voldemort/configuration.html ([https](https://www.project-voldemort.com/voldemort/configuration.html) result 200).
* http://repo.springsource.org/libs-milestone migrated to:
  https://repo.springsource.org/libs-milestone ([https](https://repo.springsource.org/libs-milestone) result 301).
* http://repo.springsource.org/libs-snapshot migrated to:
  https://repo.springsource.org/libs-snapshot ([https](https://repo.springsource.org/libs-snapshot) result 301).
* http://repo.springsource.org/plugins-release migrated to:
  https://repo.springsource.org/plugins-release ([https](https://repo.springsource.org/plugins-release) result 301).
* http://www.gradle.org/docs/current/dsl/org.gradle.api.artifacts.ConfigurationContainer.html migrated to:
  https://www.gradle.org/docs/current/dsl/org.gradle.api.artifacts.ConfigurationContainer.html ([https](https://www.gradle.org/docs/current/dsl/org.gradle.api.artifacts.ConfigurationContainer.html) result 301).
* http://www.gradle.org/docs/current/userguide/dependency_management.html migrated to:
  https://www.gradle.org/docs/current/userguide/dependency_management.html ([https](https://www.gradle.org/docs/current/userguide/dependency_management.html) result 301).
* http://www.springsource.org/spring-integration migrated to:
  https://www.springsource.org/spring-integration ([https](https://www.springsource.org/spring-integration) result 301).
* http://repo.spring.io/libs-milestone migrated to:
  https://repo.spring.io/libs-milestone ([https](https://repo.spring.io/libs-milestone) result 302).
* http://repo.spring.io/libs-snapshot migrated to:
  https://repo.spring.io/libs-snapshot ([https](https://repo.spring.io/libs-snapshot) result 302).
* http://repo.spring.io/libs-staging-local migrated to:
  https://repo.spring.io/libs-staging-local ([https](https://repo.spring.io/libs-staging-local) result 302).
* http://repo.spring.io/plugins-release migrated to:
  https://repo.spring.io/plugins-release ([https](https://repo.spring.io/plugins-release) result 302).

# Ignored
These URLs were intentionally ignored.

* http://maven.apache.org/POM/4.0.0
* http://maven.apache.org/xsd/maven-4.0.0.xsd
* http://www.w3.org/2001/XMLSchema-instance
2019-03-06 10:02:50 -05:00
Artem Bilan
2486fdaa41 GH-183: LeaderInitiator: Catch unlock errors
Fixes https://github.com/spring-projects/spring-integration-extensions/issues/183

When we get an exception during `lock.unlock()`, we don't revoke leadership.
If Hazelcast is down, this may cause a race condition when the second
candidate is selected as leader when connection comes back

* Catch `lock.unlock()` exceptions and log them under DEBUG.
This way we proceed to the `handleRevoked()` logic
2018-07-13 13:17:27 -04:00
Artem Bilan
d0df6dc5a8 GH-194: Propagate policy into MessageListener
Fixes https://github.com/spring-projects/spring-integration-extensions/issues/194

The `HazelcastEventDrivenMessageProducer.HazelcastMessageListener.processEvent()`
is missing to propagate the configured `CacheListeningPolicy`, thus
only the local member is able to listen message from the `ITopic`

* Add `getCacheListeningPolicy()` to the third argument of the `sendMessage()`
in the `HazelcastEventDrivenMessageProducer.HazelcastMessageListener.processEvent()`
2018-05-31 17:47:56 -04:00
Artem Bilan
11b8990daf Polishing catch block in the LeaderInitiator 2018-02-09 15:44:22 -05:00
Artem Bilan
f9c7cccf75 GH-183: Fix lifecycle issues in the LeaderInitiator
Fixes https://github.com/spring-projects/spring-integration-extensions/issues/183

* Replace `Thread.sleep(Long.MAX_VALUE);` in the `LeaderSelector` main
loop with the `heartBeatMillis` to `tryLock` against the Hazelcast
periodically
* Add `busyWaitMillis` timeout in case of lost leadership or exception
from the Hazelcast
* Resubmit `LeaderSelector` in case of any exception exception
* Upgrade to the Hazelcast-3.8.9 and SI-4.3.14
2018-02-06 14:42:56 -05:00
Spring Buildmaster
45395e80e5 [artifactory-release] Next development version 2017-07-17 19:15:16 +00:00
Spring Buildmaster
ca5867f64b [artifactory-release] Release version Hazelcast 1.0.0.RELEASE 2017-07-17 19:15:09 +00:00
Artem Bilan
e03e6e553e Document HazelcastLockRegistry 2017-07-17 15:03:02 -04:00
Vinicius Carvalho
89e6274cc5 Initial implementation of HazelcastMetadataStore
HazelcastMetadataStore improvements
 - Adding ListenableMetadataStore capabilities
 - Extra tests for listeners

Requested changes from review

* Make `HazelcastMetadataStore.MapListener` as static class
2017-07-14 21:35:50 -04:00
Artem Bilan
01184c1304 Add HazelcastLockRegistry implementation 2017-07-13 19:15:06 -04:00
Artem Bilan
5511987be2 GH-172: Do not require local HZ instances
Fixes spring-projects/spring-integration-extensions#172

Since we can have an application based on the `HazelcastClient`, we don't need to require `Hazelcast.getAllHazelcastInstances()` be presented.

* Rework `HazelcastLocalInstanceRegistrar` to be able to accept external `HazelcastInstance` for `MultiMap` and `MembershipListener` registration
* If there is on local `Hazelcast.getAllHazelcastInstances()` just log a warn that we can't register `MembershipListener`
* Allow for `AbstractHazelcastMessageProducer` to accept events in the `CacheListeningPolicyType.SINGLE` mode when there is no local `Hazelcast.getAllHazelcastInstances()`
2017-07-07 20:22:51 -04:00
Vinicius Carvalho
894a60b8bb Add Hazelcast MessageStore implementation
- Hazelcast implementation of the `MessageStore`
- Test case uses the same tests as gemfire plus a couple of more scenarios
* Some polishing and Docs
2017-07-07 20:17:38 -04:00
Artem Bilan
6474ce9bb6 Upgrade to Gradle 4.0 and Checkstyle 8.0 2017-07-07 19:54:04 -04:00
Artem Bilan
cfc8184993 GH-173: Leaders: Warn event errors, not re-throw
Fixes GH-173 (https://github.com/spring-projects/spring-integration-extensions/issues/173)

Currently when an error is thrown from the event publishing the role granting is broken and we just go to the role revoking.

* Since it's just an event publishing it shouldn't effect the original leader election.
* `try...catch` event publishing in the `LeaderInitiator` and `logger.warn` an `Exception`
2017-01-30 17:12:52 -05:00
Spring Buildmaster
848ae2d6a0 [artifactory-release] Next development version 2017-01-23 21:37:12 +00:00
Spring Buildmaster
541bea384d [artifactory-release] Release version 1.0.0.M2 2017-01-23 21:37:08 +00:00
Artem Bilan
4472a87e9c Fix LeaderInitiatorTests race condition
https://build.spring.io/browse/INTEXT-SIH1-10

When `LeaderInitiator` yields its leadership there is a good chance that it will obtain it back, so there is no guaranty that it isn't leader after revoking
2017-01-23 16:17:00 -05:00
Artem Bilan
6e7b4cfcc7 GH-169: Upgrade and prepare for release
Fixes GH-169 (https://github.com/spring-projects/spring-integration-extensions/issues/169)

* Upgrade Gradle and dependencies
* Apply Checkstyle
2017-01-23 15:33:30 -05:00
Artem Bilan
7e0443d34b Some upgrades and polishing 2016-07-06 17:09:19 -04:00
Dave Syer
92a01dbe29 Migrate leader election support from Spring Cloud
Fix `LeaderInitiator`

* Implement `SmartLifecycle` instead of just `Lifecycle`
* Add `Assert`s
* Rework logic from `IMap` for locks just into single `ILock`, since we require it only for the `role` as a key
* Fix `Future.cancel(true)` logic via rescheduling
See https://jira.spring.io/browse/INT-4058 and its commit comments
* Add more complex test-case to meet distributed requirements and verify several `yield()` cycles
2016-07-06 16:43:06 -04:00
erenavsarogullari
0efd494337 INTEXT-158: JavaConfig tests and upgrades
JIRA: https://jira.spring.io/browse/INTEXT-158

* Provide the test cases to demonstrate the Spring Integration Hazelcast adapters usage from the JavaConfig
* Upgrade to Hazelcast-3.6, SI-4.2.4, Gradle-2.5
* Fix Hazelcast-3.6 compatibility
* Fix failing tests
2016-01-26 15:24:58 -05:00
erenavsarogullari
573e1f301f INTEXT-167: Add Cluster Monitor Channel Adapter
JIRA: https://jira.spring.io/browse/INTEXT-167

Some refactorings are done.

Hazelcast Cluster Monitor Unit Test Refactorings are done.

Some minor bug fixes are done.

Redundant assert is removed.

HazelcastInstance lifecycle check is added

Migration Event UT Case is updated.

Code style polishing and upgrade to the `spring.io.plugin-0.4.0`
2015-07-15 13:53:32 -04:00
Artem Bilan
8f45e1caec Hazelcast: Compatibility with IO-2.0
* Add IO plugin
* Upgrade to Gradle 2.4
* Upgrade dependencies
* Upgrade to Hazelcast-3.5 and therefore make compatible with IO-2.0
* All these changes and tests make this module compatible with SI-4.2
2015-06-23 22:10:17 -04:00
Eren Avsarogullari
c6975af37b INTEXT-149: Refactor HCCacheWritingMessageHandler
JIRA: https://jira.spring.io/browse/INTEXT-149

Some refactorings are done.

Polishing

* Add `IllegalStateException` for wrong `distributedObject`
* Add an invalid test to attempt to write to `ILock`
2015-05-12 15:22:01 +03:00
Spring Buildmaster
37d70e0e84 [artifactory-release] Next development version 2015-04-20 03:15:21 -07:00
Spring Buildmaster
af4583fe27 [artifactory-release] Release version Hzelcast 1.0.0-M1 2015-04-20 03:15:08 -07:00
Eren Avsarogullari
95f7b239f7 INTEXT-150 Extract Hazelcast Headers and Payloads
JIRA: https://jira.spring.io/browse/INTEXT-150

Refactorings are committed.

Polishing:
* Add generic type to the `AbstractHazelcastEventListener` for cleaner implementors
* Remove redundant `Assert`s
* Polishing some code style
2015-04-15 23:59:28 +03:00
Artem Bilan
4ed2153a45 INTEXT-161 Add <poller> to the <int-hz:o-c-a>
JIRA: https://jira.spring.io/browse/INTEXT-161
2015-04-04 17:32:38 +03:00
erenavsarogullari
bfec7640ca INTEXT-142: Add Spring Integration Hazelcast
JIRA: https://jira.spring.io/browse/INTEXT-142
2015-04-03 12:56:48 +03:00