Interface OutboundChannelModelBuilder
public interface OutboundChannelModelBuilder
A builder to create an
OutboundChannelModel
instance.
which represents a channel to send events to the 'outside world'.
An OutboundChannelModel
consists of the following parts:
- An adapter that defines how/where the events are sent, each with specific configurations.
- An event processing pipeline that
- allows for serialization to the proper format
- (Optionally) custom steps (or override any of the above)- Author:
- Joram Barrez
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic interface
Builder for the 'event processing' pipeline which gets invoked before sending out the event.static interface
Builder to create anOutboundEventChannelAdapter
using JMS.static interface
Builder to create anOutboundEventChannelAdapter
using Kafka.static interface
Builder to create anOutboundEventChannelAdapter
using RabbitMQ. -
Method Summary
Modifier and TypeMethodDescriptionSet the category for the channel deployment.channelAdapter
(String delegateExpression) Sets a customOutboundEventChannelAdapter
via a delegate expression.deploy()
Creates theOutboundChannelModel
instance based on the configuration and registers it with theEventRegistry
.deploymentName
(String deploymentName) Set the name for the channel deployment.deploymentTenantId
(String deploymentTenantId) Set the tenant id for the channel deployment.jmsChannelAdapter
(String destination) Configures an adapter which will send events using JMS.kafkaChannelAdapter
(String topic) Configures an adapter which will send events using Kafka.Each channel needs to have a unique key to identity it.parentDeploymentId
(String parentDeploymentId) Set the parent deployment id for the channel deployment.rabbitChannelAdapter
(String routingKey) Configures an adapter which will send events using RabbitMQ.resourceName
(String resourceName) Set the resource name for the channel model.
-
Method Details
-
key
Each channel needs to have a unique key to identity it. -
deploymentName
Set the name for the channel deployment. -
resourceName
Set the resource name for the channel model. -
category
Set the category for the channel deployment. -
deploymentTenantId
Set the tenant id for the channel deployment. -
parentDeploymentId
Set the parent deployment id for the channel deployment. -
channelAdapter
OutboundChannelModelBuilder.OutboundEventProcessingPipelineBuilder channelAdapter(String delegateExpression) Sets a customOutboundEventChannelAdapter
via a delegate expression. -
jmsChannelAdapter
Configures an adapter which will send events using JMS. -
rabbitChannelAdapter
Configures an adapter which will send events using RabbitMQ. -
kafkaChannelAdapter
Configures an adapter which will send events using Kafka. -
deploy
EventDeployment deploy()Creates theOutboundChannelModel
instance based on the configuration and registers it with theEventRegistry
.
-