com.bea.alsb.financial.internal

Class BinaryMessageAggregatorImpl

java.lang.Object

com.bea.alsb.financial.internal.MessageAggregatorImpl<byte[]>

com.bea.alsb.financial.internal.BinaryMessageAggregatorImpl

All Implemented Interfaces:

BinaryMessageAggregator, MessageAggregator<byte[]>

public class BinaryMessageAggregatorImpl
extends MessageAggregatorImpl<byte[]>
implements BinaryMessageAggregator

Byte-array message aggregator implementation based on the MessageAggregatorImpl.

Field Summary

Fields inherited from class com.bea.alsb.financial.internal.MessageAggregatorImpl

appendAtTheEnd, messageCount, messageList, separator

Constructor Summary

Constructors

Constructor and Description
BinaryMessageAggregatorImpl(byte[] separator, boolean appendAtTheEnd) Constructor.

Method Summary

Modifier and Type	Method and Description
int	addMessage(byte[] message) Enhances the message addition by keeping track of the total number of bytes in the aggregator.
protected byte[]	aggregate() Defines how the multiple arrays of bytes in this aggregator become one single array of bytes.
int	getByteCount() Getter for the current byte count.

Methods inherited from class com.bea.alsb.financial.internal.MessageAggregatorImpl

getAggregatedMessage, getMessageCount, getSeparator, isAppendAtTheEnd

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bea.alsb.financial.api.MessageAggregator

getAggregatedMessage, getMessageCount, getSeparator, isAppendAtTheEnd

Constructor Detail

BinaryMessageAggregatorImpl

public BinaryMessageAggregatorImpl(byte[] separator,
                                   boolean appendAtTheEnd)

Constructor.

Parameters:

separator -

appendAtTheEnd -

Method Detail

addMessage

public int addMessage(byte[] message)

Enhances the message addition by keeping track of the total number of bytes in the aggregator.

Specified by:

addMessage in interface MessageAggregator<byte[]>

Overrides:

addMessage in class MessageAggregatorImpl<byte[]>

Parameters:

message - the message to add.

Returns:

the message count after the addition.

See Also:

MessageAggregatorImpl.addMessage(java.lang.Object)

aggregate

protected byte[] aggregate()

Defines how the multiple arrays of bytes in this aggregator become one single array of bytes.

Specified by:

aggregate in class MessageAggregatorImpl<byte[]>

Returns:

the fully-aggregated T.

See Also:

MessageAggregatorImpl.aggregate()

getByteCount

public int getByteCount()

Getter for the current byte count.

Returns:

the number of bytes in the aggregator.