The JGroups extension for Spring Integration project includes Inbound- and Outbound Channel Adapters and JGroups channel configuration helper factory classes.

JGroups cluster

With this extension you can easily start JGroups cluster/group, providing cluster/group name and JGroups configuration.

Example

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:jgroups="http://www.springframework.org/schema/integration/jgroups"
    xmlns:int="http://www.springframework.org/schema/integration"
    xsi:schemaLocation="http://www.springframework.org/schema/integration/jgroups http://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd
        http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration-2.2.xsd
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <jgroups:cluster name="mygroup">
        <jgroups:xml-configurator resource="classpath:udp.xml" />
    </jgroups:cluster>

</beans>

This example starts new JGroups cluster, named mygroup and with configuration loaded from udp.xml.

Inbound channel adapter

Inbound channel adapter is used to receive messages sent to the group. It expects user to provide reference to the JGroups cluster object. You can also supply optional reference to custom JGroups header mapper.

Example

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:jgroups="http://www.springframework.org/schema/integration/jgroups"
    xmlns:int="http://www.springframework.org/schema/integration"
    xsi:schemaLocation="http://www.springframework.org/schema/integration/jgroups http://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd
        http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration-2.2.xsd
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">


    <jgroups:cluster name="mygroup">
        <jgroups:xml-configurator resource="classpath:udp.xml" />
    </jgroups:cluster>

    <jgroups:inbound-channel-adapter id="cluster-adapter" cluster="mygroup" channel="inbound"/>

    <int:channel id="inbound">
        <int:queue/>
    </int:channel>

</beans>

Outbound channel adapter

Outbound channel adapter is used to send messages to a group. It expects user to provide reference to the JGroups cluster object. You can also supply optional reference to custom JGroups header mapper.

Example:

<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:jgroups="http://www.springframework.org/schema/integration/jgroups"
    xmlns:int="http://www.springframework.org/schema/integration"
    xsi:schemaLocation="http://www.springframework.org/schema/integration/jgroups http://www.springframework.org/schema/integration/jgroups/spring-intergration-jgroups.xsd
        http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration-2.2.xsd
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <jgroups:cluster name="mygroup">
        <jgroups:xml-configurator resource="classpath:udp.xml" />
    </jgroups:cluster>

    <int:poller fixed-rate="100" default="true"/>

    <int:channel id="inbound">
        <int:queue/>
    </int:channel>

    <jgroups:outbound-channel-adapter id="cluster-adapter" cluster="mygroup" channel="inbound"/>

</beans>

Build

For build instructions visit Spring Integration on GitHub.