@Override
    public Message toMessage(Session session) throws JMSException {
        Message message = session.createMessage();
        setMessageProperties(message);
        message.setJMSType(TYPE);
        return message;
    }