You are looking for examples, code snippets, sample applications for Spring Integration? This is the place.

Related tags

Learning Tutorial spring-integration-samples
Overview

Spring Integration Samples

Note

This (master) branch requires Spring Integration 5.0 or above. For samples running against earlier versions of Spring Integration, use the SI4.3.x and other branches.

Introduction

Welcome to the Spring Integration Samples repository which provides 50+ samples to help you learn Spring Integration. To simplify your experience, the Spring Integration samples are split into 4 distinct categories:

  • Basic
  • Intermediate
  • Advanced
  • Applications
  • DSL

Inside of each category you'll find a README.md file, which will contain a more detailed description of that category. Each sample also comes with its own README.md file explaining further details, e.g. how to run the respective sample.

| For additional samples, please also checkout the Spring Integration Extensions project as it also provides numerous samples.

Happy Integration!

Related GitHub projects

Community Sample Projects

Categories

Below is a short description of each category.

DSL

This directory holds demos/samples for Spring Integration 4.0 Java Configuration as well as the Java DSL Extension.

Basic

This is a good place to get started. The samples here are technically motivated and demonstrate the bare minimum with regard to configuration and code to help you to get introduced to the basic concepts, API and configuration of Spring Integration. For example, if you are looking for an answer on how to wire a Service Activator to a Channel or how to apply a Gateway to your message exchange or how to get started with using the MAIL or XML module, this would be the right place to find a relevant sample. The bottom line is that this is a good starting point.

  • amqp - Demonstrates the functionality of the various AMQP Adapters
  • barrier - Shows how to suspend a thread until some asynchronous event occurs
  • control-bus - Demonstrates the functionality of the Control Bus
  • enricher - This sample demonstrates how the Enricher components can be used
  • feed - Demonstrates the functionality of the Feed Adapter (RSS/ATOM)
  • file - Demonstrates aspects of the various File Adapters (e.g. File Inbound/Outbound Channel Adapters, file polling)
  • ftp - Demonstrates the FTP support available with Spring Integration
  • helloworld - Very simple starting example illustrating a basic message flow (using Channel, ServiceActivator, QueueChannel)
  • http - Demonstrates request/reply communication when using a pair of HTTP Inbound/Outbound gateways
  • jdbc - Illustrates the usage of the Jdbc Adapters, including object persistence and retrieval
  • jms - Demonstrates JMS support available with Spring Integration
  • jmx - Demonstrates JMX support using a JMX Attribute Polling Channel and JMX Operation Invoking Channel Adapter
  • jpa - Shows the usage of the JPA Components can be used
  • mail - Example showing IMAP and POP3 support
  • mqtt - Demonstrates the functionality of inbound and outbound MQTT Adapters
  • mongodb - Shows how to persist a Message payload to a MongoDb document store and how to read documents from MongoDb
  • oddeven - Example combining the functionality of Inbound Channel Adapter, Filter, Router and Poller
  • jpa - This sample illustrates how the JPA Components can be used
  • quote - Example demoing core EIP support using Channel Adapter (Inbound and Stdout), Poller with Interval Trigers, Service Activator
  • sftp - Demonstrating SFTP support using SFTP Inbound / Outbound Channel Adapters
  • tcp-amqp - Demonstrates basic functionality of bridging the Spring Integration TCP Adapters with Spring Integration AMQP Adapters
  • tcp-broadcast - Demonstrates broadcasting a message to multiple connected TCP clients.
  • tcp-client-server - Demonstrates socket communication using TcpOutboundGateway, TcpInboundGateway and also uses a Gateway and a Service Activator
  • tcp-with-headers - Demonstrates sending headers along with the payload over TCP using JSON.
  • testing-examples - A series of test cases that show techniques to test Spring Integration applications.
  • twitter - Illustrates Twitter support using the Twitter Inbound Channel Adapter, Twitter Inbound Search Channel Adapter, Twitter Outbound Channel Adapter
  • ws-inbound-gateway - Example showing basic functionality of the Web Service Gateway
  • ws-outbound-gateway - Shows outbound web services support using the Web Service Outbound Gateway, Content Enricher, Composed Message Processor (Chain)
  • xml - Example demonstrates various aspects of the Xml support using an XPath Splitter, XPath Router, XSLT Transformer as well as XPath Expression support
  • xmpp - Show the support for XMPP (formerly known as Jabber) using e.g. GoogleTalk

Intermediate

This category targets developers who are already more familiar with the Spring Integration framework (past getting started), but need some more guidance while resolving more advanced technical problems that you have to deal with when switching to a Messaging architecture. For example, if you are looking for an answer on how to handle errors in various scenarios, or how to properly configure an Aggregator for the situations where some messages might not ever arrive for aggregation, or any other issue that goes beyond a basic understanding and configuration of a particular component to address "what else you can do?" types of problems, this would be the right place to find relevant examples.

  • async-gateway - Usage example of an asynchronous Gateway
  • dynamic-poller - Example shows usage of a Poller with a custom Trigger to change polling periods at runtime
  • async-gateway - Example shows usage of an Asynchronous Gateway
  • errorhandling - Demonstrates basic Error Handling capabilities of Spring Integration
  • file-processing - Sample demonstrates how to wire a message flow to process files either sequentially (maintain the order) or concurrently (no order).
  • mail-attachments - Demonstrates the processing of email attachments
  • monitoring The project used in the Spring Integration Management and Monitoring Webinar Also available on the SpringSourceDev YouTube Channel
  • multipart-http - Demonstrates the sending of HTTP multipart requests using Spring's RestTemplate and a Spring Integration Http Outbound Gateway
  • rest-http - This sample demonstrates how to send an HTTP request to a Spring Integration's HTTP service while utilizing Spring Integration's new HTTP Path usage. This sample also uses Spring Security for HTTP Basic authentication. With HTTP Path facility, the client program can send requests with URL Variables.
  • retry-and-more Provides samples showing the application of MessageHandler Advice Chains to endpoints - retry, circuit breaker, expression evaluating
  • splitter-aggregator-reaper A demonstration of implementing the Splitter and Aggregator Enterprise Integration Patterns (EIP) together. This sample also provides a concrete example of a message store reaper in action.
  • stored-procedures-derby Provides an example of the stored procedure Outbound Gateway using Apache Derby
  • stored-procedures-ms Provides an example of the stored procedure Outbound Gateway using Microsoft SQL Server
  • stored-procedures-oracle Provides an example of the stored procedure Outbound Gateway using ORACLE XE
  • stored-procedures-postgresql Provides an example of the stored procedure Outbound Gateway using PostgreSQL
  • tcp-async-bi-directional - Demonstrates the use of Collaborating Channel Adapters for arbitrary async messaging (not request/reply) between peers.
  • tcp-client-server-multiplex - Demonstrates the use of Collaborating Channel Adapters with multiple in-flight requests/responses over a single connection.
  • travel - More sophisticated example showing the retrieval of weather (SOAP Web Service) and traffic (HTTP Service) reports using real services
  • tx-synch Provides a sample demonstrating the use of transaction synchronization, renaming an input file to a different filename, depending on whether the transaction commits, or rolls back.

Advanced

This category targets advanced developers who are quite familiar with Spring Integration but are looking to address a specific custom need by extending the Spring Integration public API. For example, if you are looking for samples showing how to implement a custom Channel or Consumer (event-based or polling-based), or you are trying to figure out what is the most appropriate way to implement a custom BeanParser on top of the Spring Integration BeanParser hierarchy when implementing a custom namespace, this would be the right place to look. Here you can also find samples that will help you with adapter development. Spring Integration comes with an extensive library of adapters that allow you to connect remote systems with the Spring Integration messaging framework. However you might have a need to integrate with a system for which the core framework does not provide an adapter, so you have to implement your own. This category would include samples showing you how to implement various adapters.

  • advanced-testing-examples - Example test cases that show advanced techniques to test Spring Integration applications
  • dynamic-ftp - Demonstrates one technique for sending files to dynamic destinations.
  • dynamic-tcp-client - Demonstrates a technique for dynamically creating TCP clients.

Applications

This category targets developers and architects who have a good understanding of Message-Driven architecture and Enterprise Integration Patterns, and have an above average understanding of Spring and Spring integration and who are looking for samples that address a particular business problem. In other words, the emphasis of samples in this category is 'business use cases' and how they can be solved via a Messaging architecture and Spring Integration in particular. For example, if you are interested to see how a Loan Broker process or Travel Agent process could be implemented and automated via Spring Integration, this would be the right place to find these types of samples.

  • cafe - Emulates a simple operation of a coffee shop combining various Spring Integration adapters (Including Router and Splitter) see Appendix A of the reference documentation for more details. Implementations are provided for:
    • AMQP
    • JMS
    • In memory channels
  • cafe-scripted - Scripted implementation of the classic cafe sample application. Supports JavaScript, Groovy, Ruby, and Python.
  • loan-broker - Simulates a simple banking application (Uses Gateway, Chain, Header Enricher, Recipient List Router, Aggregator) see Appendix A of the reference documentation for more details
  • loanshark This extension to the loan broker sample shows how to exchange messages between Spring Integration applications (and other technologies) using UDP. file-split-ftp - Reads a file; splits into 3 based on contents; sends files over ftp; sends email with results.

Contributing

See the Spring Integration Contributor Guidelines for information about how to contribute to this repository.

Resources

For more information, please visit the Spring Integration website at: https://projects.spring.io/spring-integration/

Comments
  • java.lang.NoSuchMethodError: com.sun.mail.imap.IMAPFolder.idle()

    java.lang.NoSuchMethodError: com.sun.mail.imap.IMAPFolder.idle()

    Hi,

    We are getting NoSuchMethodError. Here are the stack trace.

    18/Feb/2017:07:48:13.155 [pool-4-thread-1] ERROR o.s.s.s.TaskUtils$LoggingErrorHandler.handleError(95) - Unexpected error occurred in scheduled task. java.lang.NoSuchMethodError: com.sun.mail.imap.IMAPFolder.idle()V at org.springframework.integration.mail.ImapMailReceiver.waitForNewMessages(ImapMailReceiver.java:175) ~[spring-integration-mail-4.3.1.RELEASE.jar:4.3.1.RELEASE] at org.springframework.integration.mail.ImapIdleChannelAdapter$IdleTask.run(ImapIdleChannelAdapter.java:271) ~[spring-integration-mail-4.3.1.RELEASE.jar:4.3.1.RELEASE] at org.springframework.integration.mail.ImapIdleChannelAdapter$ReceivingTask.run(ImapIdleChannelAdapter.java:241) ~[spring-integration-mail-4.3.1.RELEASE.jar:4.3.1.RELEASE] at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54) ~[spring-context-4.2.0.RELEASE.jar:4.2.0.RELEASE] at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81) [spring-context-4.2.0.RELEASE.jar:4.2.0.RELEASE] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_101] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_101] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_101] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [na:1.8.0_101] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_101] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_101] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_101] 18/Feb/2017:07:48:14.172 [pool-7-thread-1] ERROR o.s.s.s.TaskUtils$LoggingErrorHandler.handleError(95) - Unexpected error occurred in scheduled task. java.lang.NoSuchMethodError: com.sun.mail.imap.IMAPFolder.idle()V at org.springframework.integration.mail.ImapMailReceiver.waitForNewMessages(ImapMailReceiver.java:175) ~[spring-integration-mail-4.3.1.RELEASE.jar:4.3.1.RELEASE] at org.springframework.integration.mail.ImapIdleChannelAdapter$IdleTask.run(ImapIdleChannelAdapter.java:271) ~[spring-integration-mail-4.3.1.RELEASE.jar:4.3.1.RELEASE] at org.springframework.integration.mail.ImapIdleChannelAdapter$ReceivingTask.run(ImapIdleChannelAdapter.java:241) ~[spring-integration-mail-4.3.1.RELEASE.jar:4.3.1.RELEASE] at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54) ~[spring-context-4.2.0.RELEASE.jar:4.2.0.RELEASE] at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81) [spring-context-4.2.0.RELEASE.jar:4.2.0.RELEASE] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_101] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_101] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_101] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293) [na:1.8.0_101] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_101] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_101] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_101]

    Here the spring configuration :

    <int:service-activator input-channel="emailReceiveChannel" ref="emailReceiver" method="emailReceived" /> <int:channel id="emailReceiveChannel" />

    <int-mail:imap-idle-channel-adapter id="customAdapter"
    store-uri="${lab.mail.store-uri}"
    channel="emailReceiveChannel"
    auto-startup="${lab.mail.autostart}"
    should-delete-messages="false"
    should-mark-messages-as-read="true"
    java-mail-properties="javaMailProperties"/>

<util:properties id="javaMailProperties">
    <prop key="mail.imap.socketFactory.class">javax.net.ssl.SSLSocketFactory</prop>
    <prop key="mail.imap.socketFactory.fallback">false</prop>
    <prop key="mail.store.protocol">imaps</prop>
    <prop key="mail.debug">false</prop>
</util:properties>

    It is flooding our log files. Please help how to fix it.

    Thanks, Pankaj

    waiting-for-reporter 
    opened by pankajkh 22
  • exceptions for the mail basic sample

    exceptions for the mail basic sample

    Hi, Any help would be appreciated. I'm receiving exceptions with both the IMAP and POP implementations. The POP3/IMAP access is enabled in my google account. Here is the status as stated in gmail settings for IMAP: Status: IMAP is enabled. Here is the status as stated in gmail settings for POP3: 1. Status: POP is enabled for all mail that has arrived since....

    The IMAP fails with this exception:

    14:20:59.656 WARN  [task-scheduler-1][org.springframework.integration.mail.ImapIdleChannelAdapter] error occurred in idle task
javax.mail.NoSuchProviderException: imaps
        at javax.mail.Session.getService(Session.java:806)
        at javax.mail.Session.getStore(Session.java:592)
        at javax.mail.Session.getStore(Session.java:554)
        at org.springframework.integration.mail.AbstractMailReceiver.connectStoreIfNecessary(AbstractMailReceiver.java:214)
        at org.springframework.integration.mail.AbstractMailReceiver.openFolder(AbstractMailReceiver.java:234)
        at org.springframework.integration.mail.ImapMailReceiver.waitForNewMessages(ImapMailReceiver.java:156)
        at org.springframework.integration.mail.ImapIdleChannelAdapter$IdleTask.run(ImapIdleChannelAdapter.java:220)
        at org.springframework.integration.mail.ImapIdleChannelAdapter$ReceivingTask.run(ImapIdleChannelAdapter.java:190)
        at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
        at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
14:20:59.658 WARN  [task-scheduler-1][org.springframework.integration.mail.ImapIdleChannelAdapter] Failed to execute IDLE task. Will attempt to resubmit in 10000 milliseconds.
java.lang.IllegalStateException: Failure in 'idle' task. Will resubmit.
        at org.springframework.integration.mail.ImapIdleChannelAdapter$IdleTask.run(ImapIdleChannelAdapa:239)v
        at org.springframework.integration.mail.ImapIdleChannelAdapter$ReceivingTask.run(ImapIdleChannelAdapter.java:190)
        at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
        at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
Caused by: javax.mail.NoSuchProviderException: imaps
        at javax.mail.Session.getService(Session.java:806)
        at javax.mail.Session.getStore(Session.java:592)
        at javax.mail.Session.getStore(Session.java:554)
        at org.springframework.integration.mail.AbstractMailReceiver.connectStoreIfNecessary(AbstractMailReceiver.java:214)
        at org.springframework.integration.mail.AbstractMailReceiver.openFolder(AbstractMailReceiver.java:234)
        at org.springframework.integration.mail.ImapMailReceiver.waitForNewMessages(ImapMailReceiver.java:156)
        at org.springframework.integration.mail.ImapIdleChannelAdapter$IdleTask.run(ImapIdleChannelAdapter.java:220)
        ... 10 more

    And the POP fails with javax.mail.NoSuchProviderException: pop3, here is the stack trace:

    java.lang.ClassNotFoundException: com.sun.mail.pop3.POP3Store
        at java.net.URLClassLoader$1.run(URLClassLoader.java:372)
        at java.net.URLClassLoader$1.run(URLClassLoader.java:361)
        at java.security.AccessController.doPrivileged(Native Method)
        at java.net.URLClassLoader.findClass(URLClassLoader.java:360)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
        at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
        at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
        at java.lang.Class.forName0(Native Method)
        at java.lang.Class.forName(Class.java:260)
        at javax.mail.Session.getService(Session.java:802)
        at javax.mail.Session.getStore(Session.java:592)
        at javax.mail.Session.getStore(Session.java:554)
        at org.springframework.integration.mail.AbstractMailReceiver.connectStoreIfNecessary(AbstractMailReceiver.java:214)
        at org.springframework.integration.mail.AbstractMailReceiver.openFolder(AbstractMailReceiver.java:234)
        at org.springframework.integration.mail.AbstractMailReceiver.receive(AbstractMailReceiver.java:260)
        at org.springframework.integration.mail.MailReceivingMessageSource.receive(MailReceivingMessageSource.java:103)
        at org.springframework.integration.endpoint.SourcePollingChannelAdapter.receiveMessage(SourcePollingChannelAdapter.java:144)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint.doPoll(AbstractPollingEndpoint.java:192)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint.access$000(AbstractPollingEndpoint.java:55)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:149)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:146)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller$1.run(AbstractPollingEndpoint.java:298)
        at org.springframework.integration.util.ErrorHandlingTaskExecutor$1.run(ErrorHandlingTaskExecutor.java:52)
        at org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:50)
        at org.springframework.integration.util.ErrorHandlingTaskExecutor.execute(ErrorHandlingTaskExecutor.java:49)
        at org.springframework.integration.endpoint.tPollingEndpoint$Poller.run(AbstractPollingEndpoint.java:292)
        at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
        at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
14:22:55.037 ERROR [task-scheduler-1][org.springframework.integration.handler.LoggingHandler] org.springframework.messaging.MessagingException: failure occurred while polling for mail; nested exception is javax.mail.NoSuchProviderException: pop3
        at org.springframework.integration.mail.MailReceivingMessageSource.receive(MailReceivingMessageSource.java:117)
        at org.springframework.integration.endpoint.SourcePollingChannelAdapter.receiveMessage(SourcePollingChannelAdapter.java:144)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint.doPoll(AbstractPollingEndpoint.java:192)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint.access$000(AbstractPollingEndpoint.java:55)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:149)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:146)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller$1.run(AbstractPollingEndpoint.java:298)
        at org.springframework.integration.util.ErrorHandlingTaskExecutor$1.run(ErrorHandlingTaskExecutor.java:52)
        atringframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:50)
        at org.springframework.integration.util.ErrorHandlingTaskExecutor.execute(ErrorHandlingTaskExecutor.java:49)
        at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller.run(AbstractPollingEndpoint.java:292)
        at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
        at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
Caused by: javax.mail.NoSuchProviderException: pop3
        at javax.mail.Session.getService(Session.java:806)
        at javax.mail.Session.getStore(Session.java:592)
        at javax.mail.Session.getStore(Session.java:554)
        at org.springframework.integration.mail.AbstractMailReceiver.connectStoreIfNecessary(AbstractMailReceiver.java:214)
        at org.springframework.integration.mail.AbstractMailReceiver.openFolder(AbstractMailReceiver.java:234)
        at org.springframework.integration.mail.AbstractMailReceiver.receive(AbstractMailReceiver.java:260)
        at org.springframework.integration.mail.MailReceivingMessageSource.receive(MailReceivingMessageSource.java:103)
        ... 19 more
    opened by tzvikav 17
  • javax.mail.AuthenticationFailedException

    javax.mail.AuthenticationFailedException

    I have replaced [userid]:[pasword] in basic mail sample but i get this error :

    org.springframework.integration.handler.LoggingHandler handleMessageInternal
GRAVE: org.springframework.messaging.MessagingException: failure occurred while polling for mail; nested exception is javax.mail.AuthenticationFailedException: failed to connect, no password specified?
	at org.springframework.integration.mail.MailReceivingMessageSource.receive(MailReceivingMessageSource.java:131)
	at org.springframework.integration.endpoint.SourcePollingChannelAdapter.receiveMessage(SourcePollingChannelAdapter.java:230)
	at org.springframework.integration.endpoint.AbstractPollingEndpoint.doPoll(AbstractPollingEndpoint.java:243)
	at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller.lambda$run$0(AbstractPollingEndpoint.java:372)
	at org.springframework.integration.util.ErrorHandlingTaskExecutor.lambda$execute$0(ErrorHandlingTaskExecutor.java:53)
	at org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:50)
	at org.springframework.integration.util.ErrorHandlingTaskExecutor.execute(ErrorHandlingTaskExecutor.java:51)
	at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller.run(AbstractPollingEndpoint.java:366)
	at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:54)
	at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:93)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
Caused by: javax.mail.AuthenticationFailedException: failed to connect, no password specified?
	at javax.mail.Service.connect(Service.java:400)
	at javax.mail.Service.connect(Service.java:246)
	at javax.mail.Service.connect(Service.java:195)
	at org.springframework.integration.mail.AbstractMailReceiver.connectStoreIfNecessary(AbstractMailReceiver.java:321)
	at org.springframework.integration.mail.AbstractMailReceiver.openFolder(AbstractMailReceiver.java:328)
	at org.springframework.integration.mail.AbstractMailReceiver.receive(AbstractMailReceiver.java:354)
	at org.springframework.integration.mail.MailReceivingMessageSource.receive(MailReceivingMessageSource.java:112)
	... 16 more
    opened by razzeguimohamedzied 16
  • Is the FTP example, actually working?

    Is the FTP example, actually working?

    when I run it I'm getting this:

    org.springframework.messaging.MessagingException:` Failed to invoke handler; nested exception is org.springframework.messaging.MessagingException: Failed to execute on session; nested exception is java.lang.IllegalStateException: failed to create FTPClient, failedMessage=GenericMessage [payload=target\toSend\a.txt, headers={timestamp=1489108163505, id=84218d92-8f62-13aa-587f-3cf1e9768a5b}]
	at org.springframework.integration.handler.advice.RequestHandlerRetryAdvice.doInvoke(RequestHandlerRetryAdvice.java:100)
	at org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice.invoke(AbstractRequestHandlerAdvice.java:70)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
	at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213)
	at com.sun.proxy.$Proxy11.handleMessage(Unknown Source)
	at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:116)
	at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:148)
	at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:121)
	at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:89)
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:423)
	at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:373)
	at com.ftp.samples.FtpOutboundChannelAdapterSample.runDemo(FtpOutboundChannelAdapterSample.java:56)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
	at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
	at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
	at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
	at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
	at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
	at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
	at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
	at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
	at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
	at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50)
	at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38)
	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:459)
	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:675)
	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:382)
	at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:192)
Caused by: org.springframework.messaging.MessagingException: Failed to execute on session; nested exception is java.lang.IllegalStateException: failed to create FTPClient
	at org.springframework.integration.file.remote.RemoteFileTemplate.execute(RemoteFileTemplate.java:444)
	at org.springframework.integration.file.remote.RemoteFileTemplate.send(RemoteFileTemplate.java:283)
	at org.springframework.integration.file.remote.RemoteFileTemplate.send(RemoteFileTemplate.java:273)
	at org.springframework.integration.file.remote.RemoteFileTemplate.send(RemoteFileTemplate.java:265)
	at org.springframework.integration.file.remote.handler.FileTransferringMessageHandler.handleMessageInternal(FileTransferringMessageHandler.java:170)
	at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:606)
	at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:333)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
	at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
	at org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice$1.cloneAndExecute(AbstractRequestHandlerAdvice.java:93)
	at org.springframework.integration.handler.advice.RequestHandlerRetryAdvice$2.doWithRetry(RequestHandlerRetryAdvice.java:93)
	at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:276)
	at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:201)
	at org.springframework.integration.handler.advice.RequestHandlerRetryAdvice.doInvoke(RequestHandlerRetryAdvice.java:89)
	... 35 more
Caused by: java.lang.IllegalStateException: failed to create FTPClient
	at org.springframework.integration.ftp.session.AbstractFtpSessionFactory.getSession(AbstractFtpSessionFactory.java:169)
	at org.springframework.integration.ftp.session.AbstractFtpSessionFactory.getSession(AbstractFtpSessionFactory.java:41)
	at org.springframework.integration.file.remote.RemoteFileTemplate.execute(RemoteFileTemplate.java:433)
	... 52 more
Caused by: java.net.ConnectException: Connection refused: connect
	at java.net.DualStackPlainSocketImpl.connect0(Native Method)
	at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79)
	at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
	at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
	at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
	at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172)
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
	at java.net.Socket.connect(Socket.java:579)
	at org.apache.commons.net.SocketClient.connect(SocketClient.java:188)
	at org.apache.commons.net.SocketClient.connect(SocketClient.java:209)
	at org.springframework.integration.ftp.session.AbstractFtpSessionFactory.createClient(AbstractFtpSessionFactory.java:192)
	at org.springframework.integration.ftp.session.AbstractFtpSessionFactory.getSession(AbstractFtpSessionFactory.java:166)
	... 54 more

    Also, what does it means? spring-integration-samples/basic/ftp/src/test/java/org/springframework/integration/samples/ftp/support/TestUserManager.java

    It says don't use hardcoded Port. But, how to do that?

    opened by columb1a 12
  • INTSAMPLES-134: SFTP: Use Apache MINA SshServer

    INTSAMPLES-134: SFTP: Use Apache MINA SshServer

    JIRA: https://jira.spring.io/browse/INTSAMPLES-134

    The SftpOutboundGatewaySample doesn't work for me, because of Windows file system. It isn't eligible to be LS by SFTP

    opened by artembilan 12
  • Spring @Scheduler Annotation Issues with jdk 1.8 & jdk 1.7

    Spring @Scheduler Annotation Issues with jdk 1.8 & jdk 1.7

    Hi Team,

    here is my piece of code,

    @Configuration
@EnableScheduling
public class CSVFileProcessor {

@Scheduled(fixedRate = 10000)
    private static synchronized void pollDirectory() {
        System.out.println("***started Polling***");
        faxFolder = Paths.get(folderPath);

}

    The above Code is running perfectly with Tomcat 7 & jdk 1.8

    but when I use jdk 1.7 , The Server is getting hanged while trying to initialize Spring FrameworkServlet 'appDispatcher' .

    Dec 28, 2015 4:20:14 PM org.apache.catalina.core.ApplicationContext log INFO: Initializing Spring FrameworkServlet 'appDispatcher'

    Is there anything to do with jdk Versions ?

    can you help me please ?

    opened by Sudheer786 10
  • Add specific slf4j version dependency

    Add specific slf4j version dependency

    When just importing the ftp example as a maven project, I ran into the issue of a slf4j version discrepancy described here: http://www.slf4j.org/faq.html#IllegalAccessError

    This is solved by adding the specific version dependency of slf4j-api.

    opened by kasoban 10
  • Intsamples 60

    Intsamples 60

    Two samples for the Cafe application. One for JMS-backed channels using an embedded ActiveMQ broker. The second one relies on an external ActiveMQ broker and shows the distributed processing of drink orders similar to the AMQP sample. Please let me know if you'd like me to change anything including comments, the README.md, or the details of the implementation. I have added a blog post on the details of my implementation here: http://www.christianposta.com/blog/?p=168

    opened by christian-posta 9
  • SFTP delegation example

    SFTP delegation example

    I understand there is a sample of dynamic FTP. But would be helpful to have a SFTP delegation sample for outbound adapter as well , using SFTP session caching and factory methods.

    Thanks

    new sample request 
    opened by BHARATHCK 8
  • basic/kafka-example: PartitionNotFoundException

    basic/kafka-example: PartitionNotFoundException

    I tried out the basic/kafka example and got a PartitionNotFoundException:

    16:49:05.695 [main] ERROR o.s.boot.SpringApplication - Application startup failed
org.springframework.context.ApplicationContextException: Failed to start bean 'adapter'; nested exception is org.springframework.integration.kafka.core.PartitionNotFoundException: Partition [si.topicabc2355631326,0] has no leader or has not been found
    at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:176) ~[spring-context-4.2.3.RELEASE.jar:4.2.3.RELEASE]
    at org.springframework.context.support.DefaultLifecycleProcessor.access$200(DefaultLifecycleProcessor.java:51) ~[spring-context-4.2.3.RELEASE.jar:4.2.3.RELEASE]
    at org.springframework.context.support.DefaultLifecycleProcessor$LifecycleGroup.start(DefaultLifecycleProcessor.java:346) ~[spring-context-4.2.3.RELEASE.jar:4.2.3.RELEASE]
    at org.springframework.context.support.DefaultLifecycleProcessor.startBeans(DefaultLifecycleProcessor.java:149) ~[spring-context-4.2.3.RELEASE.jar:4.2.3.RELEASE]
    at org.springframework.context.support.DefaultLifecycleProcessor.onRefresh(DefaultLifecycleProcessor.java:112) ~[spring-context-4.2.3.RELEASE.jar:4.2.3.RELEASE]
    at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:851) ~[spring-context-4.2.3.RELEASE.jar:4.2.3.RELEASE]
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:540) ~[spring-context-4.2.3.RELEASE.jar:4.2.3.RELEASE]
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:752) ~[spring-boot-1.3.0.RELEASE.jar:1.3.0.RELEASE]
    at org.springframework.boot.SpringApplication.doRun(SpringApplication.java:347) ~[spring-boot-1.3.0.RELEASE.jar:1.3.0.RELEASE]
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:295) ~[spring-boot-1.3.0.RELEASE.jar:1.3.0.RELEASE]
    at org.springframework.boot.builder.SpringApplicationBuilder.run(SpringApplicationBuilder.java:134) [spring-boot-1.3.0.RELEASE.jar:1.3.0.RELEASE]
    at org.springframework.inon.samples.kafka.Application.main(Application.java:85) [main/:na]
Caused by: org.springframework.integration.kafka.core.PartitionNotFoundException: Partition [si.topicabc2355631326,0] has no leader or has not been found
    at org.springframework.integration.kafka.core.DefaultConnectionFactory.getLeader(DefaultConnectionFactory.java:124) ~[spring-integration-kafka-1.3.0.RELEASE.jar:na]
    at org.springframework.integration.kafka.listener.AbstractOffsetManager.getOffset(AbstractOffsetManager.java:131) ~[spring-integration-kafka-1.3.0.RELEASE.jar:na]
    at org.springframework.integration.kafka.listener.KafkaMessageListenerContainer$GetOffsetForPartitionFunction.safeValueOf(KafkaMessageListenerContainer.java:599) ~[spring-integration-kafka-1.3.0.RELEASE.jar:na]
    at org.springframework.integration.kafka.listener.KafkaMessageListenerContainer$GetOffsetForPartitionFunction.safeValueOf(KafkaMessageListenerContainer.java:593) ~[spring-integration-kafka-1.3.0.RELEASE.jar:na]
    at com.gs.collections.impl.block.function.checked.CheckedFunction.valueOf(CheckedFunction.java:30) ~[gs-collections-5.0.0.jar:na]
    at com.gs.collections.impl.block.procedure.MapCollectProcedure.value(MapCollectProcedure.java:51) ~[gs-collections-5.0.0.jar:na]
    at com.gs.collections.impl.list.immutable.ImmutableSingletonList.forEach(ImmutableSingletonList.java:59) ~[gs-collections-5.0.0.jar:na]
    at com.gs.collections.impl.utility.Iterate.forEach(Iterate.java:114) ~[gs-collections-5.0.0.jar:na]
    at com.gs.collections.impl.map.mutable.UnifiedMap.collectKeysAndValues(UnifiedMap.java:987) ~[gs-collections-5.0.0.jar:na]
    at com.gs.collections.impl.AbstractRichIterable.toMap(AbstractRichIterable.java:196) ~[gs-collections-5.0.0.jar:na]
    at org.springframework.integration.kafka.listener.KafkaMessageListenerContainer.start(KafkaMessageListenerContainer.java:312) ~[spring-integration-kafka-1.3.0.RELEASE.jar:na]
    at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.doStart(KafkaMessageDrivenChannelAdapter.java:137) ~[spring-integratka-1.3.0.RELEASE.jar:na]
    at org.springframework.integration.endpoint.AbstractEndpoint.start(AbstractEndpoint.java:94) ~[spring-integration-core-4.2.2.RELEASE.jar:na]
    at org.springframework.context.support.DefaultLifecycleProcessor.doStart(DefaultLifecycleProcessor.java:173) ~[spring-context-4.2.3.RELEASE.jar:4.2.3.RELEASE]
    ... 11 common frames omitted

    I think that the problem is that TopicCreator.start() is getting called too late. I'm a beginner when it comes to Spring, but I think that TopicCreator should implement InitializingBean instead of SmartLifecycle. I made the respective change on a branch (see Application.java). It seems to work (I changed the value of kafka.topic several times and I didn't get any exceptions), but this might be pure luck.

    opened by andregmoeller 6
  • Why getClientInstance is used for inbound and getAsyncClientInstance is used for outbound to get synchronous and asynchronous clients.

    Why getClientInstance is used for inbound and getAsyncClientInstance is used for outbound to get synchronous and asynchronous clients.

    What if I use an asynchronous client for both outbound and inbound, I see that the code is private and there is no way to rewrite it

    this.client = this.clientFactory.getAsyncClientInstance(this.getUrl(), this.getClientId());

    opened by qq2429979710 5
  • Enable Gradle test-support for :sftp samples.

    Enable Gradle test-support for :sftp samples.

    I was unfortunately unable to execute the :sftpsamples, but amending the appropriate block in build.gradle with test { useJUnitPlatform() } (3edd255656d218e88681e639a660295711d37a64) allowed execution via both Gradle & IDE.

    A more general approach could be a single block on root level, along the lines of

    tasks.withType(Test) {
    useJUnitPlatform()
}

    But perhaps there's a reason for the current approach :)

    I've also taken a stab at a "how to run sample" inspired by basic/tcp-amqp/README.md

    opened by dlehammer 0
  • Project Structure - Reorganize in favor of JavaDSL and Reactive support

    Project Structure - Reorganize in favor of JavaDSL and Reactive support

    Currently, this project looks like a project that has lots of examples. Underlying these examples are mostly XML-based, which is super unreadable for new users. I think this project should be reorganized and instead of dirs like intermediate, applications, advanced, basic, dsl, there's should be:

    • xml
      • basic
      • intermediate
      • advanced
    • java
      • reactive
        • basic
        • intermediate
        • advanced
      • non-reactive
        • basic
        • intermediate
        • advanced
    • specific-applications
      • xml
      • java
        • reactive
        • non-reactive

    Notice that if a sample is JavaDSL based, it is super unreadable to use inside of its parts of another XML-based POJOs.

    Another horrible thing is that there are samples whose names are not based on the libraries, but some random names like "Loanshark". The purpose of samples is to make it clear how the usage looks. The application purpose is irrelevant and confusing.

    I don't know what is applications place in the world. I'm also not sure if basic, intermediate, and advanced separation is needed. People would be fine if there would all sit together.

    This really doesn't require a lot of work and can be super helpful to people. Even if you open an empty folder for reactive, or very thin folders for java in general, it would let people comfortably contribute.

    opened by markusherbert 9
  • Add examples for using SI with Project Reactor

    Add examples for using SI with Project Reactor

    I'd like there to be examples for using the JavaDSL with Project Reactor. It's very hard to find reference to such usage. In general, this repo is super confusing and hard for JavaDSL users.

    waiting-for-reporter 
    opened by apffa 4
  • Only accepts one instance of multipart file not an array of multipart file

    Only accepts one instance of multipart file not an array of multipart file

    How do I make it accept an array of multipart files? I also tried to test this to the multipart form of the postman. Unfortunately, I'm getting the same issue.

    //xml integration config <int-http:inbound-gateway request-channel="requestChannel" reply-channel="responseChannel" path="/upload" request-payload-type="org.springframework.util.LinkedMultiValueMap" supported-methods="POST" mapped-request-headers="*"> </int-http:inbound-gateway>

    //<\bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">

    //ServiceActivator @ServiceActivator(inputChannel="requestChannel", outputChannel="responseChannel") public Message<?> uploadEcdd(@Payload LinkedMultiValueMap<String, Object> multipartRequest, @Headers MessageHeaders messageHeaders) {

    //ex. i uploaded two images, i'm only receiving the first image. what is the cause of this? System.out.println(multipartRequest.get("files");

    }

    opened by grilezado 7
  • What is required to make DynamicTcpClientApplication also return data with the send interface?

    What is required to make DynamicTcpClientApplication also return data with the send interface?

    I'm trying to wrap my head around how to make the DynamicTcpClientApplication also give back the response data sent with:

    	@MessagingGateway(defaultRequestChannel = "toTcp.input")
	public interface ToTCP {

		public void send(String data, @Header("host") String host, @Header("port") int port);

	}

    Just changing from void to byte[] is not enough. What is needed to make sure a client can get the response from a tcp request back through the interface?

    waiting-for-reporter 
    opened by Syrou 2
Owner
Spring
Spring
GitHub http://www.springsource.org/spring-integration
The quickstarts demonstrate JBoss EAP, Jakarta EE 8 and a few additional technologies. They provide small, specific, working examples that can be used as a reference for your own project.

shared-doc/attributes.adoc WildFly Quickstarts The quickstarts demonstrate Jakarta EE 8 and a few additional technologies from the WildFly stack. They

JBoss Developer 792 Dec 16, 2022
Castled is an open source reverse ETL solution that helps you to periodically sync the data in your warehouses and databases to sales, marketing, support or custom apps without any help from engineering teams

Open source reverse-ETL platform to operationalize your data warehouse Introduction Castled is a Reverse ETL solution which enables you to make the va

Castled 314 May 2, 2022
👨‍💻This repository gives you the solution of everyday problems given in 30DaysOfCode contest which is held on Hackerrank

??‍??30DaysOfCode-PhoenixClub This repository gives you the solution of everyday problems given in 30DaysOfCode contest which is held on Hackerrank. N

Urveshkumar 8 Jan 30, 2022
Example code from Learning Spark book

Examples for Learning Spark Examples for the Learning Spark book. These examples require a number of libraries and as such have long build files. We h

Databricks 3.8k Jan 2, 2023
100 Days of Code Learning program to keep a habit of coding daily and learn things at your own pace with help from our remote community.

100 Days of Code Learning program to keep a habit of coding daily and learn things at your own pace with help from our remote community.

Git Commit Show by Invide 41 Dec 30, 2022
Demonstrates the features of the Spring MVC web framework

Spring MVC Showcase Demonstrates the capabilities of the Spring MVC web framework through small, simple examples. After reviewing this showcase, you s

Spring 5k Jan 5, 2023
Spring Data Example Projects

Spring Data Examples This repository contains example projects for the different Spring Data modules to showcase the API and how to use the features p

Spring 4.7k Jan 4, 2023
Spring Integration provides an extension of the Spring programming model to support the well-known Enterprise Integration Patterns (EIP)

Spring Integration Code of Conduct Please see our Code of conduct. Reporting Security Vulnerabilities Please see our Security policy. Checking out and

Spring 1.4k Dec 30, 2022
Short code snippets written by our open source community!

Code Examples This repository contains different code examples in different programming languages. Website https://codes.snowflakedev.org How do I con

SnowflakeDev Community ❄️ 64 Nov 13, 2022
Small example repo for looking into log4j CVE-2021-44228

log4j CVE-2021-44228 Lame useless repo to look into log4j CVE-2021-44228. Setup The repository contains a .idea/ folder which is a IntelliJ IDEA proje

null 65 Dec 13, 2022
A complete and performing library to highlight text snippets (EditText, SpannableString and TextView) using Spannable with Regular Expressions (Regex) for Android.

Highlight A complete and performing library to highlight text snippets (EditText/Editable and TextView) using Spannable with Regular Expressions (Rege

Irineu A. Silva 16 Dec 22, 2022
Scaffolding is a library for Minestom that allows you to load and place schematics.

This library is very early in development and has too many bugs to count. For your own safety, you should not use it in a production environment.

Crystal Games 18 Nov 29, 2022
Ever wondered how a baloon feels in a dangerous place? Now you know.

Dont-Pop Description Ever wondered how a balloon feels in a dangerous place? Now you know. This game belongs to the category of Survival Games: the pl

Michele Ravaioli 9 Oct 24, 2022
A distributed data integration framework that simplifies common aspects of big data integration such as data ingestion, replication, organization and lifecycle management for both streaming and batch data ecosystems.

Apache Gobblin Apache Gobblin is a highly scalable data management solution for structured and byte-oriented data in heterogeneous data ecosystems. Ca

The Apache Software Foundation 2.1k Jan 4, 2023
Docker-compose-integration-tstst - An exploration of how to run integration tests against an application that has inconvenient external dependencies (e.g. a SQL database).

Tstst? it was supposed to be docker-compose-integration-tests but i was too lazy to fix it at the outset, and now im trying to convince myself its fun

null 1 Jan 4, 2022
Framework for automated integration tests with focus on messaging integration

Citrus Integration Testing Welcome to Citrus Citrus is a test framework written in Java that is able to create fully automated end-to-end use case tes

Citrus Framework 373 Dec 27, 2022
Attempt is a lightweight component provides declarative retry support for applications, not only but a polling strategy. With Attempt, you can easily poll for something with retry functionality. Non-spring and lightweight applications are friendly for a fewer dependencies.

中文文档 Introduction Attempt is a lightweight component provides declarative retry support for applications, not only but a polling strategy. With Attemp

Jason Lee 3 Oct 11, 2022
A library that allows you to integrate questions utilizing checkboxes that allow for a great user experience. There is full customization of the question views, allowing for seamless integration of a question into your apps UI. There are multiple types of questions that help you make simple questionaries to quizzes with multiple choice and multiple answer questions.

CheckboxQuestions CheckboxQuestions is a library that provides with different forms of asking questions. So far there are YesOrNoQuestions, MultipleCh

Aadi Yadav 15 Jan 19, 2022
循序渐进，学习Spring Boot、Spring Boot & Shiro、Spring Batch、Spring Cloud、Spring Cloud Alibaba、Spring Security & Spring Security OAuth2，博客Spring系列源码：https://mrbird.cc

Spring 系列教程 该仓库为个人博客https://mrbird.cc中Spring系列源码，包含Spring Boot、Spring Boot & Shiro、Spring Cloud，Spring Boot & Spring Security & Spring Security OAuth2

mrbird 24.8k Jan 6, 2023
100+ Spring Boot Articles, Tutorials, Video tutorials, Projects, Guides, Source code examples etc

YouTube Channel - Spring Boot Tutorial Subscribe for future video and updates Spring Boot Tutorial on YouTube Newly published spring boot tutorials (2

Ramesh Fadatare 1.2k Jan 2, 2023