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

Class AbstractMessagesCoreIntegrationTests

  • @SpringBootTest(webEnvironment=NONE,
                properties={"spring.cloud.stream.bindings.input.contentType=application/x-java-object","spring.cloud.stream.bindings.output.contentType=application/x-java-object"})
@DirtiesContext
@Import(org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests.TestConfigurationContext.class)
public abstract class AbstractMessagesCoreIntegrationTests
extends java.lang.Object
    Tests for the Message Connector Aggregator Processor.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected org.activiti.cloud.services.messages.core.aggregator.MessageConnectorAggregator aggregatingMessageHandler  
      protected org.activiti.cloud.services.messages.core.channels.MessageConnectorProcessor channels  
      protected org.springframework.cloud.stream.test.binder.MessageCollector collector  
      protected org.activiti.cloud.services.messages.core.controlbus.ControlBusGateway controlBus  
      protected org.springframework.integration.channel.QueueChannel discardQueue  
      protected org.springframework.integration.channel.QueueChannel errorQueue  
      protected org.springframework.integration.store.MessageGroupStore messageGroupStore  
      protected com.fasterxml.jackson.databind.ObjectMapper objectMapper  
      protected org.springframework.integration.channel.AbstractMessageChannel output  
      protected org.springframework.transaction.PlatformTransactionManager transactionManager  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected java.lang.String correlationId​(org.springframework.messaging.Message<?> message)  
      protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload> messageBuilder​(java.lang.String messageName)  
      protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload> messageBuilder​(java.lang.String messageName, java.lang.String correlationKey)  
      protected org.springframework.integration.support.MessageBuilder<org.activiti.api.process.model.payloads.MessageEventPayload> messageBuilder​(java.lang.String messageName, java.lang.String correlationKey, java.lang.String businessKey)  
      protected org.springframework.integration.store.MessageGroup messageGroup​(java.lang.String groupName)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageReceivedEvent​(java.lang.String messageName, java.lang.String correlationKey)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageReceivedEvent​(java.lang.String messageName, java.lang.String correlationKey, java.lang.String businessKey)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageSentEvent​(java.lang.String messageName)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageSentEvent​(java.lang.String messageName, java.lang.String correlationKey)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageSentEvent​(java.lang.String messageName, java.lang.String correlationKey, java.lang.String businessKey)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageWaitingEvent​(java.lang.String messageName)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageWaitingEvent​(java.lang.String messageName, java.lang.String correlationKey)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> messageWaitingEvent​(java.lang.String messageName, java.lang.String correlationKey, java.lang.String businessKey)  
      protected <T> org.springframework.messaging.Message<T> peek()  
      protected <T> org.springframework.messaging.Message<T> poll​(long timeout, java.util.concurrent.TimeUnit unit)  
      protected void removeMessageGroup​(java.lang.String correlationId)  
      protected void send​(org.springframework.messaging.Message<?> message)  
      protected void sendAsync​(org.springframework.messaging.Message<?> message, java.util.concurrent.CountDownLatch start, java.util.concurrent.CountDownLatch sent, java.util.concurrent.ExecutorService exec)  
      void shouldProcessMessageEventsConcurrently()  
      void shouldProcessMessageEventsConcurrentlyInReversedOrder()  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> startMessageDeployedEvent​(java.lang.String messageName)  
      protected org.springframework.messaging.Message<org.activiti.api.process.model.payloads.MessageEventPayload> subscriptionCancelledEvent​(java.lang.String messageName, java.lang.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 org.activiti.cloud.services.messages.core.channels.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 org.activiti.cloud.services.messages.core.aggregator.MessageConnectorAggregator aggregatingMessageHandler

      • errorQueue

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

      • discardQueue

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

      • controlBus

        @Autowired
protected org.activiti.cloud.services.messages.core.controlbus.ControlBusGateway controlBus

      • transactionManager

        @Autowired
protected org.springframework.transaction.PlatformTransactionManager transactionManager

      • output

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

    • Constructor Detail

      • AbstractMessagesCoreIntegrationTests

        public AbstractMessagesCoreIntegrationTests()

    • Method Detail

      • shouldProcessMessageEventsConcurrently

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

      • shouldProcessMessageEventsConcurrentlyInReversedOrder

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

      • testStartMessageBeforeSent

        @Test
public void testStartMessageBeforeSent()
                                throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testStartMessageAfterSent

        @Test
public void testStartMessageAfterSent()
                               throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testSentMessagesWithBuffer

        @Test
public void testSentMessagesWithBuffer()
                                throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testReceiveMessagePayload

        @Test
public void testReceiveMessagePayload()
                               throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testStartMessagePayload

        @Test
public void testStartMessagePayload()
                             throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testSentMessagesWithBufferInDifferentOrder

        @Test
public void testSentMessagesWithBufferInDifferentOrder()
                                                throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testSubscriptionCancelled

        @Test
public void testSubscriptionCancelled()
                               throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testIdempotentMessageInterceptor

        @Test
public void testIdempotentMessageInterceptor()
                                      throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testMessageFilterDiscardChannel

        @Test
public void testMessageFilterDiscardChannel()
                                     throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testInvalidMessagePayloadDiscardChannel

        @Test
public void testInvalidMessagePayloadDiscardChannel()
                                             throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testControlBusStartStopComponents

        @Test
public void testControlBusStartStopComponents()
                                       throws java.lang.Exception
        Throws:
        java.lang.Exception

      • testTransactionException

        @Test
public void testTransactionException()
                              throws java.lang.Exception
        Throws:
        java.lang.Exception

      • messageBuilder

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

      • messageBuilder

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

      • messageBuilder

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

      • startMessageDeployedEvent

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

      • messageSentEvent

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

      • messageSentEvent

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

      • messageSentEvent

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

      • messageWaitingEvent

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

      • messageWaitingEvent

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

      • messageWaitingEvent

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

      • messageReceivedEvent

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

      • messageReceivedEvent

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

      • subscriptionCancelledEvent

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

      • send

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

      • poll

        protected <T> org.springframework.messaging.Message<T> poll​(long timeout,
                                                            java.util.concurrent.TimeUnit unit)
                                                     throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException

      • peek

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

      • messageGroup

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

      • correlationId

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

      • removeMessageGroup

        protected void removeMessageGroup​(java.lang.String correlationId)

      • sendAsync

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