com.github.mlk.queue.rabbitmq.implementation

Class RabbitMqServerImplementation

java.lang.Object

com.github.mlk.queue.rabbitmq.implementation.RabbitMqServerImplementation

All Implemented Interfaces:

com.github.mlk.queue.implementation.ServerImplementation

public class RabbitMqServerImplementation
extends Object
implements com.github.mlk.queue.implementation.ServerImplementation

Constructor Summary

Constructors

Constructor and Description
RabbitMqServerImplementation(com.rabbitmq.client.ConnectionFactory factory, boolean autoAck)

Method Summary

Modifier and Type	Method and Description
void	close()
void	listen(String queueName, com.google.common.base.Function<byte[],Boolean> action)
void	publish(String queueName, byte[] message)

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitMqServerImplementation

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

Method Detail

publish

public void publish(String queueName,
                    byte[] message)
             throws com.github.mlk.queue.QueueException

Specified by:

publish in interface com.github.mlk.queue.implementation.ServerImplementation

Throws:

com.github.mlk.queue.QueueException

listen

public void listen(String queueName,
                   com.google.common.base.Function<byte[],Boolean> action)
            throws com.github.mlk.queue.QueueException

Specified by:

listen in interface com.github.mlk.queue.implementation.ServerImplementation

Throws:

com.github.mlk.queue.QueueException

close

public void close()

Specified by:

close in interface com.github.mlk.queue.implementation.ServerImplementation