SmsReceiveJob.java 文件源码

private Optional<IncomingTextMessage> assembleMessageFragments(Object[] pdus) {
  List<IncomingTextMessage> messages = new LinkedList<>();

  for (Object pdu : pdus) {
    messages.add(new IncomingTextMessage(SmsMessage.createFromPdu((byte[])pdu)));
  }

  if (messages.isEmpty()) {
    return Optional.absent();
  }

  IncomingTextMessage message =  new IncomingTextMessage(messages);

  if (WirePrefix.isEncryptedMessage(message.getMessageBody()) ||
      WirePrefix.isKeyExchange(message.getMessageBody())      ||
      WirePrefix.isPreKeyBundle(message.getMessageBody())     ||
      WirePrefix.isEndSession(message.getMessageBody()))
  {
    return Optional.fromNullable(multipartMessageHandler.processPotentialMultipartMessage(message));
  } else {
    return Optional.of(message);
  }
}