spring-integration-aws/src/main/java/org/springframework/integration/aws/sqs/core/SqsExecutor.java
public Object executeOutboundOperation(final Message<?> message) {

		try {
			String serializedMessage = messageMarshaller.serialize(message);
			if (queue == null) {
				SendMessageRequest request = new SendMessageRequest(queueUrl,
						serializedMessage);
				SendMessageResult result = sqsClient.sendMessage(request);
				log.debug("Message sent, Id:" + result.getMessageId());
			} else {
				queue.add(serializedMessage);
			}
		} catch (MessageMarshallerException e) {
			log.error(e.getMessage(), e);
			throw new MessagingException(e.getMessage(), e.getCause());
		}

		return message.getPayload();
	}
public Object executeOutboundOperation(final Message<?> message) {

		try {
			String serializedMessage = messageMarshaller.serialize(message);
			if (queue == null) {
				SendMessageRequest request = new SendMessageRequest(queueUrl,
						serializedMessage);
				SendMessageResult result = sqsClient.sendMessage(request);
				log.debug("Message sent, Id:" + result.getMessageId());
			} else {
				queue.add(serializedMessage);
			}
		} catch (MessageMarshallerException e) {
			log.error(e.getMessage(), e);
			throw new MessagingException(e.getMessage(), e.getCause());
		}

		return message.getPayload();
	}
public Object executeOutboundOperation ( final Message < ? > message ) { try { String serializedMessage = messageMarshaller . serialize ( message ) ; if ( queue == null ) { SendMessageRequest request = new SendMessageRequest ( queueUrl , serializedMessage ) ; SendMessageResult result = sqsClient . sendMessage ( request ) ; log . debug ( "Message sent, Id:" + result . getMessageId ( ) ) ; } else { queue . add ( serializedMessage ) ; } } catch ( MessageMarshallerException e ) { log . error ( e . getMessage ( ) , e ) ; throw new MessagingException ( e . getMessage ( ) , e . getCause ( ) ) ; } return message . getPayload ( ) ; }
Executes the outbound Sqs Operation.
Executes the outbound Sqs Operation .