public class WeChatInboundJmsListener extends Object
Modifier and Type | Field and Description |
---|---|
protected Set<String> |
enabledMessageTypes |
protected InboundMessageHandler |
inboundMessageHandler |
protected InboundService |
inboundService |
protected static String |
STICKER_MESSAGE_TYPE |
protected static String |
TEXT_MESSAGE_TYPE |
protected static String |
UNSUPPORTED_STICKER_TEXT |
protected WechatEmojiConverter |
wechatEmojiConverter |
protected WeChatInboundMessageEventHandler |
weChatInboundMessageEventHandler |
Constructor and Description |
---|
WeChatInboundJmsListener(InboundMessageHandler inboundMessageHandler,
WechatEmojiConverter wechatEmojiConverter,
InboundService inboundService,
WeChatInboundMessageEventHandler weChatInboundMessageEventHandler,
Set<String> enabledMessageTypes) |
Modifier and Type | Method and Description |
---|---|
protected String |
getMessageType(InboundMessageDto message) |
void |
receiveError(InboundErrorDto error) |
void |
receiveMessage(InboundMessageDto message) |
void |
receiveStatus(InboundStatusDto status) |
protected static final String UNSUPPORTED_STICKER_TEXT
protected static final String TEXT_MESSAGE_TYPE
protected static final String STICKER_MESSAGE_TYPE
protected final InboundMessageHandler inboundMessageHandler
protected final WechatEmojiConverter wechatEmojiConverter
protected final InboundService inboundService
protected final WeChatInboundMessageEventHandler weChatInboundMessageEventHandler
public WeChatInboundJmsListener(InboundMessageHandler inboundMessageHandler, WechatEmojiConverter wechatEmojiConverter, InboundService inboundService, WeChatInboundMessageEventHandler weChatInboundMessageEventHandler, Set<String> enabledMessageTypes)
@JmsListener(destination="${flowable.external-system.wechat.inbound:wechat-inbound}") public void receiveMessage(@Payload InboundMessageDto message)
protected String getMessageType(InboundMessageDto message)
@JmsListener(destination="${flowable.external-system.wechat.inbound-status:wechat-inbound-status}") public void receiveStatus(@Payload InboundStatusDto status)
@JmsListener(destination="${flowable.external-system.wechat.inbound-error:wechat-inbound-error}") public void receiveError(@Payload InboundErrorDto error)
Copyright © 2019. All rights reserved.