org.hobbit.core.rabbit.consume

Class QueueingConsumerBasedImpl.Builder

java.lang.Object

org.hobbit.core.rabbit.consume.QueueingConsumerBasedImpl.Builder

All Implemented Interfaces:

MessageConsumerBuilder

Enclosing class:

QueueingConsumerBasedImpl

public static class QueueingConsumerBasedImpl.Builder
extends Object
implements MessageConsumerBuilder

Field Summary

Fields

Modifier and Type	Field and Description
private int	maxParallelProcessedMsgs
private String	name

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
MessageConsumer	build(DataReceiverImpl receiver, RabbitQueue queue) Builds a consumer for the given DataReceiver
MessageConsumerBuilder	maxParallelProcessedMsgs(int maxParallelProcessedMsgs)
QueueingConsumerBasedImpl.Builder	name(String name)

Methods inherited from class java.lang.Object

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

Field Detail

maxParallelProcessedMsgs

private int maxParallelProcessedMsgs

name

private String name

Constructor Detail

Builder

public Builder()

Method Detail

maxParallelProcessedMsgs

public MessageConsumerBuilder maxParallelProcessedMsgs(int maxParallelProcessedMsgs)

Specified by:

maxParallelProcessedMsgs in interface MessageConsumerBuilder

name

public QueueingConsumerBasedImpl.Builder name(String name)

Specified by:

name in interface MessageConsumerBuilder

build

public MessageConsumer build(DataReceiverImpl receiver,
                             RabbitQueue queue)

Description copied from interface: MessageConsumerBuilder

Builds a consumer for the given DataReceiver

Specified by:

build in interface MessageConsumerBuilder

Returns: