cloud.metaapi.sdk.clients.meta_api

Class SynchronizationThrottler

java.lang.Object

cloud.metaapi.sdk.clients.meta_api.SynchronizationThrottler

public class SynchronizationThrottler
extends Object

Synchronization throttler used to limit the amount of concurrent synchronizations to prevent application from being overloaded due to excessive number of synchronisation responses being sent.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,Long>	synchronizationIds

Constructor Summary

Constructors

Constructor and Description
SynchronizationThrottler(MetaApiWebsocketClient client, int maxConcurrentSynchronizations) Constructs the synchronization throttler

Method Summary

Modifier and Type	Method and Description
boolean	isSynchronizationAvailable() Returns flag whether there are free slots for synchronization requests
void	onDisconnect() Clears synchronization ids on disconnect
void	removeSynchronizationId(String synchronizationId) Removes synchronization id from slots and removes ids for the same account from the queue
CompletableFuture<com.fasterxml.jackson.databind.JsonNode>	scheduleSynchronize(String accountId, com.fasterxml.jackson.databind.node.ObjectNode request) Schedules to send a synchronization request for account
void	updateSynchronizationId(String synchronizationId) Fills a synchronization slot with synchronization id

Methods inherited from class java.lang.Object

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

Field Detail

synchronizationIds

protected Map<String,Long> synchronizationIds

Constructor Detail

SynchronizationThrottler

public SynchronizationThrottler(MetaApiWebsocketClient client,
                                int maxConcurrentSynchronizations)

Constructs the synchronization throttler

Parameters:

client - MetaApi websocket client

maxConcurrentSynchronizations - Limit of concurrent synchronizations

Method Detail

updateSynchronizationId

public void updateSynchronizationId(String synchronizationId)

Fills a synchronization slot with synchronization id

Parameters:

synchronizationId - Synchronization id

isSynchronizationAvailable

public boolean isSynchronizationAvailable()

Returns flag whether there are free slots for synchronization requests

Returns:

Flag whether there are free slots for synchronization requests

removeSynchronizationId

public void removeSynchronizationId(String synchronizationId)

Removes synchronization id from slots and removes ids for the same account from the queue

Parameters:

synchronizationId - Synchronization id

onDisconnect

public void onDisconnect()

Clears synchronization ids on disconnect

scheduleSynchronize

public CompletableFuture<com.fasterxml.jackson.databind.JsonNode> scheduleSynchronize(String accountId,
                                                                                      com.fasterxml.jackson.databind.node.ObjectNode request)

Schedules to send a synchronization request for account

Parameters:

accountId - Account id

request - Request to send