Package dev.aherscu.qa.jgiven.rabbitmq.utils

Class QueueHandler.QueueHandlerBuilder<K,V,C extends QueueHandler<K,V>,B extends QueueHandler.QueueHandlerBuilder<K,V,C,B>>

java.lang.Object

dev.aherscu.qa.jgiven.rabbitmq.utils.QueueHandler.QueueHandlerBuilder<K,V,C,B>

Enclosing class:

QueueHandler<K,V>

public abstract static class QueueHandler.QueueHandlerBuilder<K,V,C extends QueueHandler<K,V>,B extends QueueHandler.QueueHandlerBuilder<K,V,C,B>>
extends Object

Constructor Summary

Constructors

Constructor	Description
QueueHandlerBuilder()

Method Summary

Modifier and Type	Method	Description
abstract C	build()
B	channel(com.rabbitmq.client.Channel channel)
B	consumerTag(String consumerTag)
B	consumingBy(Function<byte[],V> consumingBy)
B	indexingBy(Function<Message<V>,K> indexingBy)
B	publishingBy(Function<V,byte[]> publishingBy)
B	queue(String queue)
protected abstract B	self()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueHandlerBuilder

public QueueHandlerBuilder()

Method Detail

channel

public B channel(com.rabbitmq.client.Channel channel)

Returns:

this.

queue

public B queue(String queue)

Returns:

this.

indexingBy

public B indexingBy(Function<Message<V>,K> indexingBy)

Returns:

this.

consumingBy

public B consumingBy(Function<byte[],V> consumingBy)

Returns:

this.

publishingBy

public B publishingBy(Function<V,byte[]> publishingBy)

Returns:

this.

consumerTag

public B consumerTag(String consumerTag)

Returns:

this.

self

protected abstract B self()

build

public abstract C build()

toString

public String toString()

Overrides:

toString in class Object