Examples of org.springframework.messaging.MessageHeaders

org.springframework.messaging.MessageHeaders
The headers for a {@link Message}.
IMPORTANT: This class is immutable. Any mutating operation such as {@code put(..)}, {@code putAll(..)} and others will throw{@link UnsupportedOperationException}.
Subclasses do have access to the raw headers, however, via {@link #getRawHeaders()}.
One way to create message headers is to use the {@link org.springframework.messaging.support.MessageBuilder MessageBuilder}:
```
 MessageBuilder.withPayload("foo").setHeader("key1", "value1").setHeader("key2", "value2"); 
```
A second option is to create {@link org.springframework.messaging.support.GenericMessage}passing a payload as {@link Object} and headers as a {@link Map java.util.Map}:
```
 Map headers = new HashMap(); headers.put("key1", "value1"); headers.put("key2", "value2"); new GenericMessage("foo", headers); 
```
A third option is to use {@link org.springframework.messaging.support.MessageHeaderAccessor}or one of its subclasses to create specific categories of headers. @author Arjen Poutsma @author Mark Fisher @author Gary Russell @since 4.0 @see org.springframework.messaging.support.MessageBuilder @see org.springframework.messaging.support.MessageHeaderAccessor

  }


  @Test
  public void testBuildMessageWithDefaultMutability() {
    MessageHeaderAccessor accessor = new MessageHeaderAccessor();
    MessageHeaders headers = accessor.getMessageHeaders();
    Message<?> message = MessageBuilder.createMessage("foo", headers);


    this.thrown.expect(IllegalStateException.class);
    this.thrown.expectMessage("Already immutable");
    accessor.setHeader("foo", "bar");

View Full Code Here

  public void convertAndSendWithMutableSimpMessageHeaders() {
    SimpMessageHeaderAccessor accessor = SimpMessageHeaderAccessor.create();
    accessor.setHeader("key", "value");
    accessor.setNativeHeader("fooNative", "barNative");
    accessor.setLeaveMutable(true);
    MessageHeaders headers = accessor.getMessageHeaders();


    this.messagingTemplate.convertAndSend("/foo", "data", headers);


    List<Message<byte[]>> messages = this.messageChannel.getMessages();
    Message<byte[]> message = messages.get(0);

View Full Code Here

  public void doSendWithMutableHeaders() {
    SimpMessageHeaderAccessor accessor = SimpMessageHeaderAccessor.create();
    accessor.setHeader("key", "value");
    accessor.setNativeHeader("fooNative", "barNative");
    accessor.setLeaveMutable(true);
    MessageHeaders headers = accessor.getMessageHeaders();
    Message<?> message = MessageBuilder.createMessage("payload", headers);


    this.messagingTemplate.doSend("/topic/foo", message);


    List<Message<byte[]>> messages = this.messageChannel.getMessages();

View Full Code Here

    map.put("foo", "bar");
    map.put("bar", "baz");
    GenericMessage<String> message = new GenericMessage<>("payload", map);


    MessageHeaderAccessor accessor = new MessageHeaderAccessor(message);
    MessageHeaders actual = accessor.getMessageHeaders();


    assertEquals(3, actual.size());
    assertEquals("bar", actual.get("foo"));
    assertEquals("baz", actual.get("bar"));
  }

View Full Code Here


    Thread.sleep(50);


    MessageHeaderAccessor accessor = new MessageHeaderAccessor(message);
    accessor.setHeader("foo", "BAR");
    MessageHeaders actual = accessor.getMessageHeaders();


    assertEquals(3, actual.size());
    assertNotEquals(message.getHeaders().getId(), actual.getId());
    assertEquals("BAR", actual.get("foo"));
    assertEquals("baz", actual.get("bar"));
  }

View Full Code Here

  @Test
  public void leaveMutable() {
    MessageHeaderAccessor accessor = new MessageHeaderAccessor();
    accessor.setHeader("foo", "bar");
    accessor.setLeaveMutable(true);
    MessageHeaders headers = accessor.getMessageHeaders();
    Message<?> message = MessageBuilder.createMessage("payload", headers);


    accessor.setHeader("foo", "baz");


    assertEquals("baz", headers.get("foo"));
    assertSame(accessor, MessageHeaderAccessor.getAccessor(message, MessageHeaderAccessor.class));
  }

View Full Code Here


  @Test
  public void leaveMutableDefaultBehavior() {
    MessageHeaderAccessor accessor = new MessageHeaderAccessor();
    accessor.setHeader("foo", "bar");
    MessageHeaders headers = accessor.getMessageHeaders();
    Message<?> message = MessageBuilder.createMessage("payload", headers);


    this.thrown.expect(IllegalStateException.class);
    this.thrown.expectMessage("Already immutable");
    accessor.setLeaveMutable(true);


    this.thrown.expect(IllegalStateException.class);
    this.thrown.expectMessage("Already immutable");
    accessor.setHeader("foo", "baz");


    assertEquals("bar", headers.get("foo"));
    assertSame(accessor, MessageHeaderAccessor.getAccessor(message, MessageHeaderAccessor.class));
  }

View Full Code Here

        return MessageHeaders.ID_VALUE_NONE;
      }
    });
    accessor.setEnableTimestamp(false);
    accessor.setLeaveMutable(true);
    MessageHeaders headers = accessor.getMessageHeaders();


    assertNull(headers.getId());
    assertNull(headers.getTimestamp());


    final UUID id = new UUID(0L, 23L);
    accessor.setIdGenerator(new IdGenerator() {
      @Override
      public UUID generateId() {
        return id;
      }
    });
    accessor.setEnableTimestamp(true);
    accessor.setImmutable();


    assertSame(id, accessor.getMessageHeaders().getId());
    assertNotNull(headers.getTimestamp());
  }

View Full Code Here

   * <p>This method can be invoked many times, with modifications in between
   * where each new call returns a fresh copy of the current header values.
   * @since 4.1
   */
  public MessageHeaders toMessageHeaders() {
    return new MessageHeaders(this.headers);
  }

View Full Code Here

  /**
   * Create a new message with the given payload.
   * @param payload the message payload (never {@code null})
   */
  public GenericMessage(T payload) {
    this(payload, new MessageHeaders(null));
  }

View Full Code Here

0 1 2 3 4 5 6

TOP

Related Classes of org.springframework.messaging.MessageHeaders

com.consol.citrus.channel.selector.HeaderMatchingMessageSelector

com.consol.citrus.jms.message.JmsMessageConverter

com.consol.citrus.jms.message.JmsMessageHeaderMapper

com.springsource.insight.plugin.integration.IntegrationOperationCollectionAspectTest

org.encuestame.core.integration.MailSenderActivator

org.encuestame.core.test.integration.GatewayTestCase

org.encuestame.core.test.integration.IntegrationTestCase

org.springframework.amqp.support.SimpleAmqpHeaderMapper

org.springframework.amqp.support.SimpleAmqpHeaderMapperTests

org.springframework.batch.integration.launch.JobLaunchingGatewayIntegrationTests

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.