org.jberet.support.io

Class JmsItemWriter

java.lang.Object

org.jberet.support.io.ItemReaderWriterBase

org.jberet.support.io.JmsItemReaderWriterBase

org.jberet.support.io.JmsItemWriter

All Implemented Interfaces:

javax.batch.api.chunk.ItemWriter

@Named
 @Dependent
public class JmsItemWriter
extends JmsItemReaderWriterBase
implements javax.batch.api.chunk.ItemWriter

An implementation of javax.batch.api.chunk.ItemWriter that sends data items to a JMS destination. It can sends the following JMS message types:

• if the data item is of type java.util.Map, a MapMessage is created, populated with the data contained in the data item, and sent;
• else if the data item is of type java.lang.String, a TextMessage is created with the text content in the data item, and sent;
• else if the data is of type javax.jms.Message, it is sent as is;
• else an ObjectMessage is created with the data item object, and sent.

Since:

1.1.0

See Also:

JmsItemReader, JmsItemReaderWriterBase

Field Summary

Fields

Modifier and Type	Field and Description
protected javax.jms.MessageProducer	producer

Fields inherited from class org.jberet.support.io.JmsItemReaderWriterBase

connection, connectionFactory, connectionFactoryInstance, connectionFactoryLookupName, destination, destinationInstance, destinationLookupName, session, sessionMode

Fields inherited from class org.jberet.support.io.ItemReaderWriterBase

NEW_LINE, resource, skipBeanValidation

Constructor Summary

Constructors

Constructor and Description
JmsItemWriter()

Method Summary

Modifier and Type	Method and Description
Serializable	checkpointInfo()
void	close()
void	open(Serializable checkpoint)
void	writeItems(List<Object> items)

Methods inherited from class org.jberet.support.io.ItemReaderWriterBase

getInputStream, getOutputStream, getValidator, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

producer

protected javax.jms.MessageProducer producer

Constructor Detail

JmsItemWriter

public JmsItemWriter()

Method Detail

open

public void open(Serializable checkpoint)
          throws Exception

Specified by:

open in interface javax.batch.api.chunk.ItemWriter

Overrides:

open in class JmsItemReaderWriterBase

Throws:

Exception

writeItems

public void writeItems(List<Object> items)
                throws Exception

Specified by:

writeItems in interface javax.batch.api.chunk.ItemWriter

Throws:

Exception

checkpointInfo

public Serializable checkpointInfo()
                            throws Exception

Specified by:

checkpointInfo in interface javax.batch.api.chunk.ItemWriter

Throws:

Exception

close

public void close()

Specified by:

close in interface javax.batch.api.chunk.ItemWriter

Overrides:

close in class JmsItemReaderWriterBase