AMQP Connector Release Notes

Fixed an issue in which the Publish consume operation leaked channels. (AMQPC-20)

Added mTLS support. (AMQPC-14)

Fixed the behavior that prevented the correct acknowledgment of processed messages when the application shut down. (AMQPC-12)

Fixed an issue in which inflight messages were not acknowledged during the runtime shutdown. (AMQPC-12)

Fixed an issue in which messages were lost due to channel reset when the max-retries limit was reached. (AMQPC-9)

Fixed an issue in which the Consume operation leaked channels, after performing consume and ack actions. (AMQPC-10)

Fixed an issue in which the Listener operation did not recover connection when a reconnection strategy was applied. (AMQPC-11)

The timestamp attribute is now in the amqp:properties element.

You can now set the messageid attribute in the publish-consume operation.

AMQP Connector did not apply the expiration property value. (MULE-18012)

The timestamp attribute did not appear in the 'amqp:properties' element.

The messageid attribute could not be set in the publish-consume operation. (AMQP-158)

Added a handshake configuration to configuration parameters (AMQP-157)

Added the ability to set socket attributes for AMQP (AMQP-156)

Leak in dynamic config: AmqpConfig POJOs do not implement equals and hashcode. (AMQP-152)

ConnectionException is not thrown when the queue is not found. (AMQP-151)

Use basicReject or basicAck for cases where brokers are recovered and recoverStrategy is set to NO_REQUEUE. (AMQP-150)

Channel leak in publish-consume operation. (AMQP-145)

Default TLS context should be available for a TLS connection. (AMQP-146)

AMQP Connector Publish operation incorrectly sets the delivery mode for sent messages. (AMQP-148)

Consumer Manager does not stop consumers separately when configuring a domain. (AMQP-142)

Race condition with consumer regeneration and Mule redeploy in domain. (AMQP-140)

Default Exchange is not taken into account in publish. (AMQP-141)

Operations do not close channel on MANUAL ack mode. (AMQP-139)

Defines queues bindings to exchange in queues declarations as in Mule 3. (AMQP-138)

Enforce reconnection when an AlreadyClosed exception occurs and when the reason is not identified for a fallback address. (AMQP-133)

Always enforce reconnection to be performed: guarantee reconnection when consumers are cancelled. (AMQP-132)

Move Generic Connection Provider to AmqpConfig so that the connection is bound to the configuration. (AMQP-131)

Disabling RabbitMQ NIO functionality. (AMQP-127)

Problem connecting to fallbackAddresses - always the last address was attempted. (AMQP-126)

Reincorporate fallback addresses in AMQP 4 connector. (AMQP-115)

User should be able to set the requestedHeartbeat in the connector. (AMQP-114)

Consumers are not released when associated to a connector defined in a domain. (AMQP-113)

AMQP client ShutdownSignalExceptions must be handled in listeners. (AMQP-107)

Transformer service incorrectly transformed byte array. (AMQP-105)

SNI Support.

Performance improvements.

Use of NIO RabbitMQ client API.

AMQP module ignores quality of service in listener. (AMQP-102)

transformer service incorrectly transforms byte array. (AMQP-105)

Performance improvements.

Use of NIO rabbitmq client API.

AMQP module ignores quality of service in listener. (AMQP-102)