org.jberet.support.io

Class HornetQItemWriter

java.lang.Object

org.jberet.support.io.ItemReaderWriterBase

org.jberet.support.io.HornetQItemReaderWriterBase

org.jberet.support.io.HornetQItemWriter

All Implemented Interfaces:

javax.batch.api.chunk.ItemWriter

Deprecated.

As of 1.3.0, replaced by ArtemisItemWriter

@Named
 @Dependent
 @Deprecated
public class HornetQItemWriter
extends HornetQItemReaderWriterBase
implements javax.batch.api.chunk.ItemWriter

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

• if the data item is of type java.lang.String, a org.hornetq.api.core.client.ClientMessage#TEXT_TYPE message is created with the text content in the data item, and sent;
• else if the data is of type org.hornetq.api.core.client.ClientMessage, it is sent as is;
• else an org.hornetq.api.core.client.ClientMessage#OBJECT_TYPE message is created with the data item object, and sent.

durableMessage property can be configured to send either durable or non-durable (default) messages.

Since:

1.1.0

See Also:

HornetQItemReader, HornetQItemReaderWriterBase, JmsItemWriter

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	durableMessage Deprecated. Whether the message to be produced is durable or not.
protected org.hornetq.api.core.client.ClientProducer	producer Deprecated.

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

connectorFactoryParams, queueAddress, queueName, queueParams, sendAcknowledgementHandler, serverLocator, serverLocatorInstance, serverLocatorParams, session, sessionFactory, sessionFactoryInstance

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

NEW_LINE, resource, skipBeanValidation

Constructor Summary

Constructors

Constructor and Description
HornetQItemWriter() Deprecated.

Method Summary

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

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

checkpointInfo, configureServerLocator

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

Methods inherited from interface javax.batch.api.chunk.ItemWriter

checkpointInfo

Field Detail

durableMessage

@Inject
protected boolean durableMessage

Deprecated.

Whether the message to be produced is durable or not. Optional property and defaults to false. Valid values are true and false.

producer

protected org.hornetq.api.core.client.ClientProducer producer

Deprecated.

Constructor Detail

HornetQItemWriter

public HornetQItemWriter()

Deprecated.

Method Detail

open

public void open(Serializable checkpoint)
          throws Exception

Deprecated.

Specified by:

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

Overrides:

open in class HornetQItemReaderWriterBase

Throws:

Exception

writeItems

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

Deprecated.

Specified by:

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

Throws:

Exception

close

public void close()

Deprecated.

Specified by:

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

Overrides:

close in class HornetQItemReaderWriterBase