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

  }


  @Override
  protected void handleMessageInternal(Message<?> message) {


    MessageHeaders headers = message.getHeaders();
    SimpMessageType messageType = SimpMessageHeaderAccessor.getMessageType(headers);
    String destination = SimpMessageHeaderAccessor.getDestination(headers);
    String sessionId = SimpMessageHeaderAccessor.getSessionId(headers);


    if (!checkDestinationPrefix(destination)) {

View Full Code Here


  @Test
  public void toMessageHeadersCopied() {
    Map<String, Object> map = new HashMap<String, Object>();
    map.put("foo", "bar");
    MessageHeaders headers = new MessageHeaders(map );
    Message<?> message = this.converter.toMessage("ABC", headers);


    assertEquals("bar", message.getHeaders().get("foo"));
  }

View Full Code Here


  @Test
  public void toMessageWithHeaders() {
    Map<String, Object> map = new HashMap<String, Object>();
    map.put("foo", "bar");
    MessageHeaders headers = new MessageHeaders(map);
    Message<?> message = this.converter.toMessage("ABC", headers);


    assertNotNull(message.getHeaders().getId());
    assertNotNull(message.getHeaders().getTimestamp());
    assertEquals(MimeTypeUtils.TEXT_PLAIN, message.getHeaders().get(MessageHeaders.CONTENT_TYPE));

View Full Code Here

    SimpMessageHeaderAccessor accessor = SimpMessageHeaderAccessor.create(SimpMessageType.MESSAGE);
    accessor.setHeader("foo", "bar");
    accessor.setNativeHeader("fooNative", "barNative");
    accessor.setLeaveMutable(true);


    MessageHeaders headers = accessor.getMessageHeaders();
    Message<?> message = this.converter.toMessage("ABC", headers);


    assertSame(headers, message.getHeaders());
    assertNull(message.getHeaders().getId());
    assertNull(message.getHeaders().getTimestamp());

View Full Code Here


  @Test
  public void resolve() {
    Map<String, Object> map = new HashMap<String, Object>();
    map.put(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON);
    MessageHeaders headers = new MessageHeaders(map);


    assertEquals(MimeTypeUtils.APPLICATION_JSON, this.resolver.resolve(headers));
  }

View Full Code Here


  @Test
  public void resolveStringContentType() {
    Map<String, Object> map = new HashMap<String, Object>();
    map.put(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON_VALUE);
    MessageHeaders headers = new MessageHeaders(map);


    assertEquals(MimeTypeUtils.APPLICATION_JSON, this.resolver.resolve(headers));
  }

View Full Code Here


  @Test(expected = InvalidMimeTypeException.class)
  public void resolveInvalidStringContentType() {
    Map<String, Object> map = new HashMap<String, Object>();
    map.put(MessageHeaders.CONTENT_TYPE, "invalidContentType");
    MessageHeaders headers = new MessageHeaders(map);
    this.resolver.resolve(headers);
  }

View Full Code Here


  @Test(expected = IllegalArgumentException.class)
  public void resolveUnknownHeaderType() {
    Map<String, Object> map = new HashMap<String, Object>();
    map.put(MessageHeaders.CONTENT_TYPE, new Integer(1));
    MessageHeaders headers = new MessageHeaders(map);
    this.resolver.resolve(headers);
  }

View Full Code Here

    this.resolver.resolve(headers);
  }


  @Test
  public void resolveNoContentTypeHeader() {
    MessageHeaders headers = new MessageHeaders(Collections.<String, Object>emptyMap());


    assertNull(this.resolver.resolve(headers));
  }

View Full Code Here

  }


  @Test
  public void resolveDefaultMimeType() {
    this.resolver.setDefaultMimeType(MimeTypeUtils.APPLICATION_JSON);
    MessageHeaders headers = new MessageHeaders(Collections.<String, Object>emptyMap());


    assertEquals(MimeTypeUtils.APPLICATION_JSON, this.resolver.resolve(headers));
  }

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.