nevado-jms/src/main/java/org/skyscreamer/nevado/jms/connector/AbstractSQSConnector.java
/**
     * Deserializes the body of an SQS message into a NevadoMessage object.
     *
     * @param serializedMessage String-serialized NevadoMessage
     * @return A deserialized NevadoMessage object
     * @throws JMSException Unable to deserializeFromString a single NevadoMessage object from the source
     */
Deserializes the body of an SQS message into a NevadoMessage object.
@param serializedMessage String-serialized NevadoMessage
@return A deserialized NevadoMessage object
@throws JMSException Unable to deserializeFromString a single NevadoMessage object from the source
Deserializes the body of an SQS message into a NevadoMessage object . @param serializedMessage String - serialized NevadoMessage @return A deserialized NevadoMessage object @throws JMSException Unable to deserializeFromString a single NevadoMessage object from the source
protected NevadoMessage deserializeMessage(String serializedMessage) throws JMSException {
        Serializable deserializedObject;
        try {
            deserializedObject = SerializeUtil.deserializeFromString(serializedMessage);
        } catch (IOException e) {
            String exMessage = "Unable to deserialized message: " + e.getMessage();
            _log.error(exMessage, e);
            throw new JMSException(exMessage);
        }
        if (deserializedObject == null) {
            throw new JMSException("Deserialized object is null");
        }
        if (!(deserializedObject instanceof NevadoMessage)) {
            throw new JMSException("Expected object of type NevadoMessage, got: "
                    + deserializedObject.getClass().getName());
        }
        return (NevadoMessage)deserializedObject;
    }
protected NevadoMessage deserializeMessage ( String serializedMessage ) throws JMSException { Serializable deserializedObject ; try { deserializedObject = SerializeUtil . deserializeFromString ( serializedMessage ) ; } catch ( IOException e ) { String exMessage = "Unable to deserialized message: " + e . getMessage ( ) ; _log . error ( exMessage , e ) ; throw new JMSException ( exMessage ) ; } if ( deserializedObject == null ) { throw new JMSException ( "Deserialized object is null" ) ; } if ( ! ( deserializedObject instanceof NevadoMessage ) ) { throw new JMSException ( "Expected object of type NevadoMessage, got: " + deserializedObject . getClass ( ) . getName ( ) ) ; } return ( NevadoMessage ) deserializedObject ; }
Deserializes the body of an SQS message into a NevadoMessage object.
Deserializes the body of an SQS message into a NevadoMessage object .