com.axemble.vdoc.sdk.interfaces

Interface IJMSMessageProcessor<M extends IJMSMessage>

public interface IJMSMessageProcessor<M extends IJMSMessage>

Method Summary

Modifier and Type	Method and Description
default void	afterProcessMessages() Invoked after processing the message batch
default void	beforeProcessMessages() Invoked before processing the message batch
default int	getBatchSize() Return the batch size for message processing
default String	getMessageFilter() Return the filter/discriminant if needs.
default Integer	getNumberOfParallelConsumers() Return the number of parallel consumers to run
default Integer	getPerMessageSecondTimeout() Return the timeout to process a unique message.
void	processMessage(M message) Invoked to process a message

Method Detail

getMessageFilter

default String getMessageFilter()

Return the filter/discriminant if needs. If not return null This filter only apply on message properties Example : "JMSType = 'car' AND color = 'blue' AND weight > 2500"

Returns:

the filter or null if none

getBatchSize

default int getBatchSize()

Return the batch size for message processing

Returns:

the batch size

getPerMessageSecondTimeout

default Integer getPerMessageSecondTimeout()

Return the timeout to process a unique message. If return is null then the default timeout is applied

Returns:

the timeout to process a message

getNumberOfParallelConsumers

default Integer getNumberOfParallelConsumers()

Return the number of parallel consumers to run

Returns:

the number of parallel consumers to run

beforeProcessMessages

default void beforeProcessMessages()

Invoked before processing the message batch

processMessage

void processMessage(M message)

Invoked to process a message

Parameters:

message - the message to process

afterProcessMessages

default void afterProcessMessages()

Invoked after processing the message batch