public class WhatsAppInboundJmsListener extends Object
Modifier and Type | Field and Description |
---|---|
protected Set<String> |
enabledMessageTypes |
protected Map<String,List<WhatsAppInboundEventHandler>> |
eventHandlers |
protected InboundMessageHandler |
inboundMessageHandler |
protected InboundService |
inboundService |
protected com.fasterxml.jackson.databind.ObjectMapper |
objectMapper |
Constructor and Description |
---|
WhatsAppInboundJmsListener(InboundMessageHandler inboundMessageHandler,
InboundService inboundService,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
Collection<WhatsAppInboundEventHandler> eventHandlers,
Set<String> enabledMessageTypes) |
Modifier and Type | Method and Description |
---|---|
void |
receiveError(InboundErrorDto error) |
void |
receiveMessage(InboundMessageDto message) |
void |
receivePayload(com.fasterxml.jackson.databind.JsonNode payload,
String payloadType) |
void |
receiveStatus(InboundStatusDto status) |
protected void |
unsupportedType(com.fasterxml.jackson.databind.JsonNode payload,
String payloadType) |
protected final InboundMessageHandler inboundMessageHandler
protected final InboundService inboundService
protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper
protected final Map<String,List<WhatsAppInboundEventHandler>> eventHandlers
public WhatsAppInboundJmsListener(InboundMessageHandler inboundMessageHandler, InboundService inboundService, com.fasterxml.jackson.databind.ObjectMapper objectMapper, Collection<WhatsAppInboundEventHandler> eventHandlers, Set<String> enabledMessageTypes)
@JmsListener(destination="${flowable.external-system.whatsapp.inbound-payload:whatsapp-inbound-payload}") public void receivePayload(@Payload com.fasterxml.jackson.databind.JsonNode payload, @Header(name="externalEventType") String payloadType)
protected void unsupportedType(com.fasterxml.jackson.databind.JsonNode payload, String payloadType)
@JmsListener(destination="${flowable.external-system.whatsapp.inbound:whatsapp-inbound}") public void receiveMessage(@Payload InboundMessageDto message)
@JmsListener(destination="${flowable.external-system.whatsapp.inbound-status:whatsapp-inbound-status}") public void receiveStatus(@Payload InboundStatusDto status)
@JmsListener(destination="${flowable.external-system.whatsapp.inbound-error:whatsapp-inbound-error}") public void receiveError(@Payload InboundErrorDto error)
Copyright © 2019. All rights reserved.