org.appng.core.controller.messaging

Class RabbitMQBase

java.lang.Object

org.appng.core.controller.messaging.RabbitMQBase

Direct Known Subclasses:

RabbitMQReceiver, RabbitMQSender

public class RabbitMQBase
extends Object

Base class to provide some base functionality for message receiver and sender for RabbitMQ

Author:

Claus Stümke, aiticon GmbH, 2015

Field Summary

Fields

Modifier and Type	Field and Description
protected Serializer	eventSerializer
protected String	exchange
protected static String	EXCHANGE_TYPE_FANOUT
protected String	host
protected String	password
protected int	port
protected String	user

Constructor Summary

Constructors

Constructor and Description
RabbitMQBase()

Method Summary

Modifier and Type	Method and Description
protected net.jodah.lyra.config.Config	getConnectionConfig()
void	initialize()

Methods inherited from class java.lang.Object

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

Field Detail

EXCHANGE_TYPE_FANOUT

protected static final String EXCHANGE_TYPE_FANOUT

See Also:

Constant Field Values

eventSerializer

protected Serializer eventSerializer

port

protected int port

host

protected String host

user

protected String user

password

protected String password

exchange

protected String exchange

Constructor Detail

RabbitMQBase

public RabbitMQBase()

Method Detail

initialize

public void initialize()

getConnectionConfig

protected net.jodah.lyra.config.Config getConnectionConfig()