io.growing.sdk.java.store

Class StoreStrategyAbstract

java.lang.Object

io.growing.sdk.java.store.StoreStrategyAbstract

All Implemented Interfaces:

StoreStrategy

Direct Known Subclasses:

AbortPolicyStoreStrategy, DefaultStoreStrategy

public abstract class StoreStrategyAbstract
extends Object
implements StoreStrategy

Since:

: 11/21/18 5:26 PM

Version:

: 1.0.0

Author:

: tong.wang

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	AWAIT
protected static BlockingQueue<GIOMessage>	messageBlockingQueue
protected static int	PUSH_THREAD_POOL_TIMEOUT
protected static ExecutorService	pushMsgThreadPool
protected static int	SEND_THREAD_POOL_TIMEOUT
protected static int	SENDER_THREAD_POOL_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
StoreStrategyAbstract()

Method Summary

Modifier and Type	Method and Description
abstract void	doPush(GIOMessage msg)
void	push(GIOMessage msg)
void	registerShutdownHook() 最后在调用此方法，以避免关闭时，queue没有被消费完.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.growing.sdk.java.store.StoreStrategy

awaitTerminationAfterShutdown, shutDownNow

Field Detail

pushMsgThreadPool

protected static ExecutorService pushMsgThreadPool

AWAIT

protected static final int AWAIT

PUSH_THREAD_POOL_TIMEOUT

protected static final int PUSH_THREAD_POOL_TIMEOUT

SEND_THREAD_POOL_TIMEOUT

protected static final int SEND_THREAD_POOL_TIMEOUT

SENDER_THREAD_POOL_TIMEOUT

protected static final int SENDER_THREAD_POOL_TIMEOUT

messageBlockingQueue

protected static BlockingQueue<GIOMessage> messageBlockingQueue

Constructor Detail

StoreStrategyAbstract

public StoreStrategyAbstract()

Method Detail

push

public void push(GIOMessage msg)

Specified by:

push in interface StoreStrategy

doPush

public abstract void doPush(GIOMessage msg)

registerShutdownHook

public void registerShutdownHook()

最后在调用此方法，以避免关闭时，queue没有被消费完.

Specified by:

registerShutdownHook in interface StoreStrategy