org.jberet.support.io

Class HornetQItemReaderWriterBase

java.lang.Object

org.jberet.support.io.ItemReaderWriterBase

org.jberet.support.io.HornetQItemReaderWriterBase

Direct Known Subclasses:

HornetQItemReader, HornetQItemWriter

Deprecated.

As of 1.3.0, replaced by ArtemisItemReaderWriterBase

@Deprecated
public abstract class HornetQItemReaderWriterBase
extends ItemReaderWriterBase

The base class for HornetQItemReader and HornetQItemWriter.

Since:

1.1.0

See Also:

HornetQItemReader, HornetQItemWriter

Field Summary

Fields

Modifier and Type	Field and Description
protected Map	connectorFactoryParams Deprecated. Key-value pairs to identify and configure HornetQ org.hornetq.api.core.TransportConfiguration, which is used to create HornetQ ServerLocator.
protected org.hornetq.api.core.SimpleString	queueAddress Deprecated.
protected org.hornetq.api.core.SimpleString	queueName Deprecated.
protected Map	queueParams Deprecated. Key-value pairs to identify and configure the target HornetQ queue.
protected Class	sendAcknowledgementHandler Deprecated. The fully-qualified name of a class that implements org.hornetq.api.core.client.SendAcknowledgementHandler.
protected org.hornetq.api.core.client.ServerLocator	serverLocator Deprecated.
protected javax.enterprise.inject.Instance<org.hornetq.api.core.client.ServerLocator>	serverLocatorInstance Deprecated. This field holds an optional injection of HornetQ ServerLocator.
protected Map	serverLocatorParams Deprecated. Key-value pairs to configure HornetQ ServerLocator.
protected org.hornetq.api.core.client.ClientSession	session Deprecated.
protected org.hornetq.api.core.client.ClientSessionFactory	sessionFactory Deprecated.
protected javax.enterprise.inject.Instance<org.hornetq.api.core.client.ClientSessionFactory>	sessionFactoryInstance Deprecated. This field holds an optional injection of HornetQ ClientSessionFactory.

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

NEW_LINE, resource, skipBeanValidation

Constructor Summary

Constructors

Constructor and Description
HornetQItemReaderWriterBase() Deprecated.

Method Summary

Modifier and Type	Method and Description
Serializable	checkpointInfo() Deprecated.
protected void	close() Deprecated.
protected void	configureServerLocator() Deprecated.
void	open(Serializable checkpoint) Deprecated.

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

serverLocatorInstance

@Inject
protected javax.enterprise.inject.Instance<org.hornetq.api.core.client.ServerLocator> serverLocatorInstance

Deprecated.

This field holds an optional injection of HornetQ ServerLocator. When connectorFactoryParams is not specified, and sessionFactoryInstance is not satisfied, this field will be queried to obtain an instance of HornetQ ServerLocator. The application may implement a javax.enterprise.inject.Produces method to satisfy this dependency injection.

sessionFactoryInstance

@Inject
protected javax.enterprise.inject.Instance<org.hornetq.api.core.client.ClientSessionFactory> sessionFactoryInstance

Deprecated.

This field holds an optional injection of HornetQ ClientSessionFactory. If this injection is satisfied, serverLocatorInstance will be ignored. The application may implement a javax.enterprise.inject.Produces method to satisfy this dependency injection.

connectorFactoryParams

@Inject
protected Map connectorFactoryParams

Deprecated.

Key-value pairs to identify and configure HornetQ org.hornetq.api.core.TransportConfiguration, which is used to create HornetQ ServerLocator. Optional property and defaults to null. When this property is present, it will be used to create HornetQ ServerLocator, and the injection fields serverLocatorInstance and sessionFactoryInstance will be ignored. Valid keys and values are:

• "factory-class", the fully-qualified class name of a HornetQ connector factory, required if this property is present
• any param keys and values appropriate for the above-named HornetQ connector factory class

An example of this property in job xml:

<property name="connectorFactoryParams" value="factory-class=org.hornetq.core.remoting.impl.netty.NettyConnectorFactory, host=localhost, port=5445"/>

serverLocatorParams

@Inject
protected Map serverLocatorParams

Deprecated.

Key-value pairs to configure HornetQ ServerLocator. Optional property and defaults to null. Valid keys are:

• HA: true or false (default), true if the ServerLocator receives topology updates from the cluster
• Properties in ServerLocator class that have corresponding setter method, starting with either upper or lower case character

See the current version of HornetQ ServerLocator javadoc for supported keys and values, e.g., ServerLocator

An example of this property in job xml:

<property name="serverLocatorParams" value="HA=false, AckBatchSize=5, ProducerMaxRate=10, BlockOnAcknowledge=false, ConfirmationWindowSize=5"/>

queueParams

@Inject
protected Map queueParams

Deprecated.

Key-value pairs to identify and configure the target HornetQ queue. Required property.

The following keys are supported:

• "address", required
• "durable", optional
• "filter", optional
• "name", optional
• "shared", optional
• "temporary", optional

An example of queueParams property in job xml:

<property name="queueParams" value="address=example, durable=false"/>

sendAcknowledgementHandler

@Inject
protected Class sendAcknowledgementHandler

Deprecated.

The fully-qualified name of a class that implements org.hornetq.api.core.client.SendAcknowledgementHandler. A SendAcknowledgementHandler notifies a client when an message sent asynchronously has been received by the server. See current version of HornetQ documentation for details, e.g., SendAcknowledgementHandler

An example sendAcknowledgementHandler property in job xml:

<property name="sendAcknowledgementHandler" value="org.jberet.support.io.HornetQReaderWriterTest$HornetQSendAcknowledgementHandler"/>

queueAddress

protected org.hornetq.api.core.SimpleString queueAddress

Deprecated.

queueName

protected org.hornetq.api.core.SimpleString queueName

Deprecated.

serverLocator

protected org.hornetq.api.core.client.ServerLocator serverLocator

Deprecated.

sessionFactory

protected org.hornetq.api.core.client.ClientSessionFactory sessionFactory

Deprecated.

session

protected org.hornetq.api.core.client.ClientSession session

Deprecated.

Constructor Detail

HornetQItemReaderWriterBase

public HornetQItemReaderWriterBase()

Deprecated.

Method Detail

open

public void open(Serializable checkpoint)
          throws Exception

Deprecated.

Throws:

Exception

checkpointInfo

public Serializable checkpointInfo()
                            throws Exception

Deprecated.

Throws:

Exception

configureServerLocator

protected void configureServerLocator()
                               throws Exception

Deprecated.

Throws:

Exception

close

protected void close()

Deprecated.