...
Some of the Channels supported by UCS may be considered "bulk" channels. A bulk channel is a channel that supports multiple recipients of the same message at the same time. An example of this type of channels is a Group Chat. As a general rule, when a Message is delivered through a bulk channel, the "[RECIPIENT-ID]" key is disregarded by UCS.
Design
In the current implementation, Message's "parts" attribute is used in the following processors:
- UCSPreprateChat -> uses parts[0] as the content of the chat message.
- UCSPrepareSMS -> uses parts[0] as the content of the SMS.
- UCSPrepareTextToVoide -> uses parts[0] as the message.
- UCSRouteMessageOnContext -> evaluates a regex against parts[0] and route the FlowFile accordingly.
- UCSConvertChatResponseToMessage -> uses parts[0] to store the conent of the incoming chat message.
- UCSConvertSMSResponseToMessage -> uses parts[0] to store the conent of the incoming SMS message.
For the first 3 cases (UCSPreprateChat, UCSPrepareSMS and UCSPrepareTextToVoide)we need to modify the processors to evaluate which part of a MessageBody needs to be used. Given that the required functionality is the same in the 3 procesors, we can extract this logic into a helper class: MessageBodyResolver.
The case of UCSRouteMessageOnContext is different. For this processor, the index of the part that should be used to evaluate the regex must be part of the processor configuration. A new property has to be added to this processor to allow the index to be configured. The default value of this new property should be '0'. The property should only allow positive integers (including 0) and it should also support expression language.
For the last 2 processors (UCSConvertChatResponseToMessage and UCSConvertSMSResponseToMessage), we assume that it is correct to use parts[0] to store the message. These 2 processors shouldn't be modified.
MessageBodyResolver class
A new class with the name of MessageBodyResolver must be implemented. This class will contain the required logic to determine which part of a Message should be used by a processor given a context. The context required by this resolution is the service Id, the recipient id and the recipient address being processed. Note that in some situations, some ( or all) of the context's pieces could be missing.
The logic required by this class is described in the analysis section of this document.
The proposed interface for MessageBodyResolver is:
public class MessageBodyResolver { public static MessageBody resolveMessagePart(Message message, String serviceId, String recipientId, String recipientAddress);}UCSPrepareChat invocation context
In UCSPrepareChat processor, the following resolution context information is available:
- serviceId: value of SERVICE_ID property
- recipientId: N/A
- recipientAddress: N/A
UCSPrepareSMS invocation context
In UCSPrepareSMS processor, the following resolution context information is available:
- serviceId: value of SMS_SERVICE_ID property
- recipientId: the id of each individual recipient
- recipientAddress: the PhisycalAddress.address of each individual recipient.