Package org.activiti.cloud.services.messages.tests

Class AbstractMessagesCoreIntegrationTests

java.lang.Object

org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

@SpringBootTest(webEnvironment=NONE,
                properties={"spring.application.name=rb","activiti.cloud.application.name=default-app","spring.cloud.stream.bindings.messageConnectorInput.content-type=application/json","spring.cloud.stream.bindings.messageConnectorOutput.content-type=application/json"})
@DirtiesContext
@Import(org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests.TestConfigurationContext.class)
public abstract class AbstractMessagesCoreIntegrationTests
extends Object

Tests for the Message Connector Aggregator Processor.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	activitiCloudApplicationName
protected MessageConnectorAggregator	aggregatingMessageHandler
protected MessageConnectorProcessor	channels
protected org.springframework.cloud.stream.test.binder.MessageCollector	collector
protected ControlBusGateway	controlBus
protected org.springframework.integration.channel.QueueChannel	discardQueue
protected org.springframework.integration.channel.QueueChannel	errorQueue
protected MessageAggregatorProperties	messageAggregatorProperties
protected org.springframework.integration.channel.AbstractMessageChannel	messageConnectorOutput
protected org.springframework.integration.store.MessageGroupStore	messageGroupStore
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected String	springApplicationName
protected org.springframework.transaction.PlatformTransactionManager	transactionManager

Constructor Summary

Constructors

Constructor	Description
AbstractMessagesCoreIntegrationTests()

Method Summary

Modifier and Type	Method	Description
protected String	correlationId(org.springframework.messaging.Message<?> message)
protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload>	messageBuilder(String messageName)
protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload>	messageBuilder(String messageName, String correlationKey)
protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload>	messageBuilder(String messageName, String correlationKey, String businessKey)
protected org.springframework.integration.store.MessageGroup	messageGroup(String groupName)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	messageReceivedEvent(String messageName, String correlationKey)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	messageReceivedEvent(String messageName, String correlationKey, String businessKey)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	messageSentEvent(String messageName)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	messageSentEvent(String messageName, String correlationKey)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	messageSentEvent(String messageName, String correlationKey, String businessKey)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	messageWaitingEvent(String messageName)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	messageWaitingEvent(String messageName, String correlationKey)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	messageWaitingEvent(String messageName, String correlationKey, String businessKey)
protected <T> org.springframework.messaging.Message<T>	peek()
protected <T> org.springframework.messaging.Message<T>	poll(long timeout, TimeUnit unit)
protected void	removeMessageGroup(String correlationId)
protected void	send(org.springframework.messaging.Message<?> message)
protected void	sendAsync(org.springframework.messaging.Message<?> message, CountDownLatch start, CountDownLatch sent, ExecutorService exec)
void	shouldConfigureHeaderChannelsTimeToLiveExpression()
void	shouldConfigureInputHeadersToRemove()
void	shouldProcessMessageEventsConcurrently()
void	shouldProcessMessageEventsConcurrentlyInReversedOrder()
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	startMessageDeployedEvent(String messageName)
protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload>	subscriptionCancelledEvent(String messageName, String correlationKey)
void	testControlBusStartStopComponents()
void	testIdempotentMessageInterceptor()
void	testInvalidMessagePayloadDiscardChannel()
void	testMessageFilterDiscardChannel()
void	testReceiveMessagePayload()
void	testSentMessagesWithBuffer()
void	testSentMessagesWithBufferInDifferentOrder()
void	testStartMessageAfterSent()
void	testStartMessageBeforeSent()
void	testStartMessagePayload()
void	testSubscriptionCancelled()
void	testTransactionException()

Methods inherited from class java.lang.Object

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

Field Detail

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

channels

@Autowired
protected MessageConnectorProcessor channels

collector

@Autowired
protected org.springframework.cloud.stream.test.binder.MessageCollector collector

messageGroupStore

@Autowired
protected org.springframework.integration.store.MessageGroupStore messageGroupStore

aggregatingMessageHandler

@Autowired
protected MessageConnectorAggregator aggregatingMessageHandler

errorQueue

@Autowired
protected org.springframework.integration.channel.QueueChannel errorQueue

discardQueue

@Autowired
protected org.springframework.integration.channel.QueueChannel discardQueue

controlBus

@Autowired
protected ControlBusGateway controlBus

transactionManager

@Autowired
protected org.springframework.transaction.PlatformTransactionManager transactionManager

messageAggregatorProperties

@Autowired
protected MessageAggregatorProperties messageAggregatorProperties

messageConnectorOutput

@Autowired
protected org.springframework.integration.channel.AbstractMessageChannel messageConnectorOutput

activitiCloudApplicationName

@Value("${activiti.cloud.application.name}")
protected String activitiCloudApplicationName

springApplicationName

@Value("${spring.application.name}")
protected String springApplicationName

Constructor Detail

AbstractMessagesCoreIntegrationTests

public AbstractMessagesCoreIntegrationTests()

Method Detail

shouldConfigureInputHeadersToRemove

@Test
public void shouldConfigureInputHeadersToRemove()

shouldConfigureHeaderChannelsTimeToLiveExpression

@Test
public void shouldConfigureHeaderChannelsTimeToLiveExpression()

shouldProcessMessageEventsConcurrently

@Test
@Timeout(20000L)
public void shouldProcessMessageEventsConcurrently()
                                            throws InterruptedException,
                                                   com.fasterxml.jackson.core.JsonProcessingException

Throws:

InterruptedException

com.fasterxml.jackson.core.JsonProcessingException

shouldProcessMessageEventsConcurrentlyInReversedOrder

@Test
@Timeout(20000L)
public void shouldProcessMessageEventsConcurrentlyInReversedOrder()
                                                           throws InterruptedException,
                                                                  com.fasterxml.jackson.core.JsonProcessingException

Throws:

InterruptedException

com.fasterxml.jackson.core.JsonProcessingException

testStartMessageBeforeSent

@Test
public void testStartMessageBeforeSent()
                                throws Exception

Throws:

Exception

testStartMessageAfterSent

@Test
public void testStartMessageAfterSent()
                               throws Exception

Throws:

Exception

testSentMessagesWithBuffer

@Test
public void testSentMessagesWithBuffer()
                                throws Exception

Throws:

Exception

testReceiveMessagePayload

@Test
public void testReceiveMessagePayload()
                               throws Exception

Throws:

Exception

testStartMessagePayload

@Test
public void testStartMessagePayload()
                             throws Exception

Throws:

Exception

testSentMessagesWithBufferInDifferentOrder

@Test
public void testSentMessagesWithBufferInDifferentOrder()
                                                throws Exception

Throws:

Exception

testSubscriptionCancelled

@Test
public void testSubscriptionCancelled()
                               throws Exception

Throws:

Exception

testIdempotentMessageInterceptor

@Test
public void testIdempotentMessageInterceptor()
                                      throws Exception

Throws:

Exception

testMessageFilterDiscardChannel

@Test
public void testMessageFilterDiscardChannel()
                                     throws Exception

Throws:

Exception

testInvalidMessagePayloadDiscardChannel

@Test
public void testInvalidMessagePayloadDiscardChannel()
                                             throws Exception

Throws:

Exception

testControlBusStartStopComponents

@Test
public void testControlBusStartStopComponents()
                                       throws Exception

Throws:

Exception

testTransactionException

@Test
public void testTransactionException()
                              throws Exception

Throws:

Exception

messageBuilder

protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload> messageBuilder(String messageName)

messageBuilder

protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload> messageBuilder(String messageName,
                                                                                                                                             String correlationKey)

messageBuilder

protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload> messageBuilder(String messageName,
                                                                                                                                             String correlationKey,
                                                                                                                                             String businessKey)

startMessageDeployedEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> startMessageDeployedEvent(String messageName)

messageSentEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageSentEvent(String messageName)

messageSentEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageSentEvent(String messageName,
                                                                                                                              String correlationKey)

messageSentEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageSentEvent(String messageName,
                                                                                                                              String correlationKey,
                                                                                                                              String businessKey)

messageWaitingEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageWaitingEvent(String messageName)

messageWaitingEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageWaitingEvent(String messageName,
                                                                                                                                 String correlationKey,
                                                                                                                                 String businessKey)

messageWaitingEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageWaitingEvent(String messageName,
                                                                                                                                 String correlationKey)

messageReceivedEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageReceivedEvent(String messageName,
                                                                                                                                  String correlationKey)

messageReceivedEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageReceivedEvent(String messageName,
                                                                                                                                  String correlationKey,
                                                                                                                                  String businessKey)

subscriptionCancelledEvent

protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> subscriptionCancelledEvent(String messageName,
                                                                                                                                        String correlationKey)

send

protected void send(org.springframework.messaging.Message<?> message)

poll

protected <T> org.springframework.messaging.Message<T> poll(long timeout,
                                                            TimeUnit unit)
                                                     throws InterruptedException

Throws:

InterruptedException

peek

protected <T> org.springframework.messaging.Message<T> peek()

messageGroup

protected org.springframework.integration.store.MessageGroup messageGroup(String groupName)

correlationId

protected String correlationId(org.springframework.messaging.Message<?> message)

removeMessageGroup

protected void removeMessageGroup(String correlationId)

sendAsync

protected void sendAsync(org.springframework.messaging.Message<?> message,
                         CountDownLatch start,
                         CountDownLatch sent,
                         ExecutorService exec)