1<dependencies>
2    <dependency>
3        <groupId>com.rabbitmq</groupId>
4        <artifactId>amqp-client</artifactId>
5        <version>5.x.x</version>
6    </dependency>
7</dependencies>

1import com.rabbitmq.client.ConnectionFactory;
2import com.rabbitmq.client.Connection;
3import com.rabbitmq.client.Channel;
4
5public class RabbitMQExample {
6    public static void main(String[] args) throws Exception {
7        ConnectionFactory factory = new ConnectionFactory();
8        factory.setHost("localhost"); // Change this to your RabbitMQ server address
9        try (Connection connection = factory.newConnection();
10             Channel channel = connection.createChannel()) {
11
12            // Continue with declaring exchanges and queues
13        }
14    }
15}

String exchangeName = "headers_exchange";
channel.exchangeDeclare(exchangeName, "headers", true);

1String queueName = channel.queueDeclare().getQueue();
2Map<String, Object> headers = new HashMap<>();
3headers.put("category", "novel");
4headers.put("format", "hardcover");
5
6channel.queueBind(queueName, exchangeName, "", headers); // Note the empty routing key

1AMQP.BasicProperties props = new AMQP.BasicProperties
2    .Builder()
3    .headers(headers)
4    .build();
5
6String message = "A Tale of Two Cities";
7channel.basicPublish(exchangeName, "", props, message.getBytes());

1Consumer consumer = new DefaultConsumer(channel) {
2    @Override
3    public void handleDelivery(String consumerTag, Envelope envelope,
4                               AMQP.BasicProperties properties, byte[] body) throws IOException {
5        String message = new String(body, "UTF-8");
6        System.out.println("Received: " + message);
7    }
8};
9
10channel.basicConsume(queueName, true, consumer);