THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Internal message | AMQP 1-0 message | Implemented
| |||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
Property origin | Property name | Type | Section name | Property name | Type | Comments | |||||||||
InternalMessage InternalMessageMetaData | isPersistent() isPersistent() | boolean | header | durable | unsigned byte |
| Y | ||||||||
MessageHeader | getPriority() | byte | header | priority | unsigned byte |
| Y | ||||||||
MessageHeader | getExpiration() | long | header | ttl | milliseconds |
| Y | ||||||||
MessageHeader | getExpiration() | long | properties | absolute-expiry-time | timestamp | N | |||||||||
MessageHeader | getMessageId() | String | properties | message-id | uuid/string/ulong |
| Y | ||||||||
MessageHeader | getCorrelationId() | String | properties | correlation-id | binary |
| Y | ||||||||
MessageHeader | getUserId() | String | properties | user-id | binary |
| Y | ||||||||
MessageHeader | getTimestamp() | datetime | properties | creation-time | timestamp |
| Y | ||||||||
MessageHeader | getReplyTo() | String | properties | reply-to | string |
| Y | ||||||||
InternalMessage | getTo() | String | properties | to | string |
| TODO | ||||||||
InternalMessage | getEncoding()str8 | String | properties | content-encoding | symbol |
| Y | ||||||||
MessageHeader | getContentType() | str8 | properties | content-type | symbol | delivery-properties | redelivered | bit | header | first-acquirer | boolean |
| N TODO | delivery-properties | routing-key | str8
| properties | tosubject | string | Y | N | |||||||||||
delivery-properties | exchange | str8 | properties | to | string |
| Y | ||||||||
delivery-properties | immediate | bit |
|
|
|
|
| ||||||||
delivery-properties | discard-unroutable | bit |
|
| |||||||||||
message-properties | content-type | str8 | properties | content-type | symbol | "application/java-object-stream" replaced with "application/x-java-serialized-object" | Y | ||||||||
message-properties | content-encoding | str8 | properties | content-encoding | symbol |
| Y | ||||||||
message-properties | app-id | vbin16 |
|
|
|
|
| ||||||||
message-properties | application-headers | map | application-properties | * | MessageConversionException is thrown when string or key is invalid | Y | |||||||||
message-properties | content-length | uint64 |
|
|
|
|
| ||||||||
message-properies headers | qpid.subject | str8 | properties | subject | string |
| Y | ||||||||
message properies headers | JMSXGroupID | str8 | properties | group-id | string |
| Y | ||||||||
message properties headers | JMSXGroupSeq | int | properties | group-sequence | sequence number |
| Y | ||||||||
| message-properties | content-type | str8 | message-annotation | x-opt-jms-msg-type | string | N | |||||||||
MessageHeader | getHeader(String)/getHeaderNames() | String/Enumeration | application-properties | * | MessageConversionException is thrown when string or key is invalid | Y | |||||||||
AMQP 0-8...0-9-1 message properties conversion into internal message properties
AMQP 0-8...0-9-1 message | Internal message | Implemented | |||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
Property origin | Property name | type | Property class | Property name | Type | Comments | |||||||||
message property | delivery mode | octet | InternalMessage InternalMessageMetaData | isPeristent() | boolean |
| Y | ||||||||
message property | priority | octet | MessageHeader | priority | byte |
| Y | ||||||||
message property | expiration | short-string | MessageHeader | expiration | long | Y | |||||||||
message property | timestamp | long | MessageHeader | timestamp | long | Y | |||||||||
message property | content type | short-string | MessageHeader | contentType | String |
| Y | ||||||||
message property | encoding | short-string | MessageHeader | encoding | String |
| Y | ||||||||
message property | message id | short-string | MessageHeader | messageId | String |
| Y | ||||||||
message property | correlation id | short-string | MessageHeader | correlationId | String |
| Y | ||||||||
message property | user id | short-string | MessageHeader | userId | String |
| Y | ||||||||
message property | reply to | short-string | MessageHeader | replyTo | String | If 'reply to' is a BURL parses it and converts it into <exchange>/<routingKey> format | Y | ||||||||
message property | application id | short-string | MessageHeader | appId | String |
| Y | ||||||||
message property | headers | field-table | MessageHeader | application-headers | Map<String,Object> |
| Y | ||||||||
message property | type | short-string | MessageHeader | type | String |
| Y | ||||||||
entry delivery count | int | MessageHeader | redelivered | bit | dynamically set on sending |
| |||||||||
basic.publish | routing-key | short-string | InternalMessage | initialRoutingAddress | String |
| N | ||||||||
basic.publish | exchange | short-string | InternalMessage | to | String |
| Y | ||||||||
basic.publish | immediate | bit | MessageHeader | immediate | bit |
| N | ||||||||
basic.publish | mandatory | bit | MessageHeader | discard-unroutable | bit |
| N | message-properties | application-headers['x-jms-type'] | str16 | properties | subject | string | Y | |
Content conversion
Conversion of message content from AMQP 0-8...0-9-1 into AMQP 0-10 and back is simply a matter of copying the content bytes.
...