Hazelcast Event-Driven Inbound Channel Adapter listens related cache events and sends event messages to defined channel. Its basic definition is as follows :

   <int-hazelcast:inbound-channel-adapter channel="mapChannel" 
					  cache="map" 
					  cache-events="UPDATED, REMOVED"
					  cache-listening-policy="SINGLE" />

Basically, Hazelcast Event-Driven Inbound Channel Adapter requires following attributes :

channel : Specifies channel which message is sent. It is mandatory attribute.
cache : Specifies the distributed Object reference which is listened. It is mandatory attribute.
cache-events : Specifies cache events which are listened. It is optional attribute and its default value is ADDED. Its supported values are as follows :

Supported cache event types for IMap and MultiMap : ADDED, REMOVED, UPDATED, EVICTED, EVICT_ALL and CLEAR_ALL.
Supported cache event types for ReplicatedMap : ADDED, REMOVED, UPDATED, EVICTED.
Supported cache event types for IList, ISet and IQueue : ADDED, REMOVED.
There is no need to cache event type definition for ITopic.

cache-listening-policy : Specifies cache listening policy as SINGLE or ALL. It is optional attribute and its default value is SINGLE. Each Hazelcast CQ inbound channel adapter listening same cache object with same cache-events attribute, can receive a single event message or all event messages. If it is ALL, all Hazelcast CQ inbound channel adapters listening same cache object with same cache-events attribute, will receive same event messages. If it is SINGLE, they will receive unique event messages.

Sample namespace and schemaLocation definitions are as follows :

xmlns:int-hazelcast= “http://www.springframework.org/schema/integration/hazelcast”

xsi:schemaLocation="http://www.springframework.org/schema/integration/hazelcast
		  http://www.springframework.org/schema/integration/hazelcast/spring-integration-hazelcast.xsd”

Sample definitions are as follows :

Distributed Map :

<int:channel id="mapChannel"/> 

<int-hazelcast:inbound-channel-adapter channel="mapChannel" 
					          cache="map" 
					          cache-events="UPDATED, REMOVED" /> 

<bean id="map" factory-bean="instance" factory-method="getMap"> 
	<constructor-arg value="map"/> 
</bean> 

<bean id="instance" class="com.hazelcast.core.Hazelcast" 
			factory-method="newHazelcastInstance"> 
	<constructor-arg> 
		<bean class="com.hazelcast.config.Config" /> 
	</constructor-arg> 
</bean>

Distributed MultiMap :

<int:channel id="multiMapChannel"/> 

<int-hazelcast:inbound-channel-adapter channel="multiMapChannel" 
					          cache="multiMap" 
					          cache-events="ADDED, REMOVED, CLEAR_ALL" /> 

<bean id="multiMap" factory-bean="instance" factory-method="getMultiMap"> 
	<constructor-arg value="multiMap"/> 
</bean>

Distributed List :

<int:channel id="listChannel"/> 

<int-hazelcast:inbound-channel-adapter  channel="listChannel" 
					           cache="list" 
					           cache-events="ADDED, REMOVED"
					           cache-listening-policy="ALL" /> 

<bean id="list" factory-bean="instance" factory-method="getList"> 
	<constructor-arg value="list"/> 
</bean>

Distributed Set :

<int:channel id="setChannel"/> 

<int-hazelcast:inbound-channel-adapter channel="setChannel" cache="set" /> 

<bean id="set" factory-bean="instance" factory-method="getSet"> 
	<constructor-arg value="set"/> 
</bean>

Distributed Queue :

<int:channel id="queueChannel"/> 

<int-hazelcast:inbound-channel-adapter  channel="queueChannel" 
					           cache="queue" 
					           cache-events="REMOVED"
					           cache-listening-policy="ALL" /> 

<bean id="queue" factory-bean="instance" factory-method="getQueue"> 
	<constructor-arg value="queue"/> 
</bean>

Distributed Topic :

<int:channel id="topicChannel"/> 

<int-hazelcast:inbound-channel-adapter channel="topicChannel" cache="topic" /> 

<bean id="topic" factory-bean="instance" factory-method="getTopic"> 
	<constructor-arg value="topic"/> 
</bean>

Replicated Map :

<int:channel id="replicatedMapChannel"/> 

<int-hazelcast:inbound-channel-adapter channel="replicatedMapChannel" 
					          cache="replicatedMap" 
					          cache-events="ADDED, UPDATED, REMOVED"
 					          cache-listening-policy="SINGLE"  /> 

<bean id="replicatedMap" factory-bean="instance" factory-method="getReplicatedMap"> 
	<constructor-arg value="replicatedMap"/> 
</bean> 
<bean id="instance" class="com.hazelcast.core.Hazelcast" 
			factory-method="newHazelcastInstance"> 
	<constructor-arg> 
		<bean class="com.hazelcast.config.Config" /> 
	</constructor-arg> 
</bean>

Reference : http://docs.hazelcast.org/docs/3.4/manual/html-single/hazelcast-documentation.html#distributed-data-structures

HAZELCAST CONTINUOUS QUERY INBOUND CHANNEL ADAPTER

Hazelcast Continuous Query enables to listen to the modifications performed on specific map entries. Hazelcast Continuous Query Inbound Channel Adapter is an event-driven inbound channel adapter and listens related distributed map events in the light of defined predicate. Its basic definition is as follows :

<int-hazelcast:cq-inbound-channel-adapter 
				channel="cqMapChannel" 
				cache="cqMap" 
				cache-events="UPDATED, REMOVED" 
				predicate="name=TestName AND surname=TestSurname"
				include-value="true"
				cache-listening-policy="SINGLE" />

Basically, it requires four attributes as follows :

channel : Specifies channel which message is sent. It is mandatory attribute.
cache : Specifies distributed Map reference which is listened. It is mandatory attribute.
cache-events : Specifies cache events which are listened. It is optional attribute with ADDED default value. Supported values are ADDED, REMOVED, UPDATED, EVICTED, EVICT_ALL and CLEAR_ALL.
predicate : Specifies predicate to listen to the modifications performed on specific map entries. It is mandatory attribute.
include-value : Specifies including of value and oldValue in continuous query result. It is optional attribute with 'true' default value.
cache-listening-policy : Specifies cache listening policy as SINGLE or ALL. It is optional attribute and its default value is SINGLE. Each Hazelcast CQ inbound channel adapter listening same cache object with same cache-events attribute, can receive a single event message or all event messages. If it is ALL, all Hazelcast CQ inbound channel adapters listening same cache object with same cache-events attribute, will receive same event messages. If it is SINGLE, they will receive unique event messages.

Sample definition is as follows :

<int:channel id="cqMapChannel"/> 

<int-hazelcast:cq-inbound-channel-adapter  
				channel="cqMapChannel" 
				cache="cqMap" 
				cache-events="UPDATED, REMOVED" 
				predicate="name=TestName AND surname=TestSurname"
				include-value="true"
				cache-listening-policy="SINGLE"/> 

<bean id="cqMap" factory-bean="instance" factory-method="getMap"> 
	<constructor-arg value="cqMap"/> 
</bean> 

<bean id="instance" class="com.hazelcast.core.Hazelcast" 
			factory-method="newHazelcastInstance"> 
	<constructor-arg> 
		<bean class="com.hazelcast.config.Config" /> 
	</constructor-arg> 
</bean>

Reference : http://docs.hazelcast.org/docs/3.4/manual/html-single/hazelcast-documentation.html#continuous-query

HAZELCAST DISTRIBUTED-SQL INBOUND CHANNEL ADAPTER

Hazelcast allows to run distributed queries on the distributed map. Hazelcast Distributed SQL Inbound Channel Adapter is a poller-driven inbound channel adapter. It runs defined distributed-sql and returns results in the light of iteration type. Its basic definition is as follows :

<int-hazelcast:ds-inbound-channel-adapter  
			     channel="dsMapChannel" 
			     cache="dsMap"
 			     iteration-type="ENTRY" 
                 distributed-sql="active=false OR age >= 25 OR name = 'TestName'"> 
	<int:poller fixed-delay="100"/>
</int-hazelcast:ds-inbound-channel-adapter>

Basically, it requires a poller and four attributes such as

channel : Specifies channel which message is sent. It is mandatory attribute.
cache : Specifies distributed Map reference which is queried. It is mandatory attribute.
iteration-type : Specifies result type. Distributed SQL can be run on EntrySet, KeySet, LocalKeySet or Values. It is optional attribute with VALUE default value. Supported values are ENTRY, KEY, LOCAL_KEY and VALUE.
distributed-sql : Specifies where clause of sql statement. It is mandatory attribute.

Sample definition is as follows :

<int:channel id="dsMapChannel"/> 

<int-hazelcast:ds-inbound-channel-adapter  
			channel="dsMapChannel" 
			cache="dsMap" 
			iteration-type="ENTRY" 
			distributed-sql="active=false OR age >= 25 OR name = 'TestName'"> 
	<int:poller fixed-delay="100"/>
</int-hazelcast:ds-inbound-channel-adapter> 

<bean id="dsMap" factory-bean="instance" factory-method="getMap"> 
	<constructor-arg value="dsMap"/> 
</bean> 

<bean id="instance" class="com.hazelcast.core.Hazelcast" 
			factory-method="newHazelcastInstance"> 
	<constructor-arg> 
		<bean class="com.hazelcast.config.Config" /> 
	</constructor-arg> 
</bean>

Reference : http://docs.hazelcast.org/docs/3.4/manual/html-single/hazelcast-documentation.html#query-overview

HAZELCAST OUTBOUND CHANNEL ADAPTER

Hazelcast Outbound Channel Adapter listens its defined channel and writes incoming messages to related distributed cache. It expects one of java.util.Map, List, Set and Queue data structures in incoming message's payload. Its definition is as follows :

<int-hazelcast:outbound-channel-adapter  channel="mapChannel" cache="distributedMap" />

Basically, it requires two attributes as follows :

channel : Specifies channel which message is sent. It is mandatory attribute.
cache : Specifies distributed Map reference which is queried. It is mandatory attribute.

Case 1- If incoming messages need to be written to distributed map(com.hazelcast.core.IMap), Message should have java.util.Map payload. Sample definition should be as follows :

<int:channel id="mapChannel"/> 

<int-hazelcast:outbound-channel-adapter  channel="mapChannel" cache="distributedMap" /> 

<bean id="distributedMap" factory-bean="instance" factory-method="getMap"> 
	<constructor-arg value="distributedMap"/> 
</bean> 

<bean id="instance" class="com.hazelcast.core.Hazelcast" 
			factory-method="newHazelcastInstance"> 
	<constructor-arg> 
		<bean class="com.hazelcast.config.Config" /> 
	</constructor-arg> 
</bean>

Case 2- If incoming messages need to be written to distributed list(com.hazelcast.core.IList), Message should have java.util.List payload. Sample definition should be as follows :

<int:channel id="listChannel"/> 
	 
<int-hazelcast:outbound-channel-adapter channel="listChannel" cache="distributedList" /> 

<bean id="distributedList" factory-bean="instance" factory-method="getList"> 
	<constructor-arg value="distributedList"/> 
</bean>

Case 3- If incoming messages need to be written to distributed set(com.hazelcast.core.ISet), Message should have java.util.Set payload. Sample definition should be as follows :

<int:channel id="setChannel"/> 

<int-hazelcast:outbound-channel-adapter channel="setChannel" cache="distributedSet" /> 
	 
<bean id="distributedSet" factory-bean="instance" factory-method="getSet"> 
	<constructor-arg value="distributedSet"/> 
</bean>

Case 4- If incoming messages need to be written to distributed queue(com.hazelcast.core.IQueue), Message should have java.util.Queue payload. Sample definition should be as follows :

<int:channel id="queueChannel"/> 
		 
<int-hazelcast:outbound-channel-adapter  channel="queueChannel" cache="distributedQueue" /> 
		 
<bean id="distributedQueue" factory-bean="instance" factory-method="getQueue"> 
	<constructor-arg value="distributedQueue"/> 
</bean>