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 .