public class RabbitMQBase extends Object
Modifier and Type | Field and Description |
---|---|
protected String |
addresses |
protected Serializer |
eventSerializer |
protected String |
exchange |
protected static String |
EXCHANGE_TYPE_FANOUT |
protected com.rabbitmq.client.ConnectionFactory |
factory |
protected String |
password |
protected static String |
RABBIT_MQ_ADRESSES |
protected static String |
RABBIT_MQ_EXCHANGE |
protected static String |
RABBIT_MQ_PASSWORD |
protected static String |
RABBIT_MQ_USER |
protected String |
user |
Constructor and Description |
---|
RabbitMQBase() |
Modifier and Type | Method and Description |
---|---|
protected com.rabbitmq.client.Connection |
getConnection(net.jodah.lyra.ConnectionOptions options) |
protected net.jodah.lyra.config.Config |
getConnectionConfig() |
protected void |
initConnectionFactory() |
void |
initialize() |
protected static final String RABBIT_MQ_EXCHANGE
protected static final String RABBIT_MQ_PASSWORD
protected static final String RABBIT_MQ_USER
protected static final String RABBIT_MQ_ADRESSES
protected static final String EXCHANGE_TYPE_FANOUT
protected Serializer eventSerializer
protected String user
protected String password
protected String exchange
protected String addresses
protected com.rabbitmq.client.ConnectionFactory factory
public void initialize()
protected net.jodah.lyra.config.Config getConnectionConfig()
protected void initConnectionFactory()
protected com.rabbitmq.client.Connection getConnection(net.jodah.lyra.ConnectionOptions options) throws IOException, TimeoutException
IOException
TimeoutException
Copyright © 2011–2017 aiticon GmbH. All rights reserved.