spring rabbiitmqアプリケーションと構成

package org.springframework.amqp.rabbit.core;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
/**
* spring      ，    onMessage  
*/
public interface ChannelAwareMessageListener {
    void onMessage(Message var1, Channel var2) throws Exception;
}

package org.springframework.amqp.support.converter;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageProperties;
/**
*      ，          
*/
public interface MessageConverter {
    Message toMessage(Object var1, MessageProperties var2) throws MessageConversionException;

    Object fromMessage(Message var1) throws MessageConversionException;
}

/**
*         ，   ChannelAwareMessageListener   
* onMessage     ，           ，   service    
*/
public class MyMessageListener implements ChannelAwareMessageListener {
    @Autowired
    private MessageConverter messageConverter;
    @Autowired
    private MessageService messageService;

    @Override
    public void onMessage(Message message, Channel channel) throws Exception {
        MyMessage myMessage = null;
        long startTime = System.currentTimeMillis();
        try {
            myMessage = (MyMessage) messageConverter.fromMessage(message);
            Log("     ：" + myMessage + "    ");
            messageService.processMessage(myMessage);
        } catch (Exception e) {

        }
        //      ，false           ，true    consumer     
        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        Log("     ：" + myMessage + "    ,  ：" + (System.currentTimeMillis() - startTime) + "ms");
    }
}