io.growing.sdk.java.store.impl

Class AbortPolicyStoreStrategy

java.lang.Object

io.growing.sdk.java.store.StoreStrategyAbstract

io.growing.sdk.java.store.impl.AbortPolicyStoreStrategy

All Implemented Interfaces:

StoreStrategy

public class AbortPolicyStoreStrategy
extends StoreStrategyAbstract

while speed is too fast, msg will be rejected.

Version:

1.0, 2020/10/29

Author:

liguobin@growingio.com

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	SPEED_THREAD_POOL_TIMEOUT

Fields inherited from class io.growing.sdk.java.store.StoreStrategyAbstract

AWAIT, messageBlockingQueue, PUSH_THREAD_POOL_TIMEOUT, pushMsgThreadPool, SEND_THREAD_POOL_TIMEOUT, SENDER_THREAD_POOL_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
AbortPolicyStoreStrategy()

Method Summary

Modifier and Type	Method and Description
void	awaitTerminationAfterShutdown()
void	doPush(GIOMessage msg)
void	shutDownNow()

Methods inherited from class io.growing.sdk.java.store.StoreStrategyAbstract

push, registerShutdownHook

Methods inherited from class java.lang.Object

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

Field Detail

SPEED_THREAD_POOL_TIMEOUT

protected static final int SPEED_THREAD_POOL_TIMEOUT

Constructor Detail

AbortPolicyStoreStrategy

public AbortPolicyStoreStrategy()

Method Detail

doPush

public void doPush(GIOMessage msg)

Specified by:

doPush in class StoreStrategyAbstract

awaitTerminationAfterShutdown

public void awaitTerminationAfterShutdown()

shutDownNow

public void shutDownNow()