| Class | Description |
|---|---|
| AbstractAMQPProcessorTest |
Unit tests for the AbstractAMQPProcessor class
|
| AbstractAMQPProcessorTest.MockAbstractAMQPProcessor |
Provides a stubbed processor instance for testing
|
| AMQPConsumerTest | |
| AMQPPublisherTest | |
| AMQPUtilsTest | |
| ConsumeAMQP | |
| ConsumeAMQPTest | |
| ConsumeAMQPTest.LocalConsumeAMQP | |
| PublishAMQP |
Publishing AMQP processor which upon each invocation of
AbstractAMQPProcessor.onTrigger(ProcessContext, ProcessSession) method will construct an
AMQP message sending it to an exchange identified during construction of this
class while transferring the incoming FlowFile to 'success'
Relationship. |
| PublishAMQPTest | |
| PublishAMQPTest.LocalPublishAMQP |