com.devexperts.qd.qtp

Class ByteArrayComposer

java.lang.Object

com.devexperts.qd.qtp.AbstractMessageVisitor

com.devexperts.qd.qtp.AbstractQTPComposer

com.devexperts.qd.qtp.BinaryQTPComposer

com.devexperts.qd.qtp.ByteArrayComposer

All Implemented Interfaces:

DataVisitor, RecordSink, MessageVisitor, SubscriptionVisitor

Deprecated.

Use BinaryQTPComposer.

public class ByteArrayComposer
extends BinaryQTPComposer

Deprecated class that composes QTP messages in binary format into a single byte array.

Use BinaryQTPComposer instead. Note, that unlike this ByteArrayComposer, you have to specify an output to use with BinaryQTPComposer using its setOutput method. The recommended choice of output is ChunkedOutput which takes byte arrays from a pool and keeps a list of byte array instead of reallocation and copying.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.devexperts.io.ByteArrayOutput	out Deprecated.
protected byte[]	pooledBuffer Deprecated.

Fields inherited from class com.devexperts.qd.qtp.AbstractQTPComposer

currentMessageType, msg, optSet, scheme, stats, writeEventTimeSequence, writeHeartbeat

Fields inherited from interface com.devexperts.qd.ng.RecordSink

VOID

Constructor Summary

Constructors

Constructor and Description
ByteArrayComposer(DataScheme scheme) Deprecated.
ByteArrayComposer(DataScheme scheme, boolean describeRecords) Deprecated.

Method Summary

Modifier and Type	Method and Description
boolean	compose(MessageProvider provider, QDStats stats) Deprecated. Composes message from the corresponding message provides and update IO bytes written in stats.
byte[]	getBuffer() Deprecated. Returns byte array buffer where data is stored.
int	getProcessed() Deprecated. Returns number of processed bytes ready to be sent over and removed.
boolean	hasCapacity() Deprecated. Returns true when the overall number of bytes composed had not exceeded the threshold yet.
void	removeBytes(int n) Deprecated. Removes specified number of bytes from the start of the buffer.
void	removeBytes(int off, int len) Deprecated. Removes specified number of bytes from a specified part of the buffer from offset off with a length of len.
void	setOutput(com.devexperts.io.BufferedOutput output) Deprecated. Changes output for the composed messages.

Methods inherited from class com.devexperts.qd.qtp.BinaryQTPComposer

describeRecord, finishComposingMessage, getRequestedRecordDesc, isWideDecimalSupported, writeDescribeProtocolMessage, writeEmptyHeartbeatMessage, writeEventTimeSequence, writeField, writeHeartbeatMessage, writeHistorySubscriptionTime, writeIntField, writeMessageHeader, writeObjField, writeOtherMessageBody, writeRecordHeader, writeRecordPayload

Methods inherited from class com.devexperts.qd.qtp.AbstractQTPComposer

abortMessageAndRethrow, append, beginMessage, beginRecord, compose, composeDescribeProtocol, composeEmptyHeartbeat, composeHeartbeatMessage, composeTimeProgressReport, endMessage, flush, getEventTimeSequence, getMessagePayloadSize, inMessage, resetSession, setOptSet, setStats, setWriteEventTimeSequence, setWriteHeartbeat, undoWriteMessageHeaderStateChange, visitData, visitDescribeProtocol, visitHeartbeat, visitIntField, visitObjField, visitOtherMessage, visitRecord, visitRecord, visitSubscription

Methods inherited from class com.devexperts.qd.qtp.AbstractMessageVisitor

visitHistoryAddSubscription, visitHistoryData, visitHistoryRemoveSubscription, visitStreamAddSubscription, visitStreamData, visitStreamRemoveSubscription, visitTickerAddSubscription, visitTickerData, visitTickerRemoveSubscription

Methods inherited from class java.lang.Object

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

Field Detail

pooledBuffer

protected byte[] pooledBuffer

Deprecated.

out

protected com.devexperts.io.ByteArrayOutput out

Deprecated.

Constructor Detail

ByteArrayComposer

public ByteArrayComposer(DataScheme scheme)

Deprecated.

ByteArrayComposer

public ByteArrayComposer(DataScheme scheme,
                         boolean describeRecords)

Deprecated.

Method Detail

setOutput

public void setOutput(com.devexperts.io.BufferedOutput output)

Deprecated.

Changes output for the composed messages. This implementation throws UnsupportedOperationException.

Overrides:

setOutput in class AbstractQTPComposer

Parameters:

output - output for the composed messages.

hasCapacity

public boolean hasCapacity()

Deprecated.

Returns true when the overall number of bytes composed had not exceeded the threshold yet.

Specified by:

hasCapacity in interface DataVisitor

Specified by:

hasCapacity in interface RecordSink

Specified by:

hasCapacity in interface SubscriptionVisitor

Overrides:

hasCapacity in class AbstractQTPComposer

compose

public boolean compose(MessageProvider provider,
                       QDStats stats)

Deprecated.

Composes message from the corresponding message provides and update IO bytes written in stats.

removeBytes

public void removeBytes(int n)

Deprecated.

Removes specified number of bytes from the start of the buffer. This is a shortcut to removeBytes(0, n).

Parameters:

n - number of bytes to remove.

Throws:

IllegalArgumentException - if specified number is negative or is larger than the number of processed bytes.

removeBytes

public void removeBytes(int off,
                        int len)

Deprecated.

Removes specified number of bytes from a specified part of the buffer from offset off with a length of len.

Parameters:

off - offset of bytes to remove.

len - number of bytes to remove.

Throws:

IllegalArgumentException - if off and/or len are out of valid range.

getProcessed

public int getProcessed()

Deprecated.

Returns number of processed bytes ready to be sent over and removed.

Returns:

number of processed bytes ready to be sent over and removed.

getBuffer

public byte[] getBuffer()

Deprecated.

Returns byte array buffer where data is stored. Valid index range is from zero inclusive to the number of processed bytes exclusive.

Note: the array instance used for buffering may change if new messages are added or previous ones are removed.

Returns:

byte array buffer.