Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

first commit

  • Loading branch information...
commit 994a521de49a364f288ac72ce352dbdff982d53d 0 parents
U-krishna-PC\krishna authored
190 pom.xml
@@ -0,0 +1,190 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+ <modelVersion>4.0.0</modelVersion>
+ <groupId>com.goSmarter.amqp</groupId>
+ <artifactId>spring-integration-amqp-gemfire-claimcheck</artifactId>
+ <version>1.0.0.BUILD-SNAPSHOT</version>
+ <packaging>war</packaging>
+
+ <properties>
+ <spring.framework.version>3.1.1.RELEASE</spring.framework.version>
+ <spring.amqp.version>1.0.0.RELEASE</spring.amqp.version>
+ </properties>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.springframework.amqp</groupId>
+ <artifactId>spring-amqp</artifactId>
+ <version>${spring.amqp.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.amqp</groupId>
+ <artifactId>spring-rabbit</artifactId>
+ <version>${spring.amqp.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework</groupId>
+ <artifactId>spring-test</artifactId>
+ <version>${spring.framework.version}</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework</groupId>
+ <artifactId>spring-context-support</artifactId>
+ <version>${spring.framework.version}</version>
+ <scope>runtime</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework</groupId>
+ <artifactId>spring-aop</artifactId>
+ <version>${spring.framework.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework</groupId>
+ <artifactId>spring-oxm</artifactId>
+ <version>${spring.framework.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework</groupId>
+ <artifactId>spring-webmvc</artifactId>
+ <version>${spring.framework.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework</groupId>
+ <artifactId>spring-core</artifactId>
+ <version>${spring.framework.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>javax.servlet</groupId>
+ <artifactId>servlet-api</artifactId>
+ <version>2.5</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>javax.servlet</groupId>
+ <artifactId>jstl</artifactId>
+ <version>1.1.2</version>
+ <scope>runtime</scope>
+ </dependency>
+ <dependency>
+ <artifactId>standard</artifactId>
+ <groupId>taglibs</groupId>
+ <version>1.1.2</version>
+ <type>jar</type>
+ <scope>runtime</scope>
+ </dependency>
+ <dependency>
+ <groupId>cglib</groupId>
+ <artifactId>cglib-nodep</artifactId>
+ <version>2.2</version>
+ </dependency>
+ <dependency>
+ <groupId>org.aspectj</groupId>
+ <artifactId>aspectjrt</artifactId>
+ <version>1.5.4</version>
+ </dependency>
+ <dependency>
+ <groupId>org.aspectj</groupId>
+ <artifactId>aspectjweaver</artifactId>
+ <version>1.5.4</version>
+ </dependency>
+ <dependency>
+ <groupId>org.codehaus.jackson</groupId>
+ <artifactId>jackson-mapper-asl</artifactId>
+ <version>1.4.3</version>
+ <scope>runtime</scope>
+ </dependency>
+ <dependency>
+ <groupId>junit</groupId>
+ <artifactId>junit</artifactId>
+ <version>4.10</version>
+ </dependency>
+ <dependency>
+ <groupId>log4j</groupId>
+ <artifactId>log4j</artifactId>
+ <version>1.2.16</version>
+ </dependency>
+ <dependency>
+ <groupId>com.jgoodies</groupId>
+ <artifactId>forms</artifactId>
+ <version>1.2.1</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.integration</groupId>
+ <artifactId>spring-integration-core</artifactId>
+ <version>2.1.3.RELEASE</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.integration</groupId>
+ <artifactId>spring-integration-amqp</artifactId>
+ <version>2.1.3.RELEASE</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.data</groupId>
+ <artifactId>spring-data-gemfire</artifactId>
+ <version>1.2.0.BUILD-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.springframework.integration</groupId>
+ <artifactId>spring-integration-gemfire</artifactId>
+ <version>2.1.3.RELEASE</version>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-log4j12</artifactId>
+ <version>1.6.4</version>
+ </dependency>
+ </dependencies>
+
+ <pluginRepositories>
+ <pluginRepository>
+ <id>Codehaus</id>
+ <url>http://repository.codehaus.org/</url>
+ <snapshots>
+ <enabled>false</enabled>
+ </snapshots>
+ </pluginRepository>
+ </pluginRepositories>
+ <distributionManagement>
+ <downloadUrl>http://www.springframework.org/download</downloadUrl>
+ <site>
+ <id>staging</id>
+ <url>file:///${user.dir}/target/staging/org.springframework.batch.archetype/${project.artifactId}</url>
+ </site>
+ <repository>
+ <id>spring-release</id>
+ <name>Spring Release Repository</name>
+ <url>file:///${user.dir}/target/staging/release</url>
+ </repository>
+ <snapshotRepository>
+ <id>spring-snapshot</id>
+ <name>Spring Snapshot Repository</name>
+ <url>file:///${user.dir}/target/staging/snapshot</url>
+ </snapshotRepository>
+ </distributionManagement>
+ <repositories>
+ <repository>
+ <id>libs-milestone</id>
+ <name>Springsource.org libs-milestone</name>
+ <url>http://repo.springsource.org/libs-milestone</url>
+ </repository>
+ <repository>
+ <id>libs-snapshot</id>
+ <name>Springsource.org libs-snapshot</name>
+ <url>http://repo.springsource.org/libs-snapshot</url>
+ </repository>
+ <repository>
+ <id>libs-release</id>
+ <name>Springsource.org libs-release</name>
+ <url>http://repo.springsource.org/libs-release</url>
+ </repository>
+ <repository>
+ <id>plugins-release</id>
+ <name>Springsource.org plugins-release</name>
+ <url>http://repo.springsource.org/plugins-release</url>
+ </repository>
+ </repositories>
+
+</project>
17 src/main/java/com/goSmarter/amqp/service/Subscriber1ServiceActivator.java
@@ -0,0 +1,17 @@
+package com.goSmarter.amqp.service;
+
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.integration.message.GenericMessage;
+
+public class Subscriber1ServiceActivator {
+
+ private static Log logger = LogFactory
+ .getLog(Subscriber1ServiceActivator.class);
+
+ public void logXml(GenericMessage<?> msg) throws Exception {
+ String text = msg.toString();
+ logger.debug("### PAYLOAD ###" + text);
+ }
+}
16 src/main/java/com/goSmarter/amqp/service/Subscriber2ServiceActivator.java
@@ -0,0 +1,16 @@
+package com.goSmarter.amqp.service;
+
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.integration.message.GenericMessage;
+
+public class Subscriber2ServiceActivator {
+
+ private static Log logger = LogFactory
+ .getLog(Subscriber2ServiceActivator.class);
+
+ public void logXml(GenericMessage<?> msg) throws Exception {
+ logger.debug("### PAYLOAD ###" + msg.getPayload());
+ }
+}
62 src/main/java/org/springframework/data/gemfire/examples/util/LoggingCacheListener.java
@@ -0,0 +1,62 @@
+/*
+ * Copyright 2012 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.springframework.data.gemfire.examples.util;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.stereotype.Component;
+
+import com.gemstone.gemfire.cache.EntryEvent;
+import com.gemstone.gemfire.cache.util.CacheListenerAdapter;
+
+@SuppressWarnings("rawtypes")
+/**
+ * A simple CacheListener to log cache events
+ * @author David Turanski
+ *
+ */
+@Component
+public class LoggingCacheListener extends CacheListenerAdapter {
+ private static Log log = LogFactory.getLog(LoggingCacheListener.class);
+
+
+ @Override
+ public void afterCreate(EntryEvent event) {
+ final String regionName = event.getRegion().getName();
+ final Object key = event.getKey();
+ final Object newValue = event.getNewValue();
+ log.info("In region [" + regionName + "] created key [" + key
+ + "] value [" + newValue + "]");
+ }
+
+ @Override
+ public void afterDestroy(EntryEvent event) {
+ final String regionName = event.getRegion().getName();
+ final Object key = event.getKey();
+ log.info("In region [" + regionName + "] destroyed key [" + key
+ + "]");
+ }
+
+ @Override
+ public void afterUpdate(EntryEvent event) {
+ final String regionName = event.getRegion().getName();
+ final Object key = event.getKey();
+ final Object newValue = event.getNewValue();
+ final Object oldValue = event.getOldValue();
+ log.info("In region [" + regionName + "] updated key [" + key
+ + "] [oldValue [" + oldValue + "] new value [" + newValue +"]");
+ }
+}
10 src/main/resources/application-config.xml
@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
+
+ <import resource="classpath:spring-integration-amqp-context.xml" />
+
+ <import resource="classpath:spring-integration-context.xml" />
+ <import resource="classpath:gemfire-config.xml" />
+</beans>
15 src/main/resources/gemfire-config.xml
@@ -0,0 +1,15 @@
+<?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:gfe="http://www.springframework.org/schema/gemfire"
+ xmlns:util="http://www.springframework.org/schema/util"
+ xsi:schemaLocation="http://www.springframework.org/schema/gemfire http://www.springframework.org/schema/gemfire/spring-gemfire-1.2.xsd
+ http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
+ http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-3.1.xsd">
+
+ <bean id="simpleMessageStore"
+ class="org.springframework.integration.gemfire.store.GemfireMessageStore">
+ <constructor-arg ref="myCache" />
+ </bean>
+
+ <bean id="myCache" class="org.springframework.data.gemfire.CacheFactoryBean"/>
+</beans>
26 src/main/resources/log4j.xml
@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
+<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">
+
+ <!-- Appenders -->
+ <appender name="console" class="org.apache.log4j.ConsoleAppender">
+ <param name="Target" value="System.out" />
+ <layout class="org.apache.log4j.PatternLayout">
+ <param name="ConversionPattern" value="%d{dd MMM yyyy HH:mm:ss,SSS}[%t] %-5p: %c - %m%n" />
+ </layout>
+ </appender>
+
+
+ <!-- Loggers -->
+ <logger name="com.goSmarter.amqp.service">
+ <level value="debug" />
+ </logger>
+
+
+ <!-- Root Logger -->
+ <root>
+ <priority value="error" />
+ <appender-ref ref="console" />
+ </root>
+
+</log4j:configuration>
24 src/main/resources/spring-integration-amqp-context.xml
@@ -0,0 +1,24 @@
+<?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:int="http://www.springframework.org/schema/integration"
+ xmlns:context="http://www.springframework.org/schema/context"
+ xmlns:rabbit="http://www.springframework.org/schema/rabbit"
+ xmlns:int-amqp="http://www.springframework.org/schema/integration/amqp"
+ xsi:schemaLocation="http://www.springframework.org/schema/integration/amqp http://www.springframework.org/schema/integration/amqp/spring-integration-amqp-2.1.xsd
+ http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
+ http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd
+ http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
+ http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
+
+ <!-- A reference to the org.springframework.amqp.rabbit.connection.ConnectionFactory -->
+ <rabbit:connection-factory id="connectionFactory" />
+
+ <!-- Creates a org.springframework.amqp.rabbit.core.RabbitAdmin to manage
+ exchanges, queues and bindings -->
+ <rabbit:admin connection-factory="connectionFactory" />
+
+ <int-amqp:channel id="p2p-pollable-channel" connection-factory="connectionFactory" />
+
+ <int-amqp:publish-subscribe-channel id="pub-sub-channel" connection-factory="connectionFactory" />
+</beans>
47 src/main/resources/spring-integration-context-all.xml
@@ -0,0 +1,47 @@
+<?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:int="http://www.springframework.org/schema/integration"
+ xmlns:context="http://www.springframework.org/schema/context"
+ xmlns:int-http="http://www.springframework.org/schema/integration/http"
+ xmlns:int-xml="http://www.springframework.org/schema/integration/xml"
+ xmlns:rabbit="http://www.springframework.org/schema/rabbit"
+ xmlns:int-amqp="http://www.springframework.org/schema/integration/amqp"
+ xsi:schemaLocation="http://www.springframework.org/schema/integration/http http://www.springframework.org/schema/integration/http/spring-integration-http.xsd
+ http://www.springframework.org/schema/integration/amqp http://www.springframework.org/schema/integration/amqp/spring-integration-amqp-2.1.xsd
+ http://www.springframework.org/schema/integration/xml http://www.springframework.org/schema/integration/xml/spring-integration-xml.xsd
+ http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
+ http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd
+ http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
+ http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
+
+ <int:channel id="p2p-pollable-channel" />
+
+ <int:publish-subscribe-channel id="pub-sub-channel" />
+ <int:channel id="checkout-channel1" />
+ <int:channel id="checkout-channel2" />
+
+ <bean id="simpleMessageStore"
+ class="org.springframework.integration.store.SimpleMessageStore" />
+
+ <int:claim-check-in message-store="simpleMessageStore"
+ input-channel="p2p-pollable-channel" output-channel="pub-sub-channel" />
+
+ <int:claim-check-out message-store="simpleMessageStore"
+ input-channel="pub-sub-channel" output-channel="checkout-channel1"
+ remove-message="false" />
+ <int:service-activator input-channel="checkout-channel1"
+ id="serviceActivator1" ref="serviceActivator1Bean" method="logXml" />
+
+
+ <int:claim-check-out message-store="simpleMessageStore"
+ input-channel="pub-sub-channel" output-channel="checkout-channel2"
+ remove-message="false" />
+ <int:service-activator input-channel="checkout-channel2"
+ id="serviceActivator2" ref="serviceActivator2Bean" method="logXml" />
+
+ <bean id="serviceActivator1Bean" class="com.goSmarter.amqp.service.Subscriber1ServiceActivator">
+ </bean>
+
+ <bean id="serviceActivator2Bean" class="com.goSmarter.amqp.service.Subscriber2ServiceActivator">
+ </bean>
+</beans>
42 src/main/resources/spring-integration-context.xml
@@ -0,0 +1,42 @@
+<?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:int="http://www.springframework.org/schema/integration"
+ xmlns:context="http://www.springframework.org/schema/context"
+ xmlns:int-http="http://www.springframework.org/schema/integration/http"
+ xmlns:int-xml="http://www.springframework.org/schema/integration/xml"
+ xmlns:rabbit="http://www.springframework.org/schema/rabbit"
+ xmlns:int-amqp="http://www.springframework.org/schema/integration/amqp"
+ xsi:schemaLocation="http://www.springframework.org/schema/integration/http http://www.springframework.org/schema/integration/http/spring-integration-http.xsd
+ http://www.springframework.org/schema/integration/amqp http://www.springframework.org/schema/integration/amqp/spring-integration-amqp-2.1.xsd
+ http://www.springframework.org/schema/integration/xml http://www.springframework.org/schema/integration/xml/spring-integration-xml.xsd
+ http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
+ http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd
+ http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
+ http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
+
+ <int:channel id="checkout-channel1" />
+ <int:channel id="checkout-channel2" />
+
+ <int:claim-check-in message-store="simpleMessageStore"
+ input-channel="p2p-pollable-channel" output-channel="pub-sub-channel" />
+
+ <int:claim-check-out message-store="simpleMessageStore"
+ input-channel="pub-sub-channel" output-channel="checkout-channel1"
+ remove-message="false" />
+
+ <int:claim-check-out message-store="simpleMessageStore"
+ input-channel="pub-sub-channel" output-channel="checkout-channel2"
+ remove-message="false" />
+
+ <int:service-activator input-channel="checkout-channel1"
+ id="serviceActivator1" ref="serviceActivator1Bean" method="logXml" />
+
+ <int:service-activator input-channel="checkout-channel2"
+ id="serviceActivator2" ref="serviceActivator2Bean" method="logXml" />
+
+ <bean id="serviceActivator1Bean" class="com.goSmarter.amqp.service.Subscriber1ServiceActivator">
+ </bean>
+
+ <bean id="serviceActivator2Bean" class="com.goSmarter.amqp.service.Subscriber2ServiceActivator">
+ </bean>
+</beans>
22 src/main/webapp/WEB-INF/web.xml
@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
+xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
+id="WebApp_ID" version="2.5">
+ <display-name>spring-integration-amqp-subscribe</display-name>
+ <context-param>
+ <param-name>contextConfigLocation</param-name>
+ <param-value>classpath:application-config.xml</param-value>
+ </context-param>
+ <context-param>
+ <param-name>application.configuration.name</param-name>
+ <param-value>spring-integration-amqp-subscribe</param-value>
+ </context-param>
+ <context-param>
+ <param-name>spring.profiles.active</param-name>
+ <param-value>default</param-value>
+ </context-param>
+ <listener>
+ <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
+ </listener>
+</web-app>
60 src/test/java/com/goSmarter/amqp/PublisherSubscriberTest.java
@@ -0,0 +1,60 @@
+package com.goSmarter.amqp;
+
+import static org.junit.Assert.*;
+import static org.junit.Assert.assertNull;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.StringWriter;
+import java.io.Writer;
+
+import org.apache.log4j.Logger;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.integration.Message;
+import org.springframework.integration.MessageChannel;
+import org.springframework.integration.core.PollableChannel;
+import org.springframework.integration.support.MessageBuilder;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration({ "classpath:spring-integration-context.xml",
+ "classpath:spring-integration-test-context.xml",
+ "classpath:gemfire-config.xml" })
+public class PublisherSubscriberTest {
+
+ private static Logger logger = Logger.getLogger(PublisherSubscriberTest.class);
+
+ @Autowired
+ @Qualifier("p2p-pollable-channel")
+ MessageChannel channel;
+
+ @Test
+ public void testIntegration() {
+ try {
+ String request = streamToString(getClass().getResourceAsStream(
+ "/data/payload.xml"));
+
+ Message<String> message = MessageBuilder.withPayload(request)
+ .build();
+
+ channel.send(message);
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
+
+ public static String streamToString(InputStream inputStream)
+ throws IOException {
+ Writer writer = new StringWriter();
+ byte[] b = new byte[4096];
+ for (int n; (n = inputStream.read(b)) != -1;) {
+ writer.append(new String(b, 0, n));
+ }
+ return writer.toString();
+ }
+}
8 src/test/resources/data/payload.xml
@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Root>
+<PayloadContext>
+<ApplicationProfile>
+<AppName>goSmarter</AppName>
+</ApplicationProfile>
+</PayloadContext>
+</Root>
16 src/test/resources/spring-integration-test-context.xml
@@ -0,0 +1,16 @@
+<?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:int="http://www.springframework.org/schema/integration"
+ xmlns:context="http://www.springframework.org/schema/context"
+ xsi:schemaLocation="http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd
+ http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
+ http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
+
+
+ <int:poller default="true" fixed-rate="1000" />
+
+ <int:channel id="p2p-pollable-channel" />
+
+ <int:publish-subscribe-channel id="pub-sub-channel" />
+</beans>
Please sign in to comment.
Something went wrong with that request. Please try again.