Interface ProcessorRegistration

All Superinterfaces:

ConsumerRegistration

@Contract
public interface ProcessorRegistration
extends ConsumerRegistration

Generated registration for a synchronous one-to-one message processor.

Method Summary

Modifier and Type	Method	Description
default void	dispatch(MessageBatch<?> batch)	Dispatch one immutable delivery batch to the generated invocation adapter.
String	outgoingChannel()	Target channel for the processor result.
GenericType<?>	outgoingEnvelopeGenericType()	Produced message envelope type including generic arguments.
GenericType<?>	outgoingPayloadGenericType()	Produced payload type including generic arguments.
MessageBatch<?>	process(MessageBatch<?> batch)	Invoke the processor adapter for one delivery and return one derived batch for outgoingChannel().

Methods inherited from interface ConsumerRegistration

channel, declaredFailurePolicy, envelopeGenericType, handlerId, payloadGenericType

Modifier and Type	Method	Description
String	channel()	Channel name.
default Optional<FailurePolicy>	declaredFailurePolicy()	Failure policy declared for this registration's incoming logical channel.
GenericType<?>	envelopeGenericType()	Expected message envelope type including generic arguments.
default String	handlerId()	Stable identity of this generated handler registration.
GenericType<?>	payloadGenericType()	Expected payload type including generic arguments.

Method Details

outgoingChannel

String outgoingChannel()

Target channel for the processor result.

Returns:

outgoing channel

outgoingPayloadGenericType

GenericType<?> outgoingPayloadGenericType()

Produced payload type including generic arguments.

Returns:

outgoing payload type

outgoingEnvelopeGenericType

GenericType<?> outgoingEnvelopeGenericType()

Produced message envelope type including generic arguments.

Returns:

outgoing envelope type

process

MessageBatch<?> process(MessageBatch<?> batch)

Invoke the processor adapter for one delivery and return one derived batch for outgoingChannel().

Parameters:

batch - incoming batch

Returns:

outgoing batch with preserved delivery lineage

Throws:

RuntimeException - if processing fails

dispatch

default void dispatch(MessageBatch<?> batch)

Description copied from interface: ConsumerRegistration

Dispatch one immutable delivery batch to the generated invocation adapter.

Specified by:

dispatch in interface ConsumerRegistration

Parameters:

batch - delivery batch