com.bea.alsb.financial.internal

Class BatchServiceImpl

java.lang.Object

com.bea.alsb.financial.internal.BatchServiceImpl

All Implemented Interfaces:

BatchService

public class BatchServiceImpl
extends java.lang.Object
implements BatchService

Constructor Summary

Constructors

Constructor and Description
BatchServiceImpl()

Method Summary

Modifier and Type	Method and Description
protected java.util.List<java.lang.String>	_splitStringMessage(java.lang.String messageBatch, java.lang.String separator)
BinaryMessageAggregator	addBinaryMessage(byte[] message, BinaryMessageAggregator aggregator) Adds a binary message to the given aggregator.
StringMessageAggregator	addStringMessage(java.lang.String message, StringMessageAggregator aggregator) Adds a string message to the given aggregator.
BinaryMessageAggregator	createBinaryMessageAggregator(java.lang.String bytesInHexaForSeparator, boolean appendAtTheEnd)
StringMessageAggregator	createStringMessageAggregator(java.lang.String separator, boolean appendAtTheEnd)
byte[]	getAggregatedBinaryMessageBatch(BinaryMessageAggregator aggregator)
java.lang.String	getAggregatedStringMessageBatch(StringMessageAggregator aggregator)
int	getBinaryBatchSize(BinaryMessageBatch messages)
protected byte[]	getBytesFromHexString(java.lang.String bytesInHexaForSeparator) Converts a hex string to the array of bytes represented by it.
byte[]	getNextMessage(BinaryMessageBatch messages)
java.lang.String	getNextMessage(StringMessageBatch messages)
int	getStringBatchSize(StringMessageBatch messages)
XmlTextMessageWrappersDocument	parseStringBatch(java.lang.String messageBatch, java.lang.String separator)
BinaryMessageBatch	splitBinaryMessage(byte[] messageBatch, java.lang.String bytesInHexaForSeparator) Splits the given messageBatch as delimited by the given bytes, and constructs a batch object with the list of identified messages.
StringMessageBatch	splitStringMessage(java.lang.String messageBatch, java.lang.String separator) Tokenizes the given messageBatch as delimited by the separator, and constructs a batch object with the list of identified tokens.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchServiceImpl

public BatchServiceImpl()

Method Detail

addBinaryMessage

public BinaryMessageAggregator addBinaryMessage(byte[] message,
                                                BinaryMessageAggregator aggregator)

Adds a binary message to the given aggregator.

Specified by:

addBinaryMessage in interface BatchService

See Also:

BatchService.addBinaryMessage(byte[], com.bea.alsb.financial.api.BinaryMessageAggregator)

addStringMessage

public StringMessageAggregator addStringMessage(java.lang.String message,
                                                StringMessageAggregator aggregator)

Adds a string message to the given aggregator.

Specified by:

addStringMessage in interface BatchService

See Also:

BatchService.addStringMessage(java.lang.String, com.bea.alsb.financial.api.StringMessageAggregator)

createBinaryMessageAggregator

public BinaryMessageAggregator createBinaryMessageAggregator(java.lang.String bytesInHexaForSeparator,
                                                             boolean appendAtTheEnd)

Specified by:

createBinaryMessageAggregator in interface BatchService

See Also:

BatchService.createBinaryMessageAggregator(java.lang.String, boolean)

createStringMessageAggregator

public StringMessageAggregator createStringMessageAggregator(java.lang.String separator,
                                                             boolean appendAtTheEnd)

Specified by:

createStringMessageAggregator in interface BatchService

See Also:

BatchService.createStringMessageAggregator(java.lang.String, boolean)

getAggregatedBinaryMessageBatch

public byte[] getAggregatedBinaryMessageBatch(BinaryMessageAggregator aggregator)
                                       throws AggregationException

Specified by:

getAggregatedBinaryMessageBatch in interface BatchService

Throws:

AggregationException

See Also:

BatchService.getAggregatedBinaryMessageBatch( com.bea.alsb.financial.api.BinaryMessageAggregator)

getAggregatedStringMessageBatch

public java.lang.String getAggregatedStringMessageBatch(StringMessageAggregator aggregator)
                                                 throws AggregationException

Specified by:

getAggregatedStringMessageBatch in interface BatchService

Throws:

AggregationException

See Also:

BatchService.getAggregatedStringMessageBatch( com.bea.alsb.financial.api.StringMessageAggregator)

getBinaryBatchSize

public int getBinaryBatchSize(BinaryMessageBatch messages)

Specified by:

getBinaryBatchSize in interface BatchService

See Also:

BatchService.getBinaryBatchSize( com.bea.alsb.financial.api.BinaryMessageBatch)

getNextMessage

public byte[] getNextMessage(BinaryMessageBatch messages)

Specified by:

getNextMessage in interface BatchService

See Also:

BatchService.getNextMessage( com.bea.alsb.financial.api.BinaryMessageBatch)

getNextMessage

public java.lang.String getNextMessage(StringMessageBatch messages)

Specified by:

getNextMessage in interface BatchService

See Also:

BatchService.getNextMessage( com.bea.alsb.financial.api.StringMessageBatch)

getStringBatchSize

public int getStringBatchSize(StringMessageBatch messages)

Specified by:

getStringBatchSize in interface BatchService

See Also:

BatchService.getStringBatchSize( com.bea.alsb.financial.api.StringMessageBatch)

parseStringBatch

public XmlTextMessageWrappersDocument parseStringBatch(java.lang.String messageBatch,
                                                       java.lang.String separator)

Specified by:

parseStringBatch in interface BatchService

See Also:

BatchService.parseStringBatch(java.lang.String, java.lang.String)

splitBinaryMessage

public BinaryMessageBatch splitBinaryMessage(byte[] messageBatch,
                                             java.lang.String bytesInHexaForSeparator)
                                      throws SplitException

Splits the given messageBatch as delimited by the given bytes, and constructs a batch object with the list of identified messages.

Specified by:

splitBinaryMessage in interface BatchService

Parameters:

messageBatch - the message batch, as a compact separator-delimited array of bytes.

separator - the delimiter separating the messages in the compact array of bytes.

Returns:

the batch object to be used in the pipeline.

Throws:

SplitException

See Also:

BatchService.splitBinaryMessage(byte[], java.lang.String)

splitStringMessage

public StringMessageBatch splitStringMessage(java.lang.String messageBatch,
                                             java.lang.String separator)
                                      throws SplitException

Tokenizes the given messageBatch as delimited by the separator, and constructs a batch object with the list of identified tokens.

Specified by:

splitStringMessage in interface BatchService

Parameters:

messageBatch - the message batch, as a compact separator-delimited String.

separator - the delimiter separating the messages in the compact string.

Returns:

the batch object to be used in the pipeline.

Throws:

SplitException

See Also:

BatchService.splitStringMessage(java.lang.String, java.lang.String)

_splitStringMessage

protected java.util.List<java.lang.String> _splitStringMessage(java.lang.String messageBatch,
                                                               java.lang.String separator)

Parameters:

messageBatch -

separator -

Returns:

getBytesFromHexString

protected byte[] getBytesFromHexString(java.lang.String bytesInHexaForSeparator)

Converts a hex string to the array of bytes represented by it. XXX this is broken and requires some investigation

Parameters:

bytesInHexaForSeparator - the hex string to be converted.

Returns:

the bytes as an array.