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

        this.repository = repository;
    }


    @Override
    public void onApplicationEvent(SessionConnectEvent event) {
        MessageHeaders headers = event.getMessage().getHeaders();
        Principal user = SimpMessageHeaderAccessor.getUser(headers);
        if(user == null) {
            return;
        }
        String id = SimpMessageHeaderAccessor.getSessionId(headers);

View Full Code Here

        when(wsSession2.getPrincipal()).thenReturn(principal);
        when(wsSession2.getId()).thenReturn("wsSession-id2");


        Map<String,Object> headers = new HashMap<>();
        headers.put(SimpMessageHeaderAccessor.SESSION_ATTRIBUTES, attributes);
        when(message.getHeaders()).thenReturn(new MessageHeaders(headers));


        listener = new WebSocketRegistryListener();
        connect = new SessionConnectEvent(listener,wsSession);
        connect2 = new SessionConnectEvent(listener,wsSession2);
        disconnect = new SessionDisconnectEvent(listener, message, wsSession.getId(), CloseStatus.NORMAL);

View Full Code Here

        this.mailSender = mailSender;
    }


    public void sendMessage(final Message<?> message) {
        //System.out.println("Message is:"+message.getPayload());
        final MessageHeaders messageHeaders = message.getHeaders();
        messageHeaders.get(MailHeaders.TO);
        final String content = message.getPayload().toString();


        MimeMessagePreparator preparator = new MimeMessagePreparator() {
            public void prepare(MimeMessage mimeMessage)
                    throws MessagingException {
                MimeMessageHelper message = new MimeMessageHelper(mimeMessage);
                message.setSubject("Some new subject");
                message.setTo(messageHeaders.get(MailHeaders.TO).toString().split(";"));
                message.setFrom(messageHeaders.get(MailHeaders.FROM).toString());
                message.setText(content, true);
            }
        };
        mailSender.send(preparator);
    }

View Full Code Here


    @Test
    public void testTransformation() throws Exception {
        transformerInputChannel.send(new Message<String>() {
            public MessageHeaders getHeaders() {
                return new MessageHeaders(new HashMap<String, Object>());
            }


            public String getPayload() {
                return "original www.xebia.com message http://www.xebia.com";
            }

View Full Code Here

    @Test
    public void testTweetLongUrl() throws Exception {


        bites.send(new Message<String>() {
            public MessageHeaders getHeaders() {
                return new MessageHeaders(new HashMap<String, Object>());
            }


            public String getPayload() {
                return "Url Message :"
                        + dateFormat.format(Calendar.getInstance().getTime())

View Full Code Here

        Assert.assertNotNull(this.twitterAdapter);




        this.twitterChannel.send(new Message<String>() {
            public MessageHeaders getHeaders() {
                return new MessageHeaders(new HashMap<String, Object>());
            }


            public String getPayload() {
                return "original www.xebia.com message http://www.xebia.com "+RandomStringUtils.randomAlphabetic(3);
            }

View Full Code Here

                    && !headerEntry.getKey().equals(com.consol.citrus.message.MessageHeaders.TIMESTAMP)) {
                integrationHeaders.put(headerEntry.getKey(), headerEntry.getValue());
            }
        }


        super.fromHeaders(new MessageHeaders(integrationHeaders), jmsMessage);
    }

View Full Code Here

    @Override
    public void convertOutbound(javax.jms.Message jmsMessage, Message message, JmsEndpointConfiguration endpointConfiguration) {
        Map<String, Object> headers = message.copyHeaders();


        if (headers != null) {
            endpointConfiguration.getHeaderMapper().fromHeaders(new MessageHeaders(headers), jmsMessage);
        }
    }

View Full Code Here

    catch (Exception e) {
      if (logger.isWarnEnabled()) {
        logger.warn("error occurred while mapping from AMQP properties to MessageHeaders", e);
      }
    }
    return new MessageHeaders(headers);
  }

View Full Code Here

    headerMap.put(AmqpHeaders.TIMESTAMP, testTimestamp);
    headerMap.put(AmqpHeaders.TYPE, "test.type");
    headerMap.put(AmqpHeaders.USER_ID, "test.userId");
    headerMap.put(AmqpHeaders.SPRING_REPLY_CORRELATION, "test.correlation");
    headerMap.put(AmqpHeaders.SPRING_REPLY_TO_STACK, "test.replyTo2");
    MessageHeaders messageHeaders = new MessageHeaders(headerMap);
    MessageProperties amqpProperties = new MessageProperties();
    headerMapper.fromHeaders(messageHeaders, amqpProperties);
    Set<String> headerKeys = amqpProperties.getHeaders().keySet();
    for (String headerKey : headerKeys) {
      if (headerKey.startsWith(AmqpHeaders.PREFIX)) {

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.