由于您没有为代码提供更多信息，我将用一个基本的消费者样板来回答：

import org.apache.qpid.protonj2.client.*;
import org.apache.qpid.protonj2.client.exceptions.ClientException;
public class RabbitMQConsumer {
    public static void main(String[] args) {
        String brokerUrl = "amqp://your.rabbitmq.server:port";
        String exchangeName = "yourExchangeName";
        try {
            Client client = Client.create();
            Connection connection = client.connect(brokerUrl);
            Session session = connection.openSession();
            // Assuming RabbitMQ creates a server-named queue and binds it when the consumer connects
            Receiver receiver = session.openReceiver(exchangeName);
            receiver.handler((delivery, message) -> {
                String body = message.getBody().toString();
                // Process message
                System.out.println("Received message: " + body);
            });
            receiver.open();
            System.out.println("Connected to exchange and waiting for messages...");
            // Keep the application running to listen for messages
            Thread.currentThread().join();
        } catch (ClientException | InterruptedException e) {
            e.printStackTrace();
        }
    }
}

字符串