cloud.metaapi.sdk.clients.meta_api

Class PacketOrderer

java.lang.Object

cloud.metaapi.sdk.clients.meta_api.PacketOrderer

public class PacketOrderer
extends Object

Class which orders the synchronization packets

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	PacketOrderer.Packet Class for storing packet in wait list

Constructor Summary

Constructors

Constructor and Description
PacketOrderer(OutOfOrderListener outOfOrderListener, int orderingTimeoutInSeconds) Constructs the class

Method Summary

Modifier and Type	Method and Description
void	onReconnected(List<String> reconnectAccountIds) Resets state for specified accounts on reconnect
void	onStreamClosed(String instanceId) Resets state for instance id
List<com.fasterxml.jackson.databind.JsonNode>	restoreOrder(com.fasterxml.jackson.databind.JsonNode packet) Processes the packet and resolves in the order of packet sequence number
void	start() Initializes the packet orderer
void	stop() Deinitialized the packet orderer

Methods inherited from class java.lang.Object

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

Constructor Detail

PacketOrderer

public PacketOrderer(OutOfOrderListener outOfOrderListener,
                     int orderingTimeoutInSeconds)

Constructs the class

Parameters:

outOfOrderListener - listener which will receive out of order packet events

orderingTimeoutInSeconds - packet ordering timeout

Method Detail

start

public void start()

Initializes the packet orderer

stop

public void stop()

Deinitialized the packet orderer

restoreOrder

public List<com.fasterxml.jackson.databind.JsonNode> restoreOrder(com.fasterxml.jackson.databind.JsonNode packet)

Processes the packet and resolves in the order of packet sequence number

Parameters:

packet - packet to process

Returns:

ordered packets when the packets are ready to be processed in order

onStreamClosed

public void onStreamClosed(String instanceId)

Resets state for instance id

Parameters:

instanceId - instance id to reset state for

onReconnected

public void onReconnected(List<String> reconnectAccountIds)

Resets state for specified accounts on reconnect

Parameters:

reconnectAccountIds - reconnected account ids