Search:

My new groovy transformer (GroovyTransformer.groovy):



class GroovyTransformer {

public Transaction transform(Trade trade) {
def t = new...

You can look at samples: https://github.com/SpringSource/spring-integration
...and reference: http://static.springsource.org/spring/docs/3.0.x/spring-framework-reference/html/testing.html

I think..that now I truely understand Your mechanism.

In my scenario I have some kind od message feeder (simple sending messages based on sequence).
Then I have resequencer to maintain the proper...

Thank YOU for Your help...I want to be clear..I have a configuration:



<bean id="reaper" class="org.springframework.integration.store.MessageGroupStoreReaper">
<property...

This is my resequencer configuration:


<int:resequencer id="seqNumberResequencer" input-channel="packetFilteredChannel" output-channel="sequenceStoreChannel"
discard-channel="discardChannel"...

External system is sending us messages using UDP...we can not change that.

Yes...something like that..but like Mark mentioned before...I can not assume that when messages have come in out-of-order I have to notify the re-send server imediatelly.
In my case I have to do...

Yes..now I understand..You are right..I can use the timeout attribute to determine if I should notify the server to re-send

In UDP environment...messages can be lost..You can not predict...in that case I have to send a request to synchronization server to send me (one more time) messages from 11-19 (see above). If I do...

Next thing to mention...I would like to be able to reset sequence number to 1 or custom value..is that posssible?

Imagine the use-case:

External system is sending us messages with sequnce...

No no....no 'times out'..I would like to be notified in real time that Resequencer has found out that there is a gap in a sequence. Let say we are receiving messages from 1 to 10..then we have...

Hi!

Currently I am using resequencer component by this:



<int:resequencer id="seqNumberResequencer" input-channel="inputChannel" output-channel="outputChannel"...

Hi!
I have made some tests of object transformations jn JDK6, JDK7 and Groovy 1.8.2 (using Spring Integration 2.1.0.M1). My use-case:

1. Receive message from publish-subscribe channel by...

I am not an expert in Groovy and I dont know how it is done in spring integration. Do I have to provide (to my groovy transform classes) some kind of method signature?
I can read Msg1 from context...

I would like to execute some method in groovy class. Something like this:



<transformer input-channel="input">
<groovy:script location="Msg1Transformer .groovy"/>
</transformer>

GroovyTransformerTests.groovy

This is pure business logic? Can it be some kind of:



class Msg1Transformer {

GroovyObject transform(Msg1 msg) {
}

I think...30 types max...but how can I integrate Payload Type Router with groovy scripts? (each script = 1 transformer).
I would like to have dynamic transformers (*.groovy files) and some kind of...

Hi!

I would like to implement custom Transformer component.
In my use case I have some kind of message with a type. Depending of the message's type I have to make proper transformations.
So my...

Ok, thanks...I'd rather stay with proxying to interface...

OK..I have switched to interface:
org.springframework.integration.MessageChannel

...and it works!

Hi!

I have o problem with JMX export. I have some standard Spring Integration components and I would like to export them via JMX using '<jmx:mbean-export/>'. In my 'app-context.xml' I have added:...

No, no...no removing from list :)
To sum up, now I have such components as:
- udp-inbound-channel-adapter
- transformer
- filter
- resequencer
- logging-channel-adapter

Ok. THANK YOU GUYS!!!

I know that...but Splitter component should be thread-safe...am I wrong?

Ok.thanks for Your free time.