Index
A
- aggregator
- about / The aggregator
- correlation bean / The correlation bean
- completion bean / The completion bean
- bean / The aggregator bean
- aggregators
- about / Aggregators
- int*aggregator / Aggregators
- input-channel / Aggregators
- output-channel / Aggregators
- ref / Aggregators
- method / Aggregators
- release-strategy / Aggregators
- release-strategy-method / Aggregators
- correlation-strategy / Aggregators
- correlation-strategy-method / Aggregators
- message-store / Aggregators
- correlation strategy / Correlation strategy
- release strategy / Release strategy
- message store / Message store
- annotations
- using / Using annotations
- asynchronous gateways
- about / Asynchronous gateways
- attribute polling channel adapter / The attribute polling channel adapter
B
- bidirectional endpoints / Message endpoints
C
- channel. types
- about / Channel types
- point-to-point channel / Channel types
- publish-subscribe channel / Channel types
- ChannelInterceptor interface
- preSend / Channel interceptors
- postSend / Channel interceptors
- preReceive / Channel interceptors
- postReceive / Channel interceptors
- channels
- message channels / Working with message channels
- spring implementing / Spring implementation of channels
- poll-able channel / Spring implementation of channels
- subscribe-able channel / Spring implementation of channels
- selecting / Selecting a channel
- publish-subscribe channel / Publish-subscribe channel
- queue channel / Queue channel
- priority channel / Priority channel
- rendezvous channel / Rendezvous channel
- direct channel / Direct channel
- executor channel / Executor channel
- scoped channel / Scoped channel
- Datatype channel / Datatype channel
- error handling / Error handling on channels
- persisting / Persisting and recovering channels
- recovering / Persisting and recovering channels
- interceptor pattern / Channel interceptors
- claim check
- about / Claim check
- incoming claim check transformer / Incoming claim check transformer
- outgoing claim check transformer / Outgoing claim check transformer
- completion bean / The completion bean
- content enrichers
- about / Content enrichers
- header enrichers / Header enrichers
- payload enrichers / Payload enrichers
- control bus
- about / Control bus
- correlation bean / The correlation bean
- correlation strategy, aggregators / Correlation strategy
D
- data
- filtering / Filtering the data
- data, ingesting
- about / Ingesting data
- from RSS feed / Ingesting data from the RSS feed
- from FTP server / Ingesting data from an FTP server
- data, filtering / Filtering the data
- database integration
- prerequisites / Prerequisites
- gateway / The gateway
- service activator / The service activator
- feeds reading, gateways / Gateways for updating and reading the feeds
- feeds updating, gateways / Gateways for updating and reading the feeds
- mail, sending / Sending a mail
- Database SQL
- about / Database SQL
- prerequisites / Prerequisites
- Datasource / Datasource
- inbound adapter / Reading from the database – the inbound adapter
- inbound adapter, transaction support / Transaction support
- outbound adapter / Writing to the database – the outbound adapter
- outbound gateway / Inbound and outbound gateways
- inbound gateway / Inbound and outbound gateways
- Datasource / Datasource
- Datatype channel / Datatype channel
- DB transformer / The DB transformer
- delayers
- direct channel / Direct channel
E
- End-to-End example
- prerequisites / Prerequisites
- setting up / Setting up
- Enterprise Integration Pattern (EIP) / Introducing message transformers
- enterprise messaging
- about / Enterprise messaging
- prerequisites / Prerequisites
- messages, receiving / Receiving messages – the inbound adapter
- inbound adapter / Receiving messages – the inbound adapter
- polling adapter / The polling adapter
- event-driven adapter / The event-driven adapter
- outbound adapter / Sending messages – the outbound adapter
- gateway / Gateway
- inbound gateway / The inbound gateway
- outbound gateway / The outbound gateway
- error
- handling / Handling errors
- error handling
- on channels / Error handling on channels
- error message exception type router
- about / Error message exception-type router
- int*exception-type-router / Error message exception-type router
- int*mapping exception-type / Error message exception-type router
- error message exception type router*default-output-channel / Error message exception-type router
- event-driven adapter, enterprise messaging / The event-driven adapter
- event driven endpoints / Message endpoints
- executor channel / Executor channel
F
- filenames, existing
- REPLACE / Dealing with existing filenames
- APPEND / Dealing with existing filenames
- FAIL / Dealing with existing filenames
- IGNORE / Dealing with existing filenames
- files
- working with / Working with files
- prerequisites / Prerequisites
- reading / Reading files
- downloading, from FTP server / Downloading files from the FTP server
- uploading, to FTP server / Uploading files to the FTP server
- int-ftp*outbound-channel-adapter / Uploading files to the FTP server
- channel / Uploading files to the FTP server
- remote-directory / Uploading files to the FTP server
- session-factory / Uploading files to the FTP server
- auto-create-directory / Uploading files to the FTP server
- files, reading
- about / Reading files
- int-file*inbound-channel-adapter / Reading files
- directory / Reading files
- channel / Reading files
- prevent-duplicates / Reading files
- filename-pattern / Reading files
- int*poller / Reading files
- int-file*nio-locker / Reading files
- scenes / Behind the scenes
- filters / Filters
- duplicates, preventing / Preventing duplicates
- concurrent access / Concurrent access
- files, writing
- about / Writing files
- int-file*outbound-channel-adapter / Writing files
- channel / Writing files
- directory / Writing files
- delete-source-files / Writing files
- naming / Naming the file
- target directory / Target directory
- existing filenames, dealing with / Dealing with existing filenames
- file transformers / File transformers
- file transformers / File transformers
- filters
- about / Filters, Filters
- Java class, using / Using a Java class to act as a filter
- configuring, as message endpoint / Configuring a filter as a message endpoint
- testing / Testing filters
- First in First out (FIFO) ordering / Queue channel
- FTP
- about / FTP/FTPS
- prerequisites / Prerequisites
- int-ftp*inbound-channel-adapter / Downloading files from the FTP server
- channel / Downloading files from the FTP server
- session-factory / Downloading files from the FTP server
- remote-directory / Downloading files from the FTP server
- local-directory / Downloading files from the FTP server
- auto-create-local-directory / Downloading files from the FTP server
- delete-remote-files / Downloading files from the FTP server
- filename-pattern / Downloading files from the FTP server
- local-filename-generator-expression / Downloading files from the FTP server
- incomplete files / Incomplete files
- files, uploading to / Uploading files to the FTP server
- partially written files, avoiding / Avoiding partially written files
- outbound gateway / FTP outbound gateway
- support / FTPS support
- FTP server
- files, downloading from / Downloading files from the FTP server
- files, uploading to / Uploading files to the FTP server
- data, ingesting from / Ingesting data from an FTP server
G
- gateway, database integration / The gateway
- gateways
- about / Gateways
- synchronous gateways / Synchronous gateways
- asynchronous gateways / Asynchronous gateways
H
- handlers
- chaining / Chaining handlers
- header enrichers
- about / Header enrichers
- int*header-enricher / Header enrichers
- input-channel / Header enrichers
- output-channel / Header enrichers
- int*header / Header enrichers
- headers
- testing / Testing headers
- header value router
- about / Header value router
- int*header-value-router / Header value router
- int*mapping / Header value router
- horizontal scaling
- about / Scaling up
- HTTP
- about / HTTP
- prerequisites / Prerequisites
- inbound gateway / The HTTP inbound gateway
- inbound HTTP gateway / The HTTP inbound gateway
- outbound gateway / The HTTP outbound gateway
I
- inbound adapter, Database SQL
- about / Reading from the database – the inbound adapter
- data-source / Reading from the database – the inbound adapter
- query / Reading from the database – the inbound adapter
- update / Reading from the database – the inbound adapter
- transaction support / Transaction support
- inbound adapter, enterprise messaging
- inbound endpoints / Message endpoints
- inbound gateway, Database SQL / Inbound and outbound gateways
- inbound gateway, enterprise messaging / The inbound gateway
- inbound gateway, HTTP
- about / The HTTP inbound gateway
- int-http*inbound-gateway / The HTTP inbound gateway
- request-channel / The HTTP inbound gateway
- path / The HTTP inbound gateway
- supported-methods / The HTTP inbound gateway
- inbound gateway, web services / The inbound gateway
- integration
- about / Integration
- database integration / Database integration
- mail, sending / Sending a mail
- ItemReader
- about / ItemReader
- lineMapper / ItemReader
- lineTokenizer / ItemReader
- fieldSetMapper / ItemReader
- ItemWriter
- about / ItemWriter
J
- Java class
- int*filter / Using a Java class to act as a filter
- input-channel / Using a Java class to act as a filter
- output-channel / Using a Java class to act as a filter
- ref / Using a Java class to act as a filter
- method / Using a Java class to act as a filter
- Jconsole / Prerequisites
- JDK 1.6 / Setting up STS
- JMS queue
- messages, putting on / Putting messages on to the JMS queue
- JMS transformer / The JMS transformer
- JMX
- about / JMX support
- prerequisites / Prerequisites
- NameSpace support / Prerequisites
- maven dependency / Prerequisites
- server, initializing / Prerequisites
- management annotations / Prerequisites
- Jconsole / Prerequisites
- notification listening channel adapter / The notification listening channel adapter
- notification publishing channel adapter / The notification publishing channel adapter
- attribute polling channel adapter / The attribute polling channel adapter
- tree polling channel adapter / The tree polling channel adapter
- operation invoking channel adapter / The operation invoking channel adapter
- operation invoking outbound gateway / The operation invoking outbound gateway
- MBean exporter / The MBean exporter
M
- mail transformer / The mail transformer
- management / Monitoring and management
- marshaller / Working with XML payload
- marshalling transformer
- about / The marshalling transformer
- int-xml*marshalling-transformer / The marshalling transformer
- input-channel / The marshalling transformer
- output-channel / The marshalling transformer
- marshaller / The marshalling transformer
- result-type / The marshalling transformer
- MBean
- exporting as / Exporting as an MBean
- MBean exporter / The MBean exporter
- message
- tracking / Tracking the message
- MessageChannel interface / Spring implementation of channels
- poll-able channel / Spring implementation of channels
- subscribe-able channel / Spring implementation of channels
- message channels
- working with / Working with message channels
- message endpoint
- filter, configuring as / Configuring a filter as a message endpoint
- message endpoints
- about / Message endpoints
- receivers or senders / Message endpoints
- polling endpoints or event driven endpoints / Message endpoints
- unidirectional or bidirectional endpoints / Message endpoints
- inbound or outbound endpoints / Message endpoints
- messages
- testing / Testing messages
- message store
- about / Message store
- message store, aggregators / Message store
- message transformers
- about / Introducing message transformers
- message translator / Introducing message transformers
- monitoring / Monitoring and management
N
- notification listening channel adapter
- about / The notification listening channel adapter
- int-jmx*notification-listening-channel-adapter / The notification listening channel adapter
- channel / The notification listening channel adapter
- object-name / The notification listening channel adapter
- notification publishing channel adapter / The notification publishing channel adapter
O
- operation invoking channel adapter / The operation invoking channel adapter
- operation invoking outbound gateway / The operation invoking outbound gateway
- outbound adapter, Database SQL / Writing to the database – the outbound adapter
- outbound adapter, enterprise messaging / Sending messages – the outbound adapter
- outbound endpoints / Message endpoints
- outbound gateway, Database SQL / Inbound and outbound gateways
- outbound gateway, enterprise messaging / The outbound gateway
- outbound gateway, FTP / FTP outbound gateway
- int-ftp*outbound-gateway / FTP outbound gateway
- session-factory / FTP outbound gateway
- command / FTP outbound gateway
- command-options / FTP outbound gateway
- reply-channel / FTP outbound gateway
- outbound gateway, HTTP
- about / The HTTP outbound gateway
- int-http*outbound-gateway / The HTTP outbound gateway
- channel / The HTTP outbound gateway
- url / The HTTP outbound gateway
- http-method / The HTTP outbound gateway
- expected-response-type / The HTTP outbound gateway
- outbound gateway, web services / The outbound gateway
- output channel
- defining / Default output channel
- exception, throwing / Default output channel
- default output channel, defining / Default output channel
- OXM (Object-to-XML) / Working with XML payload
P
- payload enrichers
- about / Payload enrichers
- int*enricher / Payload enrichers
- input-channel / Payload enrichers
- request-channel / Payload enrichers
- int*property / Payload enrichers
- payload type router
- about / Payload-type router
- int*payload-type-router / Payload-type router
- int*mapping / Payload-type router
- point-to-point channel
- about / Channel types
- poll-able channel / Spring implementation of channels
- polling adapter, enterprise messaging
- int-jms*inbound-channel-adapter / The polling adapter
- connection-factory / The polling adapter
- destination / The polling adapter
- channel / The polling adapter
- polling endpoints / Message endpoints
- priority channel / Priority channel
- project
- first project, setting up / Creating your first project
- publish-subscribe channel
- about / Channel types
Q
- queue channel / Queue channel
R
- receivers / Message endpoints
- recipient list router
- about / Recipient list router
- int*recipient-list-router / Recipient list router
- int*recipient / Recipient list router
- release strategy, aggregators / Release strategy
- rendezvous channel / Rendezvous channel
- resequencers
- about / Resequencers
- router
- about / Router
- routers
- about / Routers
- payload type router / Payload-type router
- header value router / Header value router
- recipient list router / Recipient list router
- Xpath router / XPath router
- Error message exception type router / Error message exception-type router
- output channel / Default output channel
- annotations, using / Using annotations
- RSS feed
- data, ingesting from / Ingesting data from the RSS feed
S
- scoped channel / Scoped channel
- senders / Message endpoints
- service activator, database integration / The service activator
- service activators
- about / Service activators
- @MessageEndpoint / Service activators
- @ServiceActivator / Service activators
- int*service-activator / Service activators
- input-channel / Service activators
- output-channel / Service activators
- ref / Service activators
- social integration
- about / Social integration
- prerequisites / Prerequisites
- tweets, receiving / Receiving tweets
- tweets, sending / Sending tweets
- twitter search outbound gateway / Twitter search outbound gateway
- splitter
- about / The splitter
- splitters
- splitter test
- about / Splitter test
- Spring Batch
- about / Spring Batch
- prerequisites / Prerequisites
- Namespace support / Prerequisites
- Maven entry / Prerequisites
- batch*job / The Spring Batch job language
- batch*step / The Spring Batch job language
- batch*tasklet / The Spring Batch job language
- batch*chunk / The Spring Batch job language
- batch*listeners / The Spring Batch job language
- and Spring Integration / Spring Batch and Spring Integration
- Spring Batch job
- defining / Defining a Spring Batch job
- language / The Spring Batch job language
- ItemReader / ItemReader
- ItemWriter / ItemWriter
- Spring Batch job, language
- Job / The Spring Batch job language
- Step / The Spring Batch job language
- JobInstance / The Spring Batch job language
- JobParameter / The Spring Batch job language
- JobExcecution / The Spring Batch job language
- StepExecution / The Spring Batch job language
- ExecutionContext / The Spring Batch job language
- JobRepository / The Spring Batch job language
- JobLauncher / The Spring Batch job language
- ItemReader / The Spring Batch job language
- ItemWriter / The Spring Batch job language
- ItemProcessor / The Spring Batch job language
- Spring Expression Language (SpEL) expression / Target directory
- Spring Integration
- about / Spring Batch and Spring Integration
- job, launching / Launching the job
- batch job status, tracking / Tracking the status of a batch job
- other way round / The other way round
- URL / Summary
- Spring Integration Scala DSL
- about / Spring Integration Scala DSL
- URL / Spring Integration Scala DSL
- state
- scaling / Scaling the state
- message store / Message store
- claim check / Claim check
- stream
- reading from / Reading from a stream
- stream processing
- about / Stream processing
- prerequisites / Prerequisites
- stream, reading from / Reading from a stream
- stream, writing to / Writing to a stream
- STS
- setting up / Setting up STS
- visual editor / STS visual editor
- subscribe-able channel / Spring implementation of channels
- synchronous gateways
- about / Synchronous gateways
- int*gateway / Synchronous gateways
- service-interface / Synchronous gateways
- default-request-channel / Synchronous gateways
- default-reply-channel / Synchronous gateways
T
- testing
- prerequisites / Prerequisite
- threading
- about / Threading
- transactions
- about / Transactions
- transformation
- about / Transformation
- DB transformer / The DB transformer
- JMS transformer / The JMS transformer
- mail transformer / The mail transformer
- transformers
- about / Beyond default transformers
- int*transformer / Beyond default transformers
- ref / Beyond default transformers
- input-channel / Beyond default transformers
- output-channel / Beyond default transformers
- method / Beyond default transformers
- tree polling channel adapter / The tree polling channel adapter
- tweets
- receiving / Receiving tweets
- int-twitter*inbound-channel-adapter / Receiving tweets
- twitter-template / Receiving tweets, Twitter search outbound gateway
- channel / Receiving tweets
- sending / Sending tweets
- int-twitter*search-outbound-gateway / Twitter search outbound gateway
- request-channel / Twitter search outbound gateway
- search-args-expression / Twitter search outbound gateway
- reply-channel / Twitter search outbound gateway
- twitter
- URL / Prerequisites
- search outbound gateway / Twitter search outbound gateway
U
- unidirectional endpoints / Message endpoints
- unmarshaller / Working with XML payload
- unmarshalling transformer
- about / The unmarshalling transformer
V
- vertical scaling
- about / Scaling up
W
- web services
- about / Web services
- prerequisites / Prerequisites
- inbound gateway / The inbound gateway
- outbound gateway / The outbound gateway
- wire trap
- about / Wire tap
X
- XML messages
- validating / Validating XML messages
- XML payload
- about / Working with XML payload
- marshalling transformer / The marshalling transformer
- unmarshalling transformer / The unmarshalling transformer
- XPath transformers / XPath transformers
- Xpath router
- about / XPath router
- XPath transformers
- about / XPath transformers