プロパティによって、またはプロパティによってより具体的に、RabbitMQ ルーティング (交換経由) を実行したいと考えていますtype。
これは私の送信コードです:
AMQP.BasicProperties.Builder propsBuilder = new AMQP.BasicProperties.Builder();
propsBuilder.type(typeName);
channel.basicPublish(targetExchange, "", true, props, data);
交換タイプで試してみましたheadersが、正しく理解できれば、「ヘッダー」はプロパティ自体ではなく、プロパティ「ヘッダー」内に設定されたヘッダーのみです。
これは私の受信バインディングコードです(意図したとおりに動作しません):
channel.exchangeDeclare(exchangeName, "headers", false, true, null);
HashMap<String, Object> filter = new HashMap<String, Object>();
filter.put("x-match", "all");
filter.put("type", "HEARTBEAT");
channel.queueBind(queueName, exchangeName, "", filter);
また、別の取引所への交換ルーティングを使用するときに同じフィルタリングを設定できるかどうかも疑問に思っていました. 私はそれが可能であるべきだと信じています。