Package org.openwms.transactions.api.commands

Class RabbitAsyncTransactionApiImpl

java.lang.Object

org.openwms.transactions.api.commands.RabbitAsyncTransactionApiImpl

All Implemented Interfaces:

AsyncTransactionApi<TransactionCommand>

@Profile("AMQP")
@Component
class RabbitAsyncTransactionApiImpl
extends Object
implements AsyncTransactionApi<TransactionCommand>

A RabbitTransactionApiImpl is a sender facade that uses RabbitMQ to send transaction commands. It is activated with the Spring profile AMQP. It expects to work with an exchange name configured as owms.commands.transactions.tx.send-to.

Author:

Heiko Scherrer

Field Summary

Fields

Modifier and Type	Field	Description
private final String	exchangeName
private final org.springframework.amqp.core.AmqpTemplate	template

Constructor Summary

Constructors

Constructor	Description
RabbitAsyncTransactionApiImpl(org.springframework.amqp.core.AmqpTemplate template, String exchangeName)

Method Summary

Modifier and Type	Method	Description
void	process(TransactionCommand command)	Process the given command.

Methods inherited from class java.lang.Object

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

Field Details

template

private final org.springframework.amqp.core.AmqpTemplate template

exchangeName

private final String exchangeName

Constructor Details

RabbitAsyncTransactionApiImpl

RabbitAsyncTransactionApiImpl(org.springframework.amqp.core.AmqpTemplate template,
 @Value("${owms.commands.transactions.tx.exchange-name}")
 String exchangeName)

Method Details

process

@Measured
public void process(TransactionCommand command)

Process the given command.

Specified by:

process in interface AsyncTransactionApi<TransactionCommand>

Parameters:

command - Command to process