io.growing.sdk.java.sender

Class FixThreadPoolSender

java.lang.Object

io.growing.sdk.java.sender.FixThreadPoolSender

All Implemented Interfaces:

MessageSender

public class FixThreadPoolSender
extends Object
implements MessageSender

Since:

: 11/21/18 4:46 PM

Version:

: 1.0.0

Author:

: tong.wang

Constructor Summary

Constructors

Constructor and Description
FixThreadPoolSender()

Method Summary

Modifier and Type	Method and Description
void	awaitTermination(long timeout)
void	doSend(String projectKey, List<GIOMessage> msgList)
static NetProviderAbstract	getNetProvider()
void	sendMsg(String projectKey, List<GIOMessage> msg)
void	shutdownNow()

Methods inherited from class java.lang.Object

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

Constructor Detail

FixThreadPoolSender

public FixThreadPoolSender()

Method Detail

sendMsg

public void sendMsg(String projectKey,
                    List<GIOMessage> msg)

Specified by:

sendMsg in interface MessageSender

getNetProvider

public static NetProviderAbstract getNetProvider()

doSend

public void doSend(String projectKey,
                   List<GIOMessage> msgList)

shutdownNow

public void shutdownNow()

Specified by:

shutdownNow in interface MessageSender

awaitTermination

public void awaitTermination(long timeout)

Specified by:

awaitTermination in interface MessageSender