Package ch.tocco.nice2.optional.rabbitmq.impl

Class RabbitMqServiceImpl

java.lang.Object

ch.tocco.nice2.optional.rabbitmq.impl.RabbitMqServiceImpl

All Implemented Interfaces:

RabbitMqService

@Component
public class RabbitMqServiceImpl
extends Object
implements RabbitMqService

Nested Class Summary

Nested classes/interfaces inherited from interface ch.tocco.nice2.optional.rabbitmq.api.RabbitMqService

RabbitMqService.Message

Constructor Summary

Constructors

Constructor	Description
RabbitMqServiceImpl(org.slf4j.Logger log, Context context, SecurityManager securityManager, QueryBuilderFactory queryBuilderFactory)

Method Summary

Modifier and Type	Method	Description
void	sendMessageEntities(EntityList messageEntities)
void	sendMessages(String exchangeName, List<? extends RabbitMqService.Message> messages)
void	setHost(String host)
void	setPassword(String password)
void	setPort(Integer port)
void	setUsername(String username)
void	setVirtualHost(String virtualHost)

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitMqServiceImpl

public RabbitMqServiceImpl(org.slf4j.Logger log,
 Context context,
 SecurityManager securityManager,
 QueryBuilderFactory queryBuilderFactory)

Method Details

setHost

@Value("${nice2.optional.rabbitmq.host}")
public void setHost(String host)

setVirtualHost

@Value("${nice2.optional.rabbitmq.virtualHost}")
public void setVirtualHost(String virtualHost)

setPort

@Value("${nice2.optional.rabbitmq.port}")
public void setPort(Integer port)

setUsername

@Value("${nice2.optional.rabbitmq.username}")
public void setUsername(String username)

setPassword

@Value("${nice2.optional.rabbitmq.password}")
public void setPassword(String password)

sendMessages

public void sendMessages(String exchangeName,
 List<? extends RabbitMqService.Message> messages)

Specified by:

sendMessages in interface RabbitMqService

sendMessageEntities

public void sendMessageEntities(EntityList messageEntities)

Specified by:

sendMessageEntities in interface RabbitMqService