JarCasting
JarCasting JarCasting

com.xing.testing:logger

High Availability AMQP Messaging With Redundant Queues

License

License
GroupId

GroupId

com.xing.testing
ArtifactId

ArtifactId

logger
Last Version

Last Version

1.1
Release Date

Release Date
Type

Type

jar
Description

Description

High Availability AMQP Messaging With Redundant Queues
Project Organization

Project Organization

New Work SE

Download logger

Filename Size
logger-1.1.pom
logger-1.1.jar 6 KB
logger-1.1-sources.jar 3 KB
logger-1.1-javadoc.jar 272 KB
Browse

How to add to project

<!-- https://jarcasting.com/artifacts/com.xing.testing/logger/ -->
<dependency>
    <groupId>com.xing.testing</groupId>
    <artifactId>logger</artifactId>
    <version>1.1</version>
</dependency>
// https://jarcasting.com/artifacts/com.xing.testing/logger/
implementation 'com.xing.testing:logger:1.1'
// https://jarcasting.com/artifacts/com.xing.testing/logger/
implementation ("com.xing.testing:logger:1.1")
'com.xing.testing:logger:jar:1.1'
<dependency org="com.xing.testing" name="logger" rev="1.1">
  <artifact name="logger" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.xing.testing', module='logger', version='1.1')
)
libraryDependencies += "com.xing.testing" % "logger" % "1.1"
[com.xing.testing/logger "1.1"]

Dependencies

compile (7)

Group / Artifact Type Version
org.junit.jupiter : junit-jupiter-engine jar
org.junit.platform : junit-platform-launcher jar
org.junit.jupiter : junit-jupiter-params jar
ch.qos.logback : logback-core jar
ch.qos.logback : logback-classic jar
junit : junit jar 4.13.1
org.springframework : spring-test jar

Project Modules

There are no modules declared in this project.

Beetle

This project is no longer actively developed!

High Availability AMQP Messaging with Redundant Queues

Java client library.

This library enables sending redundant messages to multiple AMQP brokers each having a queue. This way, if one of the brokers crashes, the messages in the queue which are on the other broker will still be there. At the receiving side, the beetle client will deduplicate the messages and the handler will receive the message once (in case of successful handling).

This package consists of two parts.

It also contains some demo apps:

How to use

Beetle Core

Beetle Java Client, supports sending redundant messages via BeetleChannel::basicPublish when the Beetle header x-publish-message-redundancy is set to a value larger than 1, as seen in beetle core demo Application.

x-publish-message-redundancy = 2 means, the message will be sent to 2 brokers if there are at least 2. The list of RabbitMQ servers should be configured using BEETLE_SERVERS environment variable.

On the receiving side, deduplication is only supported for BeetleChannel::basicConsume, as it creates a consumer and subscribes to the queue for message consumption. Using basicGet will result duplicates so it should not be used.

Spring Integration

Spring Integration module defines a BeetleConnectionFactory bean (as @ConditionalOnMissingBean) extending from com.rabbitmq.client.ConnectionFactory, so by default Beetle Client will be used to communicate with RabbitMQ brokers unless another ConnectionFactory is configured.

The list of RabbitMQ servers should be configured using beetle.servers application property or BEETLE_SERVERS environment variable.

Please see the following demo apps for sample usage:

Important Note: Deduplication for Spring integration is only supported when @RabbitListener is used. Usage of RabbitTemplate for receiving messages is not supported. Indeed, RabbitTemplate abuses consumers by creating a consumer for each message and closing them afterwards, which contradicts the purpose of a consumer. It also adds the overhead of establishing and tearing down the TCP connection every time. Under high load this approach would risk to run into issues with the number of connections/sockets available to the application because the operating system might not immediately free the resources used.

Requeue Messages at the End of Queues

Please see: https://github.com/xing/beetle/blob/master/DEAD_LETTERING.md

com.xing.testing

XING Developers

Versions

Version
1.1