Hi All. Does anybody has an experience with Spring Integration project as embedded ESB? I'm highly interesting in such use cases as: Reading files from directory on schedule basis Getting data from JDBC data source Modularity and possibility to start/stop/redeploy module on the fly (e.g. one module can scan directory on schedule basi...
I've been trying to find information on this, but due to the immaturity of the Spring Integration framework I haven't had much luck. Here is my desired work flow: New files are placed in an 'Incoming' directory Files are picked up using a file:inbound-channel-adapter The file content is streamed, N lines at a time, to a 'Stage 1' chan...
I'm still struggling with Spring Integration- here's my scenario: A web service gets a request from client A web service puts the request onto a queue A queue consumer processes the messages FIFO and sends a response that gets routed back to the web service Web services sends response back to client A There will be multiple web servi...
I'm looking for a lightweight framework that builds on top of the Process Manager pattern: http://www.eaipatterns.com/ProcessManager.html I'm specifically interested in using this for doing event processing whereby I'm interested in the success or failure outcome of a particular event and passing a message on to another "stage" based o...
I'm trying to configure my spring integration and want to use the element, which basically sits between a retryFilter and a queue. All works fine if I go straight from the retryFilter to the queue, however, as soon as I put the delayer element in between them, the config file fails to be loaded (as happens when there is an error in it)...
I have the spring-flex-testdrive example (JMS chat application which uses a Topic to pub/sub messages) to work on Tomcat with ActiveMQ now I want to run this example on Glassfish with OpenMQ. This is a related sample config I found online but it doesn't quite work for the Flex/Glassfish/OpenMQ/BlazeDs/Spring-Integration technology com...
I'd like to configure a process that looks something like: Method Call -> Dynamic Proxy Gateway -> Channel -> Service Activator -> Method Call ^---------- Transformer <- Channel <- [return value] Effectively, I'd like to somehow access the hidden channel Spring Integration creates and transform the return mess...
I've gone through the "Spring Integration in 10 minutes" tutorial for setting up a basic Spring Integration application. I'd like to deploy this application in Tomcat and have the input channel live on the server and send the output back to a client, but I'm having a difficult time finding any examples of this. Could anyone provide m...
I have a system which contains multiple applications connected together using JMS and Spring Integration. Messages get sent along a chain of applications. [App A] -> [App B] -> [App C] We set a global id in the message header so we can trace each message lifecycle through the system. I would like to be able to prepend any log message...
Hello everyone, I am using spring 2.5.6 and spring-integration 1.0.3 and MQ client 6.0.2.2 I have had to add a message selector to my message-driven-channel-adapter, but now I am getting the following error: MQJMS2008: failed to open MQ queue ; nested exception is com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2085 It wor...
What are the differences between Spring integration and JBoss jBPM? Thank you. ...
Technologies Involved Mule Apache CXF Given A simple POJO (controversial acronym, but let's say a smart POJO): public class SmartPojo implements SomeBusinessInterface { public String doSomethingSmart( With something ) { String result; result = Irrelevant.process( something ) return result; ...
I have a workflow that I want to looks something like this: / Worker 1 \ =Request Channel= -> [Holding Queue|||] -> Worker 2 -> =Response Channel= \ Worker 3 / That is: Requests come in and they enter a FIFO queue Identical workers then pick up tasks ...
I'm attempting to wire a queue to the front of a MessageChannel, and I need to do so programatically so it can be done at run time in response to an osgi:listener being triggered. So far I've got: public void addService(MessageChannel mc, Map<String,Object> properties) { //Create the queue and the QueueChannel BlockingQueue<Mes...
I have the following method and want to avoid having to explicitly show the JAXBElement<> syntax. Is there some sort of annotation that would allow the method to appear to accept raw MessageResponse objects but in actuality work the same as shown below? I'm not sure how clear that was so I'll say this: I'm looking for some syntactic suga...
This configuration works fine, but inbound-channel-adapter which is supposed to poll every 15 secs is running continously. Does anyone have an idea what I'm doning wrong? <si:channel id="msgChannel" /> <si:inbound-channel-adapter ref="jdbcInputAdapter" method="fetchData" channel="msgChannel"> <si:poller> ...
We have build a solution based on file based delivery using Spring-Integration. This works fine but we need to process many files. We are happy with Spring Integration but we want to scale up. For this we'd like to use a messaging system like Rabbit MQ(or other solutions). Does anybody have experience with this, what's needed to get this...
For the following scenario I am looking for your advices and tips on best practices: In a distributed (mainly Java-based) system with: many (different) client applications (web-app, command-line tools, REST API) a central JMS message broker (currently in favor of using ActiveMQ) multiple stand-alone processing nodes (running on multip...
I'm considering message serialization support for spring-integration. This would be useful for various wire level transports to implement guaranteed delivery, but also to allow interoperability with other messaging systems (e.g. through AMQP). The fundamental problem that arises is that a message containing Java object in it's payload a...
As a seasoned Spring user I was assuming that Spring Integration would make the most sense in a recent project requiring some (JMS) messaging capabilities (more details). After some days working with Spring Integration it still feels like a lot of configuration overhead given the amount of channels you have to configure to bring some req...