Package ru.tinkoff.qa.neptune.rabbit.mq.function.get

Class RabbitMqBasicGetArraySupplier<M,R,S extends RabbitMqBasicGetArraySupplier<M,R,S>>

java.lang.Object

ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier<T,R,M,P,THIS>

ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetArrayStepSupplier<RabbitMqStepContext,R,S>

ru.tinkoff.qa.neptune.rabbit.mq.function.get.RabbitMqBasicGetArraySupplier<M,R,S>

All Implemented Interfaces:

Cloneable, Supplier<Function<RabbitMqStepContext,R[]>>, ru.tinkoff.qa.neptune.core.api.steps.parameters.StepParameterPojo

Direct Known Subclasses:

RabbitMqBasicGetArraySupplier.Mapped, RabbitMqBasicGetArraySupplier.StringMessages

public abstract class RabbitMqBasicGetArraySupplier<M,R,S extends RabbitMqBasicGetArraySupplier<M,R,S>>
extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetArrayStepSupplier<RabbitMqStepContext,R,S>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RabbitMqBasicGetArraySupplier.Mapped<M,T>
static class	RabbitMqBasicGetArraySupplier.StringMessages

Nested classes/interfaces inherited from class ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier

ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.DefaultGetParameterReader, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.DefineCriteriaParameterName, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.DefineFromParameterName, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.DefineGetImperativeParameterName, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.DefinePollingTimeParameterName, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.DefineResultDescriptionParameterName, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.DefineTimeOutParameterName, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetArrayChainedStepSupplier<T extends Object,R extends Object,M extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetArrayChainedStepSupplier<T,R,M,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetArrayStepSupplier<T extends Object,R extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetArrayStepSupplier<T,R,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetListChainedStepSupplier<T extends Object,S extends Iterable<R>,M extends Object,R extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetListChainedStepSupplier<T,S,M,R,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetListStepSupplier<T extends Object,S extends Iterable<R>,R extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetListStepSupplier<T,S,R,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectChainedStepSupplier<T extends Object,R extends Object,M extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectChainedStepSupplier<T,R,M,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectFromArrayChainedStepSupplier<T extends Object,R extends Object,M extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectFromArrayChainedStepSupplier<T,R,M,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectFromArrayStepSupplier<T extends Object,R extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectFromArrayStepSupplier<T,R,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectFromIterableChainedStepSupplier<T extends Object,R extends Object,M extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectFromIterableChainedStepSupplier<T,R,M,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectFromIterableStepSupplier<T extends Object,R extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectFromIterableStepSupplier<T,R,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectStepSupplier<T extends Object,R extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetObjectStepSupplier<T,R,THIS>>, ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetSimpleStepSupplier<T extends Object,R extends Object,THIS extends ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier.GetSimpleStepSupplier<T,R,THIS>>

Field Summary

Fields

Modifier and Type	Field	Description
static String	NO_DESC_ERROR_TEXT

Fields inherited from class ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier

toReport

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RabbitMqBasicGetArraySupplier(ru.tinkoff.qa.neptune.rabbit.mq.function.get.GetFromQueue.MergeProperty<List<M>> getFromQueue, Function<M,R> function, Class<R> componentClass)

Method Summary

Modifier and Type	Method	Description
S	autoAck()	It means that server should consider messages acknowledged once delivered.
protected void	onFailure(RabbitMqStepContext m, Throwable throwable)
protected void	onSuccess(R[] t)
static <M,T> RabbitMqBasicGetArraySupplier.Mapped<M,T>	rabbitArray(String description, com.fasterxml.jackson.core.type.TypeReference<M> typeT, Class<T> componentClass, Function<M,T> toGet)	Creates a step that gets some array value which is calculated by body of message.
static <T> RabbitMqBasicGetArraySupplier.Mapped<T,T>	rabbitArray(String description, com.fasterxml.jackson.core.type.TypeReference<T> typeT)	Creates a step that gets some (sub)array from array body of message.
static <M,T> RabbitMqBasicGetArraySupplier.Mapped<M,T>	rabbitArray(String description, Class<M> classT, Class<T> componentClass, Function<M,T> toGet)	Creates a step that gets some array value which is calculated by body of message.
static <T> RabbitMqBasicGetArraySupplier.Mapped<T,T>	rabbitArray(String description, Class<T> classT)	Creates a step that gets some (sub)array from array body of message.
static <M,T> RabbitMqBasicGetArraySupplier.Mapped<M,T>	rabbitArray(String description, String queue, com.fasterxml.jackson.core.type.TypeReference<M> typeT, Class<T> componentClass, Function<M,T> toGet)	Creates a step that gets some array value which is calculated by body of message.
static <T> RabbitMqBasicGetArraySupplier.Mapped<T,T>	rabbitArray(String description, String queue, com.fasterxml.jackson.core.type.TypeReference<T> typeT)	Creates a step that gets some (sub)array from array body of message.
static <M,T> RabbitMqBasicGetArraySupplier.Mapped<M,T>	rabbitArray(String description, String queue, Class<M> classT, Class<T> componentClass, Function<M,T> toGet)	Creates a step that gets some array value which is calculated by body of message.
static <T> RabbitMqBasicGetArraySupplier.Mapped<T,T>	rabbitArray(String description, String queue, Class<T> classT)	Creates a step that gets some (sub)array from array body of message.
static RabbitMqBasicGetArraySupplier.StringMessages	rabbitArrayOfRawMessages()
static RabbitMqBasicGetArraySupplier.StringMessages	rabbitArrayOfRawMessages(String queue)	Creates a step that returns array of string contents of messages.
static RabbitMqBasicGetArraySupplier.StringMessages	rabbitArrayOfRawMessages(String queue, Charset charset)	Creates a step that returns array of string contents of messages.
static RabbitMqBasicGetArraySupplier.StringMessages	rabbitArrayOfRawMessages(Charset charset)	Creates a step that returns array of string contents of messages.
default THIS	returnAfterIndex(int arg0)
default THIS	returnArrayOfLength(int arg0)
default THIS	returnBeforeIndex(int arg0)
default THIS	returnIfEntireLength(ru.tinkoff.qa.neptune.core.api.steps.selections.ItemsCountCondition arg0)
default THIS	returnItemsOfIndexes(Integer... arg0)
default THIS	returnOnCondition(String arg0, Predicate<T> arg1)
default THIS	returnOnCondition(ru.tinkoff.qa.neptune.core.api.steps.Criteria<R[]> arg0)
default THIS	returnOnConditionOnlyNot(ru.tinkoff.qa.neptune.core.api.steps.Criteria<T>... arg0)
default THIS	returnOnConditionOnlyOne(ru.tinkoff.qa.neptune.core.api.steps.Criteria<T>... arg0)
default THIS	returnOnConditionOr(ru.tinkoff.qa.neptune.core.api.steps.Criteria<T>... arg0)
S	timeOut(Duration timeOut)

Methods inherited from class ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier

addIgnored, addIgnored, additionalParameters, eraseTimeOut, getCriteria, getDescription, getEndFunction, getFrom, getParameters, makeACopy, onStart, pollingInterval, preparePreFunction, setDescription, throwOnNoResult, toString, turnReportingOff

Methods inherited from class java.lang.Object

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

Field Detail

NO_DESC_ERROR_TEXT

public static final String NO_DESC_ERROR_TEXT

See Also:

Constant Field Values

Constructor Detail

RabbitMqBasicGetArraySupplier

protected RabbitMqBasicGetArraySupplier(ru.tinkoff.qa.neptune.rabbit.mq.function.get.GetFromQueue.MergeProperty<List<M>> getFromQueue,
                                        Function<M,R> function,
                                        Class<R> componentClass)

Method Detail

rabbitArray

public static <M,T> RabbitMqBasicGetArraySupplier.Mapped<M,T> rabbitArray(String description,
                                                                                      String queue,
                                                                                      Class<M> classT,
                                                                                      Class<T> componentClass,
                                                                                      Function<M,T> toGet)

Creates a step that gets some array value which is calculated by body of message.

Type Parameters:

M - is a type of deserialized message

T - is a type of item of array

Parameters:

description - is description of value to get

queue - is a queue to read

classT - is a class of a value to deserialize message

toGet - describes how to get desired value

Returns:

an instance of RabbitMqBasicGetArraySupplier

rabbitArray

public static <M,T> RabbitMqBasicGetArraySupplier.Mapped<M,T> rabbitArray(String description,
                                                                                      Class<M> classT,
                                                                                      Class<T> componentClass,
                                                                                      Function<M,T> toGet)

Creates a step that gets some array value which is calculated by body of message. It gets required value from default queue.

Type Parameters:

M - is a type of deserialized message

T - is a type of item of array

Parameters:

description - is description of value to get

classT - is a class of a value to deserialize message

toGet - describes how to get desired value

Returns:

an instance of RabbitMqBasicGetArraySupplier

See Also:

RabbitMQRoutingProperties.DEFAULT_QUEUE_NAME

rabbitArray

public static <M,T> RabbitMqBasicGetArraySupplier.Mapped<M,T> rabbitArray(String description,
                                                                                      String queue,
                                                                                      com.fasterxml.jackson.core.type.TypeReference<M> typeT,
                                                                                      Class<T> componentClass,
                                                                                      Function<M,T> toGet)

Creates a step that gets some array value which is calculated by body of message.

Type Parameters:

M - is a type of deserialized message

T - is a type of item of array

Parameters:

description - is description of value to get

queue - is a queue to read

typeT - is a reference to type of value to deserialize message

toGet - describes how to get desired value

Returns:

an instance of RabbitMqBasicGetArraySupplier

rabbitArray

public static <M,T> RabbitMqBasicGetArraySupplier.Mapped<M,T> rabbitArray(String description,
                                                                                      com.fasterxml.jackson.core.type.TypeReference<M> typeT,
                                                                                      Class<T> componentClass,
                                                                                      Function<M,T> toGet)

Creates a step that gets some array value which is calculated by body of message. It gets required value from default queue.

Type Parameters:

M - is a type of deserialized message

T - is a type of item of array

Parameters:

description - is description of value to get

typeT - is a reference to type of value to deserialize message

toGet - describes how to get desired value

Returns:

an instance of RabbitMqBasicGetArraySupplier

See Also:

RabbitMQRoutingProperties.DEFAULT_QUEUE_NAME

rabbitArray

public static <T> RabbitMqBasicGetArraySupplier.Mapped<T,T> rabbitArray(String description,
                                                                              String queue,
                                                                              Class<T> classT)

Creates a step that gets some (sub)array from array body of message.

Type Parameters:

T - is a type of item of array

Parameters:

description - is description of value to get

queue - is a queue to read

classT - is a class of a value to deserialize message

Returns:

an instance of RabbitMqBasicGetArraySupplier

rabbitArray

public static <T> RabbitMqBasicGetArraySupplier.Mapped<T,T> rabbitArray(String description,
                                                                              Class<T> classT)

Creates a step that gets some (sub)array from array body of message. It gets required value from default queue.

Type Parameters:

T - is a type of item of array

Parameters:

description - is description of value to get

classT - is a class of a value to deserialize message

Returns:

an instance of RabbitMqBasicGetArraySupplier

See Also:

RabbitMQRoutingProperties.DEFAULT_QUEUE_NAME

rabbitArray

public static <T> RabbitMqBasicGetArraySupplier.Mapped<T,T> rabbitArray(String description,
                                                                              String queue,
                                                                              com.fasterxml.jackson.core.type.TypeReference<T> typeT)

Creates a step that gets some (sub)array from array body of message.

Type Parameters:

T - is a type of item of array

Parameters:

description - is description of value to get

queue - is a queue to read

typeT - is a reference to type of value to deserialize message

Returns:

an instance of RabbitMqBasicGetArraySupplier

rabbitArray

public static <T> RabbitMqBasicGetArraySupplier.Mapped<T,T> rabbitArray(String description,
                                                                              com.fasterxml.jackson.core.type.TypeReference<T> typeT)

Creates a step that gets some (sub)array from array body of message. It gets required value from default queue.

Type Parameters:

T - is a type of item of array

Parameters:

description - is description of value to get

typeT - is a reference to type of value to deserialize message

Returns:

an instance of RabbitMqBasicGetArraySupplier

See Also:

RabbitMQRoutingProperties.DEFAULT_QUEUE_NAME

rabbitArrayOfRawMessages

public static RabbitMqBasicGetArraySupplier.StringMessages rabbitArrayOfRawMessages(String queue,
                                                                                    Charset charset)

Creates a step that returns array of string contents of messages.

Parameters:

queue - are queue to get messages from

charset - is a required charset

Returns:

an instance of RabbitMqBasicGetArraySupplier.StringMessages

rabbitArrayOfRawMessages

public static RabbitMqBasicGetArraySupplier.StringMessages rabbitArrayOfRawMessages(Charset charset)

Creates a step that returns array of string contents of messages.

Parameters:

charset - is a required charset

Returns:

an instance of RabbitMqBasicGetArraySupplier.StringMessages

rabbitArrayOfRawMessages

public static RabbitMqBasicGetArraySupplier.StringMessages rabbitArrayOfRawMessages(String queue)

Creates a step that returns array of string contents of messages.

Parameters:

queue - are queue to get messages from

Returns:

an instance of RabbitMqBasicGetArraySupplier.StringMessages

rabbitArrayOfRawMessages

public static RabbitMqBasicGetArraySupplier.StringMessages rabbitArrayOfRawMessages()

timeOut

public S timeOut(Duration timeOut)

Overrides:

timeOut in class ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier<RabbitMqStepContext,R[],RabbitMqStepContext,R,S extends RabbitMqBasicGetArraySupplier<M,R,S>>

onSuccess

protected void onSuccess(R[] t)

Overrides:

onSuccess in class ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier<RabbitMqStepContext,R[],RabbitMqStepContext,R,S extends RabbitMqBasicGetArraySupplier<M,R,S>>

onFailure

protected void onFailure(RabbitMqStepContext m,
                         Throwable throwable)

Overrides:

onFailure in class ru.tinkoff.qa.neptune.core.api.steps.SequentialGetStepSupplier<RabbitMqStepContext,R[],RabbitMqStepContext,R,S extends RabbitMqBasicGetArraySupplier<M,R,S>>

autoAck

public S autoAck()

It means that server should consider messages acknowledged once delivered.

Returns:

self-reference

returnArrayOfLength

public default THIS returnArrayOfLength(int arg0)

returnItemsOfIndexes

public default THIS returnItemsOfIndexes(Integer... arg0)

returnBeforeIndex

public default THIS returnBeforeIndex(int arg0)

returnAfterIndex

public default THIS returnAfterIndex(int arg0)

returnIfEntireLength

public default THIS returnIfEntireLength(ru.tinkoff.qa.neptune.core.api.steps.selections.ItemsCountCondition arg0)

returnOnCondition

public default THIS returnOnCondition(ru.tinkoff.qa.neptune.core.api.steps.Criteria<R[]> arg0)

returnOnCondition

public default THIS returnOnCondition(String arg0,
                                      Predicate<T> arg1)

returnOnConditionOr

public default THIS returnOnConditionOr(ru.tinkoff.qa.neptune.core.api.steps.Criteria<T>... arg0)

returnOnConditionOnlyOne

public default THIS returnOnConditionOnlyOne(ru.tinkoff.qa.neptune.core.api.steps.Criteria<T>... arg0)

returnOnConditionOnlyNot

public default THIS returnOnConditionOnlyNot(ru.tinkoff.qa.neptune.core.api.steps.Criteria<T>... arg0)