public class BatchServiceImpl extends java.lang.Object implements BatchService
Constructor and Description |
---|
BatchServiceImpl() |
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.
|
public BinaryMessageAggregator addBinaryMessage(byte[] message, BinaryMessageAggregator aggregator)
addBinaryMessage
in interface BatchService
BatchService.addBinaryMessage(byte[], com.bea.alsb.financial.api.BinaryMessageAggregator)
public StringMessageAggregator addStringMessage(java.lang.String message, StringMessageAggregator aggregator)
addStringMessage
in interface BatchService
BatchService.addStringMessage(java.lang.String, com.bea.alsb.financial.api.StringMessageAggregator)
public BinaryMessageAggregator createBinaryMessageAggregator(java.lang.String bytesInHexaForSeparator, boolean appendAtTheEnd)
createBinaryMessageAggregator
in interface BatchService
BatchService.createBinaryMessageAggregator(java.lang.String, boolean)
public StringMessageAggregator createStringMessageAggregator(java.lang.String separator, boolean appendAtTheEnd)
createStringMessageAggregator
in interface BatchService
BatchService.createStringMessageAggregator(java.lang.String, boolean)
public byte[] getAggregatedBinaryMessageBatch(BinaryMessageAggregator aggregator) throws AggregationException
getAggregatedBinaryMessageBatch
in interface BatchService
AggregationException
BatchService.getAggregatedBinaryMessageBatch( com.bea.alsb.financial.api.BinaryMessageAggregator)
public java.lang.String getAggregatedStringMessageBatch(StringMessageAggregator aggregator) throws AggregationException
getAggregatedStringMessageBatch
in interface BatchService
AggregationException
BatchService.getAggregatedStringMessageBatch( com.bea.alsb.financial.api.StringMessageAggregator)
public int getBinaryBatchSize(BinaryMessageBatch messages)
getBinaryBatchSize
in interface BatchService
BatchService.getBinaryBatchSize( com.bea.alsb.financial.api.BinaryMessageBatch)
public byte[] getNextMessage(BinaryMessageBatch messages)
getNextMessage
in interface BatchService
BatchService.getNextMessage( com.bea.alsb.financial.api.BinaryMessageBatch)
public java.lang.String getNextMessage(StringMessageBatch messages)
getNextMessage
in interface BatchService
BatchService.getNextMessage( com.bea.alsb.financial.api.StringMessageBatch)
public int getStringBatchSize(StringMessageBatch messages)
getStringBatchSize
in interface BatchService
BatchService.getStringBatchSize( com.bea.alsb.financial.api.StringMessageBatch)
public XmlTextMessageWrappersDocument parseStringBatch(java.lang.String messageBatch, java.lang.String separator)
parseStringBatch
in interface BatchService
BatchService.parseStringBatch(java.lang.String, java.lang.String)
public BinaryMessageBatch splitBinaryMessage(byte[] messageBatch, java.lang.String bytesInHexaForSeparator) throws SplitException
splitBinaryMessage
in interface BatchService
messageBatch
- the message batch, as a compact separator
-delimited array of bytes.separator
- the delimiter separating the messages in the compact array of bytes.SplitException
BatchService.splitBinaryMessage(byte[], java.lang.String)
public StringMessageBatch splitStringMessage(java.lang.String messageBatch, java.lang.String separator) throws SplitException
splitStringMessage
in interface BatchService
messageBatch
- the message batch, as a compact separator
-delimited String.separator
- the delimiter separating the messages in the compact string.SplitException
BatchService.splitStringMessage(java.lang.String, java.lang.String)
protected java.util.List<java.lang.String> _splitStringMessage(java.lang.String messageBatch, java.lang.String separator)
messageBatch
-separator
-protected byte[] getBytesFromHexString(java.lang.String bytesInHexaForSeparator)
bytesInHexaForSeparator
- the hex string to be converted.