MaxMessagesReadPlanFactory

cc.otavia.core.channel.message.MaxMessagesReadPlanFactory
See theMaxMessagesReadPlanFactory companion object
abstract class MaxMessagesReadPlanFactory(maxMessagesPerRead: Int) extends ReadPlanFactory

Base implementation of ReadPlanFactory which allows to limit the number of messages read per read loop.

Attributes

Companion
object
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Constructors

def this()

Concrete methods

override def newPlan(channel: Channel): ReadPlan

Creates a new ReadPlan for the given Channel.

Creates a new ReadPlan for the given Channel.

Value parameters

channel

the Channel for which the ReadPlan is used.

Attributes

Definition Classes