Examples of toMessage()


Examples of org.springframework.amqp.support.converter.MessageConverter.toMessage()

       
        MessageProperties messageProperties = new MessageProperties();
       
        MessageConverter converter = new XStreamConverter();
        ((XStreamConverter) converter).setEncoding("UTF-8");
        Message amqpMessage = converter.toMessage(testObject, messageProperties);
        Assert.assertEquals("{\"amqp.spring.converter.XStreamConverterTest_-TestObject\":{\"value\":\"TESTING\"}}", new String(amqpMessage.getBody()));

        Object newObject = converter.fromMessage(amqpMessage);
        Assert.assertEquals(testObject, newObject);
        Assert.assertEquals("UTF-8", ((XStreamConverter) converter).getEncoding());
View Full Code Here

Examples of org.springframework.amqp.support.converter.MessageConverter.toMessage()

        testObject.setValue("TESTING");
       
        MessageProperties messageProperties = new MessageProperties();
       
        MessageConverter converter = new StringConverter();
        Message amqpMessage = converter.toMessage(testObject, messageProperties);
        Object newObject = converter.fromMessage(amqpMessage);
       
        Assert.assertEquals("TESTING", newObject);
    }
   
View Full Code Here

Examples of org.springframework.jms.support.converter.MessageConverter.toMessage()

   * @see #setMessageConverter
   */
  protected Message buildMessage(Session session, Object result) throws JMSException {
    MessageConverter converter = getMessageConverter();
    if (converter != null) {
      return converter.toMessage(result, session);
    }
    else {
      if (!(result instanceof Message)) {
        throw new MessageConversionException(
            "No MessageConverter specified - cannot handle message [" + result + "]");
View Full Code Here

Examples of org.springframework.jms.support.converter.MessageConverter.toMessage()

   * @see #setMessageConverter
   */
  protected Message buildMessage(Session session, Object result) throws JMSException {
    MessageConverter converter = getMessageConverter();
    if (converter != null) {
      return converter.toMessage(result, session);
    }
    else {
      if (!(result instanceof Message)) {
        throw new MessageConversionException(
            "No MessageConverter specified - cannot handle message [" + result + "]");
View Full Code Here

Examples of org.springframework.jms.support.converter.MessageConverter.toMessage()

   * @see #setMessageConverter
   */
  protected Message buildMessage(Session session, Object result) throws JMSException {
    MessageConverter converter = getMessageConverter();
    if (converter != null) {
      return converter.toMessage(result, session);
    }
    else {
      if (!(result instanceof Message)) {
        throw new MessageConversionException(
            "No MessageConverter specified - cannot handle message [" + result + "]");
View Full Code Here

Examples of org.springframework.jms.support.converter.MessageConverter.toMessage()

    if (converter != null) {
      if (result instanceof org.springframework.messaging.Message) {
        return this.messagingMessageConverter.toMessage(result, session);
      }
      else {
        return converter.toMessage(result, session);
      }
    }
    else {
      if (!(result instanceof Message)) {
        throw new MessageConversionException(
View Full Code Here

Examples of org.springframework.jms.support.converter.MessageConverter.toMessage()

   * @see #setMessageConverter
   */
  protected Message buildMessage(Session session, Object result) throws JMSException {
    MessageConverter converter = getMessageConverter();
    if (converter != null) {
      return converter.toMessage(result, session);
    }
    else {
      if (!(result instanceof Message)) {
        throw new MessageConversionException(
            "No MessageConverter specified - cannot handle message [" + result + "]");
View Full Code Here

Examples of org.springframework.jms.support.converter.MessageConverter.toMessage()

   * @see #setMessageConverter
   */
  protected Message buildMessage(Session session, Object result) throws JMSException {
    MessageConverter converter = getMessageConverter();
    if (converter != null) {
      return converter.toMessage(result, session);
    }
    else {
      if (!(result instanceof Message)) {
        throw new MessageConversionException(
            "No MessageConverter specified - cannot handle message [" + result + "]");
View Full Code Here

Examples of org.springframework.jms.support.converter.SimpleMessageConverter.toMessage()

        messageControl.setReturnValue(content, 1);
        sessionControl.replay();
        messageControl.replay();

        SimpleMessageConverter converter = new SimpleMessageConverter();
        Message msg = converter.toMessage(content, session);
        assertEquals(content, converter.fromMessage(msg));

        sessionControl.verify();
        messageControl.verify();
    }
View Full Code Here

Examples of org.springframework.jms.support.converter.SimpleMessageConverter.toMessage()

        messageControl.setReturnValue(content.length, 1);
        sessionControl.replay();
        messageControl.replay();

        SimpleMessageConverter converter = new SimpleMessageConverter();
        Message msg = converter.toMessage(content, session);
        assertEquals(content.length, ((byte[]) converter.fromMessage(msg)).length);

        sessionControl.verify();
        messageControl.verify();
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.