org.springframework.batch.item.jms
Class JmsItemReader<T>
java.lang.Object
org.springframework.batch.item.jms.JmsItemReader<T>
- All Implemented Interfaces:
- ItemReader<T>, org.springframework.beans.factory.InitializingBean
public class JmsItemReader<T>
- extends java.lang.Object
- implements ItemReader<T>, org.springframework.beans.factory.InitializingBean
An ItemReader for JMS using a JmsTemplate. The template
should have a default destination, which will be used to provide items in
read().
The implementation is thread safe after its properties are set (normal
singleton behavior).
- Author:
- Dave Syer
|
Field Summary |
protected java.lang.Class<? extends T> |
itemType
|
protected org.springframework.jms.core.JmsOperations |
jmsTemplate
|
protected org.apache.commons.logging.Log |
logger
|
|
Method Summary |
void |
afterPropertiesSet()
|
T |
read()
Reads a piece of input data and advance to the next one. |
void |
setItemType(java.lang.Class<? extends T> itemType)
Set the expected type of incoming message payloads. |
void |
setJmsTemplate(org.springframework.jms.core.JmsOperations jmsTemplate)
Setter for jms template. |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
protected org.apache.commons.logging.Log logger
itemType
protected java.lang.Class<? extends T> itemType
jmsTemplate
protected org.springframework.jms.core.JmsOperations jmsTemplate
JmsItemReader
public JmsItemReader()
setJmsTemplate
public void setJmsTemplate(org.springframework.jms.core.JmsOperations jmsTemplate)
- Setter for jms template.
- Parameters:
jmsTemplate - a JmsOperations instance
setItemType
public void setItemType(java.lang.Class<? extends T> itemType)
- Set the expected type of incoming message payloads. Set this to
Message to receive the raw underlying message.
- Parameters:
itemType - the java class of the items to be delivered. Typically
the same as the class parameter
- Throws:
java.lang.IllegalStateException - if the message payload is of the wrong
type.
read
public T read()
- Description copied from interface:
ItemReader
- Reads a piece of input data and advance to the next one. Implementations
must return
null at the end of the input
data set. In a transactional setting, caller might get the same item
twice from successive calls (or otherwise), if the first call was in a
transaction that rolled back.
- Specified by:
read in interface ItemReader<T>
afterPropertiesSet
public void afterPropertiesSet()
throws java.lang.Exception
- Specified by:
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
- Throws:
java.lang.Exception
Copyright © 2009. All Rights Reserved.