com.github.mlk.queue.rabbitmq

Class RabbitMqServer

java.lang.Object

com.github.mlk.queue.Server

com.github.mlk.queue.rabbitmq.RabbitMqServer

All Implemented Interfaces:

AutoCloseable

public class RabbitMqServer
extends com.github.mlk.queue.Server

Constructor Summary

Constructors

Constructor and Description
RabbitMqServer(com.rabbitmq.client.ConnectionFactory factory)
RabbitMqServer(com.rabbitmq.client.ConnectionFactory factory, boolean autoAck)
RabbitMqServer(String host)
RabbitMqServer(String host, boolean autoAck)

Method Summary

Modifier and Type	Method and Description
protected com.github.mlk.queue.implementation.ServerImplementation	getImplementation()

Methods inherited from class com.github.mlk.queue.Server

close

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMqServer

public RabbitMqServer(String host,
                      boolean autoAck)

Parameters:

host - The host to connect to. This will result in a default connection factory with this host.

autoAck - Should the messages be automatically ack'ed. If set then the return from the Function in @Handle methods is ignored

RabbitMqServer

public RabbitMqServer(com.rabbitmq.client.ConnectionFactory factory,
                      boolean autoAck)

Parameters:

factory - The connection factory for Rabbit MQ.

autoAck - Should the messages be automatically ack'ed. If set then the return from the Function in @Handle methods is ignored

RabbitMqServer

public RabbitMqServer(String host)

Parameters:

host - The host to connect to. This will result in a default connection factory with this host.

RabbitMqServer

public RabbitMqServer(com.rabbitmq.client.ConnectionFactory factory)

Parameters:

factory - The connection factory for Rabbit MQ.

Method Detail

getImplementation

protected com.github.mlk.queue.implementation.ServerImplementation getImplementation()

Specified by:

getImplementation in class com.github.mlk.queue.Server