org.continuity.api.amqp

Class ExchangeDefinition<F extends RoutingKeyFormatter>

java.lang.Object

org.continuity.api.amqp.ExchangeDefinition<F>

Type Parameters:

F - The RoutingKeyFormatter type.

public class ExchangeDefinition<F extends RoutingKeyFormatter>
extends java.lang.Object

Defines one exchange.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ExchangeDefinition(java.lang.String name, boolean durable, boolean autoDelete, F routingKeyFormatter)

Method Summary

Modifier and Type	Method and Description
org.springframework.amqp.core.TopicExchange	create() Creates an instance of this exchange.
java.lang.String	deriveQueueName(java.lang.String listeningService) Derives a queue name for a listening service from the exchange definition.
protected static ExchangeBuilder	event(java.lang.String scope, java.lang.String event)
F	formatRoutingKey() Formats the appropriate routing key.
java.lang.String	name() Gets the name of this exchange.
protected static ExchangeBuilder	task(java.lang.String scope, java.lang.String task)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExchangeDefinition

protected ExchangeDefinition(java.lang.String name,
                             boolean durable,
                             boolean autoDelete,
                             F routingKeyFormatter)

Method Detail

event

protected static ExchangeBuilder event(java.lang.String scope,
                                       java.lang.String event)

task

protected static ExchangeBuilder task(java.lang.String scope,
                                      java.lang.String task)

name

public java.lang.String name()

Gets the name of this exchange.

Returns:

The name as string.

create

public org.springframework.amqp.core.TopicExchange create()

Creates an instance of this exchange.

Returns:

An TopicExchange.

formatRoutingKey

public F formatRoutingKey()

Formats the appropriate routing key.

Returns:

A formatter that allows to format the key.

deriveQueueName

public java.lang.String deriveQueueName(java.lang.String listeningService)

Derives a queue name for a listening service from the exchange definition.

Parameters:

listeningService - The name of the listening service.

Returns:

A queue name.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object