本文整理了Java中org.springframework.messaging.Message类的一些代码示例，展示了Message类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message类的具体详情如下：
包路径：org.springframework.messaging.Message
类名称：Message

Message介绍

[英]A generic message representation with headers and body.
[中]带有标题和正文的通用消息表示。

代码示例

代码示例来源：origin: spring-projects/spring-framework

private MessageBuilder(Message<T> originalMessage) {
  Assert.notNull(originalMessage, "Message must not be null");
  this.payload = originalMessage.getPayload();
  this.originalMessage = originalMessage;
  this.headerAccessor = new MessageHeaderAccessor(originalMessage);
}

代码示例来源：origin: spring-projects/spring-framework

private void sendInternal(Message<?> message) {
  String destination = SimpMessageHeaderAccessor.getDestination(message.getHeaders());
  Assert.notNull(destination, "Destination header required");
  long timeout = this.sendTimeout;
  boolean sent = (timeout >= 0 ? this.messageChannel.send(message, timeout) : this.messageChannel.send(message));
  if (!sent) {
    throw new MessageDeliveryException(message,
        "Failed to send message to destination '" + destination + "' within timeout: " + timeout);
  }
}

代码示例来源：origin: spring-projects/spring-framework

/**
 * Encodes the given STOMP {@code message} into a {@code byte[]}.
 * @param message the message to encode
 * @return the encoded message
 */
public byte[] encode(Message<byte[]> message) {
  return encode(message.getHeaders(), message.getPayload());
}

代码示例来源：origin: spring-projects/spring-framework

@Override
protected Object convertFromInternal(Message<?> message, Class<?> targetClass, @Nullable Object conversionHint) {
  Charset charset = getContentTypeCharset(getMimeType(message.getHeaders()));
  Object payload = message.getPayload();
  return (payload instanceof String ? payload : new String((byte[]) payload, charset));
}

代码示例来源：origin: spring-projects/spring-framework

@Nullable
public Message<?> preHandle(Message<?> message) throws MessagingException {
  String destination = SimpMessageHeaderAccessor.getDestination(message.getHeaders());
  if (!getBroadcastDestination().equals(destination)) {
    return message;
  }
  SimpMessageHeaderAccessor accessor =
      SimpMessageHeaderAccessor.getAccessor(message, SimpMessageHeaderAccessor.class);
  Assert.state(accessor != null, "No SimpMessageHeaderAccessor");
  if (accessor.getSessionId() == null) {
    // Our own broadcast
    return null;
  }
  destination = accessor.getFirstNativeHeader(SimpMessageHeaderAccessor.ORIGINAL_DESTINATION);
  if (logger.isTraceEnabled()) {
    logger.trace("Checking unresolved user destination: " + destination);
  }
  SimpMessageHeaderAccessor newAccessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
  for (String name : accessor.toNativeHeaderMap().keySet()) {
    if (NO_COPY_LIST.contains(name)) {
      continue;
    }
    newAccessor.setNativeHeader(name, accessor.getFirstNativeHeader(name));
  }
  if (destination != null) {
    newAccessor.setDestination(destination);
  }
  newAccessor.setHeader(SimpMessageHeaderAccessor.IGNORE_ERROR, true); // ensure send doesn't block
  return MessageBuilder.createMessage(message.getPayload(), newAccessor.getMessageHeaders());
}

代码示例来源：origin: spring-projects/spring-integration

protected void doAddMessage(Message<?> message) {
  Assert.notNull(message, "'message' must not be null");
  UUID messageId = message.getHeaders().getId();
  Assert.notNull(messageId, "Cannot store messages without an ID header");
  doStoreIfAbsent(this.messagePrefix + messageId, new MessageHolder(message));
}

代码示例来源：origin: spring-projects/spring-framework

@Override
@Nullable
public Message<byte[]> handleErrorMessageToClient(Message<byte[]> errorMessage) {
  StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(errorMessage, StompHeaderAccessor.class);
  Assert.notNull(accessor, "No StompHeaderAccessor");
  if (!accessor.isMutable()) {
    accessor = StompHeaderAccessor.wrap(errorMessage);
  }
  return handleInternal(accessor, errorMessage.getPayload(), null, null);
}

代码示例来源：origin: spring-projects/spring-framework

@Override
@Nullable
protected Object convertFromInternal(Message<?> message, Class<?> targetClass, @Nullable Object conversionHint) {
  Assert.notNull(this.unmarshaller, "Property 'unmarshaller' is required");
  try {
    Source source = getSource(message.getPayload());
    Object result = this.unmarshaller.unmarshal(source);
    if (!targetClass.isInstance(result)) {
      throw new TypeMismatchException(result, targetClass);
    }
    return result;
  }
  catch (Exception ex) {
    throw new MessageConversionException(message, "Could not unmarshal XML: " + ex.getMessage(), ex);
  }
}

代码示例来源：origin: spring-projects/spring-batch

/**
 * Launches a Batch Job using the provided request {@link Message}. The payload
 * of the {@link Message} <em>must</em> be an instance of {@link JobLaunchRequest}.
 *
 * @param requestMessage must not be null.
 * @return Generally a {@link JobExecution} will always be returned. An
 * exception ({@link MessageHandlingException}) will only be thrown if there
 * is a failure to start the job. The cause of the exception will be a
 * {@link JobExecutionException}.
 *
 * @throws MessageHandlingException when a job cannot be launched
 */
@Override
protected Object handleRequestMessage(Message<?> requestMessage) {
  Assert.notNull(requestMessage, "The provided requestMessage must not be null.");
  final Object payload = requestMessage.getPayload();
  Assert.isInstanceOf(JobLaunchRequest.class, payload, "The payload must be of type JobLaunchRequest.");
  final JobLaunchRequest jobLaunchRequest = (JobLaunchRequest) payload;
  final JobExecution jobExecution;
  try {
    jobExecution = this.jobLaunchingMessageHandler.launch(jobLaunchRequest);
  } catch (JobExecutionException e) {
    throw new MessageHandlingException(requestMessage, e);
  }
  return jobExecution;
}

代码示例来源：origin: spring-projects/spring-framework

/**
 * Extract the SiMP session attributes from the given message and
 * wrap them in a {@link SimpAttributes} instance.
 * @param message the message to extract session attributes from
 */
public static SimpAttributes fromMessage(Message<?> message) {
  Assert.notNull(message, "Message must not be null");
  MessageHeaders headers = message.getHeaders();
  String sessionId = SimpMessageHeaderAccessor.getSessionId(headers);
  Map<String, Object> sessionAttributes = SimpMessageHeaderAccessor.getSessionAttributes(headers);
  if (sessionId == null) {
    throw new IllegalStateException("No session id in " + message);
  }
  if (sessionAttributes == null) {
    throw new IllegalStateException("No session attributes in " + message);
  }
  return new SimpAttributes(sessionId, sessionAttributes);
}

代码示例来源：origin: spring-projects/spring-framework

@Override
protected void doSend(String destination, Message<?> message) {
  Assert.notNull(destination, "Destination must not be null");
  SimpMessageHeaderAccessor simpAccessor =
      MessageHeaderAccessor.getAccessor(message, SimpMessageHeaderAccessor.class);
  if (simpAccessor != null) {
    if (simpAccessor.isMutable()) {
      simpAccessor.setDestination(destination);
      simpAccessor.setMessageTypeIfNotSet(SimpMessageType.MESSAGE);
      simpAccessor.setImmutable();
      sendInternal(message);
      return;
    }
    else {
      // Try and keep the original accessor type
      simpAccessor = (SimpMessageHeaderAccessor) MessageHeaderAccessor.getMutableAccessor(message);
      initHeaders(simpAccessor);
    }
  }
  else {
    simpAccessor = SimpMessageHeaderAccessor.wrap(message);
    initHeaders(simpAccessor);
  }
  simpAccessor.setDestination(destination);
  simpAccessor.setMessageTypeIfNotSet(SimpMessageType.MESSAGE);
  message = MessageBuilder.createMessage(message.getPayload(), simpAccessor.getMessageHeaders());
  sendInternal(message);
}

代码示例来源：origin: spring-projects/spring-framework

protected final void doSend(MessageChannel channel, Message<?> message, long timeout) {
  Assert.notNull(channel, "MessageChannel is required");
  Message<?> messageToSend = message;
  MessageHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, MessageHeaderAccessor.class);
  if (accessor != null && accessor.isMutable()) {
    accessor.removeHeader(this.sendTimeoutHeader);
    accessor.removeHeader(this.receiveTimeoutHeader);
    accessor.setImmutable();
  }
  else if (message.getHeaders().containsKey(this.sendTimeoutHeader)
      || message.getHeaders().containsKey(this.receiveTimeoutHeader)) {
    messageToSend = MessageBuilder.fromMessage(message)
        .setHeader(this.sendTimeoutHeader, null)
        .setHeader(this.receiveTimeoutHeader, null)
        .build();
  }
  boolean sent = (timeout >= 0 ? channel.send(messageToSend, timeout) : channel.send(messageToSend));
  if (!sent) {
    throw new MessageDeliveryException(message,
        "Failed to send message to channel '" + channel + "' within timeout: " + timeout);
  }
}

代码示例来源：origin: spring-projects/spring-framework

@Override
@Nullable
protected final Message<?> doSendAndReceive(MessageChannel channel, Message<?> requestMessage) {
  Assert.notNull(channel, "'channel' is required");
  Object originalReplyChannelHeader = requestMessage.getHeaders().getReplyChannel();
  Object originalErrorChannelHeader = requestMessage.getHeaders().getErrorChannel();
  long sendTimeout = sendTimeout(requestMessage);
  long receiveTimeout = receiveTimeout(requestMessage);
  TemporaryReplyChannel tempReplyChannel = new TemporaryReplyChannel(this.throwExceptionOnLateReply);
  requestMessage = MessageBuilder.fromMessage(requestMessage).setReplyChannel(tempReplyChannel)
      .setHeader(this.sendTimeoutHeader, null)
      .setHeader(this.receiveTimeoutHeader, null)
      .setErrorChannel(tempReplyChannel).build();
  try {
    doSend(channel, requestMessage, sendTimeout);
  }
  catch (RuntimeException ex) {
    tempReplyChannel.setSendFailed(true);
    throw ex;
  }
  Message<?> replyMessage = this.doReceive(tempReplyChannel, receiveTimeout);
  if (replyMessage != null) {
    replyMessage = MessageBuilder.fromMessage(replyMessage)
        .setHeader(MessageHeaders.REPLY_CHANNEL, originalReplyChannelHeader)
        .setHeader(MessageHeaders.ERROR_CHANNEL, originalErrorChannelHeader)
        .build();
  }
  return replyMessage;
}

代码示例来源：origin: spring-projects/spring-framework

public WebSocketMessage<?> encode(Message<byte[]> message, Class<? extends WebSocketSession> sessionType) {
    StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);
    Assert.notNull(accessor, "No StompHeaderAccessor available");
    byte[] payload = message.getPayload();
    byte[] bytes = ENCODER.encode(accessor.getMessageHeaders(), payload);
    boolean useBinary = (payload.length > 0  &&
        !(SockJsSession.class.isAssignableFrom(sessionType)) &&
        MimeTypeUtils.APPLICATION_OCTET_STREAM.isCompatibleWith(accessor.getContentType()));
    return (useBinary ? new BinaryMessage(bytes) : new TextMessage(bytes));
  }
}

代码示例来源：origin: spring-projects/spring-framework

private void assertTextMessage(Message<?> message) {
  assertNotNull("message should not be null", message);
  assertEquals("Wrong payload", "Hello", message.getPayload());
  assertEquals("Invalid foo property", "bar", message.getHeaders().get("foo"));
}

代码示例来源：origin: spring-projects/spring-framework

private void execute(Message<byte[]> message) {
  if (logger.isTraceEnabled()) {
    StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);
    if (accessor != null) {
      logger.trace("Sending " + accessor.getDetailedLogMessage(message.getPayload()));
    }
  }
  TcpConnection<byte[]> conn = this.connection;
  Assert.state(conn != null, "Connection closed");
  try {
    conn.send(message).get();
  }
  catch (ExecutionException ex) {
    throw new MessageDeliveryException(message, ex.getCause());
  }
  catch (Throwable ex) {
    throw new MessageDeliveryException(message, ex);
  }
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public TypedValue read(EvaluationContext context, @Nullable Object target, String name) {
  Object value;
  if (target instanceof Message) {
    value = name.equals("headers") ? ((Message) target).getHeaders() : null;
  }
  else if (target instanceof MessageHeaders) {
    MessageHeaders headers = (MessageHeaders) target;
    SimpMessageHeaderAccessor accessor =
        MessageHeaderAccessor.getAccessor(headers, SimpMessageHeaderAccessor.class);
    Assert.state(accessor != null, "No SimpMessageHeaderAccessor");
    if ("destination".equalsIgnoreCase(name)) {
      value = accessor.getDestination();
    }
    else {
      value = accessor.getFirstNativeHeader(name);
      if (value == null) {
        value = headers.get(name);
      }
    }
  }
  else {
    // Should never happen...
    throw new IllegalStateException("Expected Message or MessageHeaders.");
  }
  return new TypedValue(value);
}

代码示例来源：origin: spring-projects/spring-framework

@Override
  public void afterMessageHandled(
      Message<?> msg, MessageChannel ch, MessageHandler handler, @Nullable Exception ex) {
    Runnable task = (Runnable) msg.getHeaders().get(OrderedMessageSender.COMPLETION_TASK_HEADER);
    if (task != null) {
      task.run();
    }
  }
}

代码示例来源：origin: spring-projects/spring-framework

@Override
@Nullable
protected Object convertFromInternal(
    Message<?> message, @Nullable Class<?> targetClass, @Nullable Object conversionHint) {
  return message.getPayload();
}

代码示例来源：origin: spring-projects/spring-framework

private void handleError(WebSocketSession session, Throwable ex, @Nullable Message<byte[]> clientMessage) {
  if (getErrorHandler() == null) {
    sendErrorMessage(session, ex);
    return;
  }
  Message<byte[]> message = getErrorHandler().handleClientMessageProcessingError(clientMessage, ex);
  if (message == null) {
    return;
  }
  StompHeaderAccessor accessor = MessageHeaderAccessor.getAccessor(message, StompHeaderAccessor.class);
  Assert.state(accessor != null, "No StompHeaderAccessor");
  sendToClient(session, accessor, message.getPayload());
}