That was quite easy. We should add header to Spring Integration message:
<header-enricher input-channel="social-verify-channel-reschedule" output-channel="social-verify-channel">
<!--...
Type: Posts; User: igor.bljahhin; Keyword(s):
That was quite easy. We should add header to Spring Integration message:
<header-enricher input-channel="social-verify-channel-reschedule" output-channel="social-verify-channel">
<!--...
Thanks for the link.
Unfortunately, that guide didn't helped in my case. I cleaned cache, added Spring Project nature and rebuild the proejct.
I uploaded image to Google+. BTW, the original image quality was fine, its forum's uploader, who decreased the quality of the image...
No luck still... Latest version of STS (2.9.2) and Spring Integration ver. 2.2.0.M3.
Screenshot:...
Thank you!
I am trying to solve my problem in SSTS, but didn't succeed yet.
I'm on Eclipse, but I will try to switch to SSTS...
Hi!
When do you plan to publish schema files of the version 2.2 on http://www.springframework.org/schema/integration/? They are still missed on that site and Eclipse gives a bunch of errors when...
I have same issue in 2.2.0.M2.
My configuration is
<jms:channel id="userInvitationChannel" queue="userQueue" selector="ACTION = 'INVITE'" transaction-manager="transactionManager"...
Hello,
My Spring Integration application uses ActiveMQ as JMS server. There are plenty of "jms:message-driven-channel-adapter" and "jms:channel" in my application, which send the messages to...
I do it almost in same way, like the user "clerik": I have added the field "retryCount" to my message object and in case of exception, I increment the value of this field, and save the message back...
That was easy, thanks to the book "Spring Integration in Action":
@ContextConfiguration
@RunWith(SpringJUnit4ClassRunner.class)
public class CampaignStatisticsIntegrationTest {
@Autowired...
Hello,
I'd like to test my SI flow with JUnit. I've read the forum and found that I need to create my own TaskExecutor and set "waitForTasksToCompleteOnShutdown" to "true".
So, I defined the...
Thank you for reply, Gary! I'll try the solution suggested by Oleg.
Thank you, Oleg!
Seems like this is right solution for me.
I set "schedulerSupport" to "true" in broker's configuration's and now scheduling is working.
Hello,
I would like to use ActiveMQ's scheduled processing feature (http://activemq.apache.org/delay-and-schedule-message-delivery.html). I can set the value to AMQ_SCHEDULED_DELAY header of JMS...
Hi!
I would like to calculate "time-to-live" value dynamically based on payload. I tried to use expression like this:
<jms:outbound-channel-adapter id="statisticsCheckAdapter"...
Sure, I do it on SI M3 and latest Spring.
Feel free to use it ;)
Hi!
I thought that, if one group of messages somehow get mixed with another group, then nothing bad will happen. The adapters will be stopped a bit later - not a big deal. But then I realized, that,...
Oops, I was sure that "SEQUENCE_NUMBER" and "SEQUENCE_SIZE" are real values :)
Unfortunately, your first suggesting wasn't working for me, because SI started to complain about "Got...
Hello,
I have three adapters, which send the message each minute. I inject into the header of the message the correlation ID, the sequence size and the sequence number. Then all messages should...
Hi!
I have a similar case. Our application uses three external systems: a database and two web services. I would like to implement the option of checking the state of these external systems, and...
Placing start code into @Before method starts the execution of inbound adapters well, but produces a new problem too. Test method finishes before than SI flow.
I do not know, the solution with...
I found that adapters are not running when they are initialized in JUnit test.
This code is working fine:
public class Main {
private static final Logger LOG =...
Hi!
Thank you for reply! The control over JMX is working like a charm: I can see in the log, that adapter is started and stopped.
Another problem is that the adapter actually do not ask...