rabbitmq / rabbitmq-amqp1.0

AMQP 1.0 support for RabbitMQ
https://www.rabbitmq.com/
Other
93 stars 20 forks source link

No custom fields can be added to the head of the properties of an Amqp 1.0 message. #62

Closed trademkose closed 3 years ago

trademkose commented 6 years ago

Hello -

I am trying to connect and send message from QPID JMS client to RabbitMQ with AMQP 1.0 plugin.I could send message to a queue. However, I can't add custom fields to the head of the properties of an AMQP 1.0 message.But I could achieve to add custom fields when I send AMQP 0.9.1 message with using Jmeter. You can see the custom fields the following image;

-AMQP 0.9.1 image

My AMQP 1.0 clinet's code is below to set the properties and the headers of the properties;

`JmsMapMessage message = (JmsMapMessage) session.createMapMessage();

AmqpJmsMessageFacade messageFacade = (AmqpJmsMessageFacade) message.getFacade();

Properties properties = new Properties();

properties.setReplyTo("adem1");
properties.setContentType(Symbol.getSymbol("application/json"));

properties.set_headers("arg0111");//I added this method to Properties class(org.apache.qpid.proton.amqp.messaging.Properties) //And I am not sure this because of this method is true way to set the headers.

messageFacade.setProperties(properties);

messageProducer.send(message);`

The messages is received to the queue but header is not set. -AMQP 1.0 image

So Does RabbitMq AMQP 1.0 plugin crush or override the sent fields of the header? How did you test this scenario?

Thank you for your supporting.

michaelklishin commented 6 years ago

Can you please provide a way to reproduce?

trademkose commented 6 years ago

We wrote our all setup for sending message at #61 issue.

If You want more details about our setup,We can send.

kjnilsson commented 6 years ago

Headers in AMQP 1.0 and AMQP 0.9.1 are very different things. Have you tried base64 decoding the string in x-amqp-1.0-properties?

michaelklishin commented 6 years ago

@trademkose any comments on the question above? We do need a runnable way to reproduce before we can comment on what may be going on.

61 was addressed and should be available in an alpha build shortly. Therefore any further tests should be conducted against a version that includes it.

SyamPearson commented 4 years ago

could you please say how you give host port address username and password parameters to amqp1.0 to send a message to cloudamqp queue

michaelklishin commented 4 years ago

@SyamPearson please direct your questions the mailing list.

lukebakken commented 3 years ago

Closing due to inactivity and assumption that #61 addressed this issue.