com.devexperts.qd.qtp

Class AgentChannels

java.lang.Object

com.devexperts.qd.qtp.AgentChannels

public class AgentChannels
extends Object

The AgentChannels class represents a collection of agent channels, each associated with a QDAgent. The main methods of this class, such as processSubscription(com.devexperts.qd.ng.RecordSource, com.devexperts.qd.QDContract, boolean), retrieveData(), and nextRetrieveTime(long), automatically operate on the collection of channels.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AgentChannels.Owner The Owner interface represents the owner of the agent channels.

Constructor Summary

Constructors

Constructor and Description
AgentChannels(AgentChannels.Owner owner, Collection<ChannelShaper> shapers)

Method Summary

Modifier and Type	Method and Description
static void	clearDataInBuffer(RecordBuffer buf, boolean keepTime)
void	close()
void	closeAndExamineDataBySubscription(RecordBuffer buf)
long	nextRetrieveTime(long currentTime) Returns the next time when the retrieveData() method should be called.
boolean	processSubscription(RecordSource sub, QDContract contract, boolean isSubscriptionAdd) Processes subscription.
boolean	retrieveData() Retrieves accumulated messages using the provided RetrieveFromProvider function.

Methods inherited from class java.lang.Object

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

Constructor Detail

AgentChannels

public AgentChannels(AgentChannels.Owner owner,
                     Collection<ChannelShaper> shapers)

Method Detail

clearDataInBuffer

public static void clearDataInBuffer(RecordBuffer buf,
                                     boolean keepTime)

processSubscription

public boolean processSubscription(RecordSource sub,
                                   QDContract contract,
                                   boolean isSubscriptionAdd)

Processes subscription.

Parameters:

sub - the subscription

contract - the QDContract

isSubscriptionAdd - flag indicating whether the subscription is added or removed

Returns:

true if the contract exists, false otherwise

nextRetrieveTime

public long nextRetrieveTime(long currentTime)

Returns the next time when the retrieveData() method should be called.

Parameters:

currentTime - the current time in milliseconds obtained from System.currentTimeMillis()

Returns:

the next scheduled time for invoking retrieveData(); returns 0 if data should be retrieved immediately using retrieveData(), returns Long.MAX_VALUE if waiting for AgentChannels.Owner.recordsAvailable() to be triggered.

retrieveData

public boolean retrieveData()

Retrieves accumulated messages using the provided RetrieveFromProvider function.

Returns:

true if some messages still remain in the provider, false otherwise

close

public void close()

closeAndExamineDataBySubscription

public void closeAndExamineDataBySubscription(RecordBuffer buf)