A C D E M O P R S T
All Classes All Packages

A

AbstractMessagesCoreIntegrationTests - Class in org.activiti.cloud.services.messages.tests

Tests for the Message Connector Aggregator Processor.

AbstractMessagesCoreIntegrationTests() - Constructor for class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

activitiCloudApplicationName - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

aggregatingMessageHandler - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

C

channels - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

collector - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

controlBus - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

correlationId(Message<?>) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

D

discardQueue - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

E

errorQueue - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

M

messageAggregatorProperties - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageBuilder(String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageBuilder(String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageBuilder(String, String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageConnectorOutput - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageGroup(String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageGroupStore - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageReceivedEvent(String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageReceivedEvent(String, String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageSentEvent(String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageSentEvent(String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageSentEvent(String, String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageWaitingEvent(String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageWaitingEvent(String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

messageWaitingEvent(String, String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

O

objectMapper - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

org.activiti.cloud.services.messages.tests - package org.activiti.cloud.services.messages.tests

P

peek() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

poll(long, TimeUnit) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

R

removeMessageGroup(String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

S

send(Message<?>) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

sendAsync(Message<?>, CountDownLatch, CountDownLatch, ExecutorService) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

shouldConfigureHeaderChannelsTimeToLiveExpression() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

shouldConfigureInputHeadersToRemove() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

shouldProcessMessageEventsConcurrently() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

shouldProcessMessageEventsConcurrentlyInReversedOrder() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

springApplicationName - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

startMessageDeployedEvent(String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

subscriptionCancelledEvent(String, String) - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

T

testControlBusStartStopComponents() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testIdempotentMessageInterceptor() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testInvalidMessagePayloadDiscardChannel() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testMessageFilterDiscardChannel() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testReceiveMessagePayload() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testSentMessagesWithBuffer() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testSentMessagesWithBufferInDifferentOrder() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testStartMessageAfterSent() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testStartMessageBeforeSent() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testStartMessagePayload() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testSubscriptionCancelled() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

testTransactionException() - Method in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

transactionManager - Variable in class org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests

A C D E M O P R S T
All Classes All Packages