Package dev.aherscu.qa.jgiven.rabbitmq.steps

Class RabbitMqActions<K,V,SELF extends RabbitMqActions<K,V,SELF>>

java.lang.Object

com.tngtech.jgiven.base.StageBase<SELF>

com.tngtech.jgiven.Stage<SELF>

dev.aherscu.qa.jgiven.commons.utils.StageEx<SELF>

dev.aherscu.qa.jgiven.commons.steps.GenericActions<RabbitMqScenarioType,SELF>

dev.aherscu.qa.jgiven.rabbitmq.steps.RabbitMqActions<K,V,SELF>

All Implemented Interfaces:

dev.aherscu.qa.jgiven.commons.model.ScenarioType<RabbitMqScenarioType>

public class RabbitMqActions<K,V,SELF extends RabbitMqActions<K,V,SELF>>
extends dev.aherscu.qa.jgiven.commons.steps.GenericActions<RabbitMqScenarioType,SELF>

Field Summary

Fields

Modifier and Type	Field	Description
protected QueueHandler<K,V>	queueHandler
protected Function<V,byte[]>	toBytes

Fields inherited from class dev.aherscu.qa.jgiven.commons.utils.StageEx

assertElementTimer, ATTACHEMENT_TRANSFORMER, clickTimer, currentStep, locateTimer, pollDelay, pollTimeout, retryPolicy, scrollIntoViewTimer, sendKeysTimer

Constructor Summary

Constructors

Constructor	Description
RabbitMqActions()

Method Summary

Modifier and Type	Method	Description
SELF	consuming()
SELF	publishing(List<Message<V>> messages)
SELF	publishing(Stream<Message<V>> messages)

Methods inherited from class dev.aherscu.qa.jgiven.commons.steps.GenericActions

comment, concatenate_$_files_from_$_into, deleting_directory, doing_nothing, doing_nothing, doing_nothing, failing_on_purpose_with, retrying, retrying, safely, safely

Methods inherited from class dev.aherscu.qa.jgiven.commons.utils.StageEx

alert, attach, attachScreenshot, attachScreenshot, attachScreenshot, beforeScenarioConfigurePolling, context, element, elements, ensureElements, retry, safely, scrollIntoView

Methods inherited from class com.tngtech.jgiven.Stage

and, but, given, then, when, with

Methods inherited from class com.tngtech.jgiven.base.StageBase

$, $, self

Methods inherited from class java.lang.Object

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

Field Detail

queueHandler

@ExpectedScenarioState
protected QueueHandler<K,V> queueHandler

toBytes

@ProvidedScenarioState
protected Function<V,byte[]> toBytes

Constructor Detail

RabbitMqActions

public RabbitMqActions()

Method Detail

publishing

public SELF publishing(@Hidden
                       Stream<Message<V>> messages)

publishing

public SELF publishing(List<Message<V>> messages)

consuming

public SELF consuming()