0

我需要在 rabbitmq 中排队我的 json 有效负载并从队列中接收消息。我可以很好地将消息发送到队列中,但是当我尝试从主题交换中检索消息时,我得到了空指针异常。onMessage 方法实现中的以下行引发空指针异常。

simpleMessage=(SimpleMessage) rabbitTemplate.receiveAndConvert(qu);

有人可以解释我怎么做或指导我到有解决方案的链接

@Component
public class RabbitListener implements me {

    @Autowired
    RabbitTemplate rabbitTemplae;

    //@Override
    public void onMessage(Message message) {


    System.out.println("in listener");

        SimpleMessage simpleMessage= new SimpleMessage();
       // System.out.println("Received a new message = [" + new String(message.getBody().toString()) + "]");
        System.out.println("READY TO RECEIVE");
        String qu=message.getMessageProperties().getConsumerQueue();

        System.out.println("que name  "+qu);
      //simpleMessage=(SimpleMessage) rabbitTemplae.receiveAndConvert("MyTestQueue");
        //System.out.println("rabbitMQ  RECEIVE MESSAGE "+  rabbitTemplae.receiveAndConvert("MyTestQueu", 100000));
        simpleMessage=(SimpleMessage) rabbitTemplae.receiveAndConvert(qu);

        //rabbitTemplae.receiveAndConvert
      // System.out.println( simpleMessage.getDescription());


    }
}

需要将其从队列中转换回以下对象

public class SimpleMessage implements Serializable {

    private String name;
    private String description;

    public SimpleMessage() {
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getDescription() {
        return description;
    }

    public void setDescription(String description) {
        this.description = description;
    }

    @Override
    public String toString() {
        return "SimpleMessage{" +
                "name='" + name + '\'' +
                ", description='" + description + '\'' +
                '}';
    }
}
4

0 回答 0