Package org.springframework.amqp.core

Examples of org.springframework.amqp.core.MessageProperties

797
798
799
800
801
802
803
  protected Message convertMessageIfNecessary(final Object object) {
    if (object instanceof Message) {
      return (Message) object;
    }
    return getRequiredMessageConverter().toMessage(object,
        new MessageProperties());
  }
View Full Code Here
133
134
135
136
137
138
139
140
141
142
143
144
145
    }

    log.debug("Req-> Exchange:'" + exchange + "' RoutingKey:'" + routingKey
        + "' " + request);

    MessageProperties messageProperties = new MessageProperties();
    messageProperties.setExpiration(EXPIRATION_TIME);
    messageProperties.setCorrelationId(calculateCorrelationId(request)
        .getBytes());

    for (int numRequest = 0; numRequest < numRetries + 1; numRequest++) {

      if (numRequest > 0) {
View Full Code Here
189
190
191
192
193
194
195
    log.debug("Not-> Exchange:'" + exchange + "' RoutingKey:'" + routingKey
        + "' " + message);

    template.send(exchange, routingKey, new Message(message.getBytes(),
        new MessageProperties()));
  }
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
    public void testExchangePattern() throws Exception {
        org.apache.camel.Message camelMessage = new DefaultMessage();
        Exchange exchange = new DefaultExchange(new DefaultCamelContext(), ExchangePattern.InOut);
        exchange.setIn(camelMessage);
       
        MessageProperties properties = new MessageProperties();
        org.springframework.amqp.core.Message amqpMessage = new org.springframework.amqp.core.Message("Testing".getBytes(), properties);
       
        amqpMessage = new SpringAMQPMessage.HeadersPostProcessor(camelMessage).postProcessMessage(amqpMessage);
        ExchangePattern exchangePattern = SpringAMQPMessage.getExchangePattern(amqpMessage);
        Assert.assertEquals(exchange.getPattern(), exchangePattern);
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
43
   
    @Test
    public void fromAMQP() throws Exception {
        String body = "Test Message";
        MessageConverter msgConverter = new StringMessageConverter();
        MessageProperties properties = new MessageProperties();
        properties.setHeader("NotSecret", "Popcorn");
        org.springframework.amqp.core.Message message = new org.springframework.amqp.core.Message(body.getBytes(), properties);
       
        SpringAMQPMessage camelMessage = SpringAMQPMessage.fromAMQPMessage(msgConverter, message);
        Assert.assertEquals(body, camelMessage.getBody(String.class));
        Assert.assertEquals("Popcorn", camelMessage.getHeader("NotSecret"));
View Full Code Here
12
13
14
15
16
17
18
19
20
21
22
23
import org.springframework.amqp.core.MessageProperties;

public class SpringAMQPHeaderTest {
    @Test
    public void fromBasicProperties() throws Exception {
        MessageProperties properties = new MessageProperties();
        properties.setHeader("NotSecret", "Popcorn");
        org.springframework.amqp.core.Message message = new Message(new byte[]{}, properties);
        message.getMessageProperties().setPriority(1);
        message.getMessageProperties().setReplyTo("BuzzSaw");
       
        SpringAMQPMessage camelMessage = SpringAMQPHeader.setBasicPropertiesToHeaders(new SpringAMQPMessage(), message);
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
        camelMessage.setHeader(SpringAMQPHeader.REPLY_TO, "BuzzSaw");
       
        Exchange exchange = new DefaultExchange(new DefaultCamelContext());
        exchange.setIn(camelMessage);
       
        Message message = new Message(new byte[]{}, new MessageProperties());
        message = SpringAMQPHeader.setBasicPropertiesFromHeaders(message, camelMessage.getHeaders());
        Assert.assertNull(message.getMessageProperties().getHeaders().get("Secret"));
        Assert.assertEquals(Integer.valueOf(1), message.getMessageProperties().getPriority());
        Assert.assertEquals("BuzzSaw", message.getMessageProperties().getReplyTo());
    }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
        Assert.assertEquals("BuzzSaw", message.getMessageProperties().getReplyTo());
    }
   
    @Test
    public void copyAMQPHeaders() throws Exception {
        MessageProperties properties = new MessageProperties();
        properties.setHeader("NotSecret", "Popcorn");
        org.springframework.amqp.core.Message message = new Message(new byte[]{}, properties);
        message.getMessageProperties().setReplyTo("BuzzSaw");
       
        SpringAMQPMessage camelMessage = SpringAMQPHeader.copyHeaders(new SpringAMQPMessage(), message.getMessageProperties().getHeaders());
        Assert.assertEquals("Popcorn", camelMessage.getHeader("NotSecret"));
View Full Code Here
62
63
64
65
66
67
68
69
70
71
        camelMessage.setHeader(SpringAMQPHeader.REPLY_TO, "BuzzSaw");
       
        Exchange exchange = new DefaultExchange(new DefaultCamelContext());
        exchange.setIn(camelMessage);
       
        Message message = new Message(new byte[]{}, new MessageProperties());
        message = SpringAMQPHeader.copyHeaders(message, camelMessage.getHeaders());
        Assert.assertEquals("My Secret", message.getMessageProperties().getHeaders().get("Secret"));
        Assert.assertNull(message.getMessageProperties().getReplyTo());
    }
View Full Code Here
15
16
17
18
19
20
21
22
23
24
25
    @Test
    public void testConversion() throws Exception {
        TestObject testObject = new TestObject();
        testObject.setValue("TESTING");
       
        MessageProperties messageProperties = new MessageProperties();
       
        MessageConverter converter = new XStreamConverter();
        ((XStreamConverter) converter).setEncoding("UTF-8");
        Message amqpMessage = converter.toMessage(testObject, messageProperties);
        Assert.assertEquals("{\"amqp.spring.converter.XStreamConverterTest_-TestObject\":{\"value\":\"TESTING\"}}", new String(amqpMessage.getBody()));
View Full Code Here
TOP

Related Classes of org.springframework.amqp.core.MessageProperties

  • amqp.spring.camel.component.SpringAMQPHeaderTest
  • amqp.spring.camel.component.SpringAMQPMessage
  • amqp.spring.camel.component.SpringAMQPMessageTest
  • amqp.spring.converter.ContentTypeConverterFactory
  • amqp.spring.converter.ContentTypeConverterFactoryTest
  • amqp.spring.converter.StringConverter
  • amqp.spring.converter.StringConverterTest
  • amqp.spring.converter.XStreamConverter
  • amqp.spring.converter.XStreamConverterTest
  • com.jbrisbin.groovy.mqdsl.RabbitMQBuilder$Publish
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.