Package org.jumpmind.symmetric.ext

Interface IReloadQueueThreadAssigner

All Superinterfaces:

IExtensionPoint

public interface IReloadQueueThreadAssigner
extends IExtensionPoint

Method Summary

Modifier and Type	Method	Description
void	addDynamicQueues(Collection<String> queues, NodeCommunication.CommunicationType communicationType)
Collection<ExtractRequest>	assignThreadsToExtractRequests(List<ExtractRequest> extractRequests, Channel reloadChannel)

Method Details

assignThreadsToExtractRequests

Collection<ExtractRequest> assignThreadsToExtractRequests(List<ExtractRequest> extractRequests,
 Channel reloadChannel)

addDynamicQueues

void addDynamicQueues(Collection<String> queues,
 NodeCommunication.CommunicationType communicationType)