org.axonframework.eventhandling.amqp.spring
Class DefaultRabbitMqStrategy

java.lang.Object
  org.axonframework.eventhandling.amqp.spring.DefaultRabbitMqStrategy

All Implemented Interfaces:

RabbitMqStrategy

public class DefaultRabbitMqStrategy
extends Object
implements RabbitMqStrategy

Strategy for creating a SimpleMessageListenerContainer instance using the Spring AMQP 1.3 API. Since then, the final "setExclusive" method has been added, causing the ExtendedMessageListenerContainer to fail. This implementation creates the SimpleMessageListenerContainer directly.

Since:

2.4

Author:

Allard Buijze

Constructor Summary

DefaultRabbitMqStrategy()

Method Summary

org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer	createContainer() Create a new instance of the container
void	setExclusive(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container, boolean exclusive) Define exclusive mode on the underlying container

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultRabbitMqStrategy

public DefaultRabbitMqStrategy()

Method Detail

setExclusive

public void setExclusive(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container,
                         boolean exclusive)

Description copied from interface: RabbitMqStrategy

Define exclusive mode on the underlying container

Specified by:

setExclusive in interface RabbitMqStrategy

Parameters:

container - The container to set exclusive mode on

exclusive - Whether to enable or disable exclusive mode

createContainer

public org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer createContainer()

Description copied from interface: RabbitMqStrategy

Create a new instance of the container

Specified by:

createContainer in interface RabbitMqStrategy

Returns:

a new instance of the container