public class RabbitMqServerImplementation extends Object implements com.github.mlk.queue.implementation.ServerImplementation
| Constructor and Description |
|---|
RabbitMqServerImplementation(com.rabbitmq.client.ConnectionFactory factory,
boolean autoAck) |
| 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) |
public RabbitMqServerImplementation(com.rabbitmq.client.ConnectionFactory factory,
boolean autoAck)
public void publish(String queueName, byte[] message) throws com.github.mlk.queue.QueueException
publish in interface com.github.mlk.queue.implementation.ServerImplementationcom.github.mlk.queue.QueueExceptionpublic void listen(String queueName, com.google.common.base.Function<byte[],Boolean> action) throws com.github.mlk.queue.QueueException
listen in interface com.github.mlk.queue.implementation.ServerImplementationcom.github.mlk.queue.QueueExceptionpublic void close()
close in interface com.github.mlk.queue.implementation.ServerImplementationCopyright © 2016. All rights reserved.