Package org.dromara.oa.core.provider.service

Class AbstractOaBlend<C extends OaSupplierConfig>

java.lang.Object

org.dromara.oa.core.provider.service.AbstractOaBlend<C>

All Implemented Interfaces:

OaSender

Direct Known Subclasses:

ByteTalkOaImpl, DingTalkOaImpl, WeTalkOaImpl

public abstract class AbstractOaBlend<C extends OaSupplierConfig>
extends Object
implements OaSender

Author:

dongfeng 2023-10-22 21:03

Field Summary

Fields

Modifier and Type	Field	Description
private C	config
private String	configId
protected Executor	pool
protected PriorityBlockingQueue<Request>	priorityQueueMap

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractOaBlend(C config)
protected	AbstractOaBlend(C config, Executor pool)

Method Summary

Modifier and Type	Method	Description
protected C	getConfig()
protected void	priorityQueueMapThreadInit()
void	senderAsync(Request request, MessageType messageType)	异步(回调)
void	senderAsync(Request request, MessageType messageType, OaCallBack callBack)	异步(不回调)
void	senderAsyncByPriority(Request request, MessageType messageType)	发送带优先级的消息

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.dromara.oa.api.OaSender

getConfigId, getSupplier, sender

Field Detail

configId

private final String configId

config

private final C extends OaSupplierConfig config

pool

protected final Executor pool

priorityQueueMap

protected final PriorityBlockingQueue<Request> priorityQueueMap

Constructor Detail

AbstractOaBlend

protected AbstractOaBlend(C config,
                          Executor pool)

AbstractOaBlend

protected AbstractOaBlend(C config)

Method Detail

getConfig

protected C getConfig()

priorityQueueMapThreadInit

protected void priorityQueueMapThreadInit()

senderAsync

public final void senderAsync(Request request,
                              MessageType messageType)

Description copied from interface: OaSender

异步(回调)

Specified by:

senderAsync in interface OaSender

senderAsync

public final void senderAsync(Request request,
                              MessageType messageType,
                              OaCallBack callBack)

Description copied from interface: OaSender

异步(不回调)

Specified by:

senderAsync in interface OaSender

Parameters:

request - oa请求体

messageType - 消息类型

callBack - 回调方法

senderAsyncByPriority

public final void senderAsyncByPriority(Request request,
                                        MessageType messageType)

Description copied from interface: OaSender

发送带优先级的消息

Specified by:

senderAsyncByPriority in interface OaSender

Parameters:

request - oa请求体

messageType - 消息类型