com.bea.alsb.financial.services

Interface BatchService

All Known Implementing Classes:

BatchServiceImpl

public interface BatchService

Service for aggregating messages into and splitting them from a batch.

Method Summary

Modifier and Type	Method and Description
BinaryMessageAggregator	addBinaryMessage(byte[] message, BinaryMessageAggregator aggregator)
StringMessageAggregator	addStringMessage(java.lang.String message, StringMessageAggregator 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)
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[] message, java.lang.String bytesInHexaForSeparator)
StringMessageBatch	splitStringMessage(java.lang.String message, java.lang.String separator)

Method Detail

splitBinaryMessage

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

Throws:

SplitException

getBinaryBatchSize

int getBinaryBatchSize(BinaryMessageBatch messages)

getNextMessage

byte[] getNextMessage(BinaryMessageBatch messages)

splitStringMessage

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

Throws:

SplitException

getStringBatchSize

int getStringBatchSize(StringMessageBatch messages)

getNextMessage

java.lang.String getNextMessage(StringMessageBatch messages)

parseStringBatch

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

createBinaryMessageAggregator

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

addBinaryMessage

BinaryMessageAggregator addBinaryMessage(byte[] message,
                                         BinaryMessageAggregator aggregator)

getAggregatedBinaryMessageBatch

byte[] getAggregatedBinaryMessageBatch(BinaryMessageAggregator aggregator)
                                throws AggregationException

Throws:

AggregationException

createStringMessageAggregator

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

addStringMessage

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

getAggregatedStringMessageBatch

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

Throws:

AggregationException