Package org.springframework.amqp.core

Examples of org.springframework.amqp.core.MessageProperties

145
146
147
148
149
150
151
152
153
154
155
156
157
158
  @Override
  protected org.springframework.amqp.core.Message buildMessage(Channel channel, Object result) throws Exception {
    MessageConverter converter = getMessageConverter();
    if (converter != null && !(result instanceof org.springframework.amqp.core.Message)) {
      if (result instanceof org.springframework.messaging.Message) {
        return this.messagingMessageConverter.toMessage(result, new MessageProperties());
      }
      else {
        return converter.toMessage(result, new MessageProperties());
      }
    }
    else {
      if (!(result instanceof org.springframework.amqp.core.Message)) {
        throw new MessageConversionException("No MessageConverter specified - cannot handle message ["
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
   * @see #setMessageConverter
   */
  protected Message buildMessage(Channel channel, Object result) throws Exception {
    MessageConverter converter = getMessageConverter();
    if (converter != null && !(result instanceof Message)) {
      return converter.toMessage(result, new MessageProperties());
    }
    else {
      if (!(result instanceof Message)) {
        throw new MessageConversionException("No MessageConverter specified - cannot handle message ["
            + result + "]");
View Full Code Here
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
          if (reply != null) {
            Address replyTo = replyToAddressCallback.getReplyToAddress(receiveMessage, reply);

            Message replyMessage = RabbitTemplate.this.convertMessageIfNecessary(reply);

            MessageProperties receiveMessageProperties = receiveMessage.getMessageProperties();
            MessageProperties replyMessageProperties = replyMessage.getMessageProperties();

            Object correlation = RabbitTemplate.this.correlationKey == null
                ? receiveMessageProperties.getCorrelationId()
                : receiveMessageProperties.getHeaders().get(RabbitTemplate.this.correlationKey);

            if (RabbitTemplate.this.correlationKey == null || correlation == null) {
              // using standard correlationId property
              if (correlation == null) {
                String messageId = receiveMessageProperties.getMessageId();
                if (messageId != null) {
                  correlation = messageId.getBytes(RabbitTemplate.this.encoding);
                }
              }
              replyMessageProperties.setCorrelationId((byte[]) correlation);
            }
            else {
              replyMessageProperties.setHeader(RabbitTemplate.this.correlationKey, correlation);
            }

            // 'doSend()' takes care about 'channel.txCommit()'.
            RabbitTemplate.this.doSend(channel, replyTo.getExchangeName(), replyTo.getRoutingKey(), replyMessage, null);
          }
View Full Code Here
799
800
801
802
803
804
805
  protected Message convertMessageIfNecessary(final Object object) {
    if (object instanceof Message) {
      return (Message) object;
    }
    return getRequiredMessageConverter().toMessage(object, new MessageProperties());
  }
View Full Code Here
838
839
840
841
842
843
844
845
846
847
848
        DefaultConsumer consumer = new DefaultConsumer(channel) {

          @Override
          public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
                         byte[] body) throws IOException {
            MessageProperties messageProperties = messagePropertiesConverter.toMessageProperties(
                properties, envelope, encoding);
            Message reply = new Message(body, messageProperties);
            if (logger.isTraceEnabled()) {
              logger.trace("Message received " + reply);
            }
View Full Code Here
1002
1003
1004
1005
1006
1007
1008
1009
1010
1011
1012
1013
1014
      publisherCallbackChannel.addPendingConfirm(this, channel.getNextPublishSeqNo(),
          new PendingConfirm(correlationData, System.currentTimeMillis()));
    }
    boolean mandatory = this.returnCallback != null &&
        this.mandatoryExpression.getValue(this.evaluationContext, message, Boolean.class);
    MessageProperties messageProperties = message.getMessageProperties();
    if (mandatory) {
      messageProperties.getHeaders().put(PublisherCallbackChannel.RETURN_CORRELATION, this.uuid);
    }
    BasicProperties convertedMessageProperties = this.messagePropertiesConverter
        .fromMessageProperties(messageProperties, encoding);
    channel.basicPublish(exchange, routingKey, mandatory, convertedMessageProperties, message.getBody());
    // Check if commit needed
View Full Code Here
1030
1031
1032
1033
1034
1035
1036
1037
1038
1039
  protected boolean isChannelLocallyTransacted(Channel channel) {
    return isChannelTransacted() && !ConnectionFactoryUtils.isChannelTransactional(channel, getConnectionFactory());
  }

  private Message buildMessageFromResponse(GetResponse response) {
    MessageProperties messageProps = this.messagePropertiesConverter.toMessageProperties(
        response.getProps(), response.getEnvelope(), this.encoding);
    messageProps.setMessageCount(response.getMessageCount());
    return new Message(response.getBody(), messageProps);
  }
View Full Code Here
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
1134
        logger.warn("Returned message but no callback available");
      }
    }
    else {
      properties.getHeaders().remove(PublisherCallbackChannel.RETURN_CORRELATION);
      MessageProperties messageProperties = messagePropertiesConverter.toMessageProperties(
          properties, null, this.encoding);
      Message returnedMessage = new Message(body, messageProperties);
      this.returnCallback.returnedMessage(returnedMessage,
          replyCode, replyText, exchange, routingKey);
    }
View Full Code Here
44
45
46
47
48
49
50
51
52
53
54
  }

  public final Message toMessage(Object object, MessageProperties messageProperties)
      throws MessageConversionException {
    if (messageProperties==null) {
      messageProperties = new MessageProperties();
    }
    Message message = createMessage(object, messageProperties);
    messageProperties = message.getMessageProperties();
    if (this.createMessageIds && messageProperties.getMessageId()==null) {
      messageProperties.setMessageId(UUID.randomUUID().toString());
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
   * Converts from a AMQP Message to an Object.
   */
  @Override
  public Object fromMessage(Message message) throws MessageConversionException {
    Object content = null;
    MessageProperties properties = message.getMessageProperties();
    if (properties != null) {
      String contentType = properties.getContentType();
      if (contentType != null && contentType.startsWith("text") && !ignoreContentType) {
        String encoding = properties.getContentEncoding();
        if (encoding == null) {
          encoding = this.defaultCharset;
        }
        try {
          content = new String(message.getBody(), encoding);
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.