| Modifier and Type | Method and Description |
|---|---|
void |
EventRegistry.eventReceived(InboundChannelModel channelModel,
String event)
Events received in adapters should call this method to process events.
|
void |
InboundEventProcessor.eventReceived(InboundChannelModel channelModel,
String event) |
void |
InboundEventChannelAdapter.setInboundChannelModel(InboundChannelModel inboundChannelModel) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultInboundEventProcessor.eventReceived(InboundChannelModel channelModel,
String event) |
void |
DefaultEventRegistry.eventReceived(InboundChannelModel channelModel,
String event) |
| Modifier and Type | Field and Description |
|---|---|
protected InboundChannelModel |
InboundChannelDefinitionBuilderImpl.channelModel |
protected InboundChannelModel |
InboundChannelDefinitionBuilderImpl.InboundEventProcessingPipelineBuilderImpl.channelModel |
| Constructor and Description |
|---|
InboundEventProcessingPipelineBuilderImpl(InboundChannelModel channelModel,
EventRepositoryService eventRepository,
InboundChannelDefinitionBuilderImpl channelDefinitionBuilder) |
| Modifier and Type | Method and Description |
|---|---|
protected InboundEventProcessingPipeline |
InboundChannelModelProcessor.createExpressionEventProcessingPipeline(InboundChannelModel channelModel,
EventRepositoryService eventRepositoryService) |
protected InboundEventProcessingPipeline |
InboundChannelModelProcessor.createJsonEventProcessingPipeline(InboundChannelModel channelModel,
EventRepositoryService eventRepositoryService) |
protected InboundEventProcessingPipeline |
InboundChannelModelProcessor.createXmlEventProcessingPipeline(InboundChannelModel channelModel,
EventRepositoryService eventRepositoryService) |
protected void |
InboundChannelModelProcessor.registerChannelModel(InboundChannelModel inboundChannelModel,
EventRepositoryService eventRepositoryService,
boolean fallbackToDefaultTenant) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
InboundChannelModelValidator.validateChannel(InboundChannelModel inboundChannelModel) |
protected void |
InboundChannelModelValidator.validateDeserializer(InboundChannelModel inboundChannelModel) |
| Modifier and Type | Method and Description |
|---|---|
void |
ChannelJsonConverter.addInboundChannelModelClass(String type,
Class<? extends InboundChannelModel> channelModelClass) |
| Modifier and Type | Class and Description |
|---|---|
class |
DelegateExpressionInboundChannelModel |
class |
JmsInboundChannelModel |
class |
KafkaInboundChannelModel |
class |
RabbitInboundChannelModel |
| Modifier and Type | Field and Description |
|---|---|
protected InboundChannelModel |
JmsChannelMessageListenerAdapter.inboundChannelModel |
| Modifier and Type | Method and Description |
|---|---|
InboundChannelModel |
JmsChannelMessageListenerAdapter.getInboundChannelModel() |
| Modifier and Type | Method and Description |
|---|---|
protected javax.jms.MessageListener |
JmsChannelModelProcessor.createMessageListener(EventRegistry eventRegistry,
InboundChannelModel inboundChannelModel) |
void |
JmsChannelMessageListenerAdapter.setInboundChannelModel(InboundChannelModel inboundChannelModel) |
| Constructor and Description |
|---|
JmsChannelMessageListenerAdapter(EventRegistry eventRegistry,
InboundChannelModel inboundChannelModel) |
| Modifier and Type | Field and Description |
|---|---|
protected InboundChannelModel |
KafkaChannelMessageListenerAdapter.inboundChannelModel |
| Modifier and Type | Method and Description |
|---|---|
InboundChannelModel |
KafkaChannelMessageListenerAdapter.getInboundChannelModel() |
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.kafka.listener.GenericMessageListener<org.apache.kafka.clients.consumer.ConsumerRecord<Object,Object>> |
KafkaChannelDefinitionProcessor.createMessageListener(EventRegistry eventRegistry,
InboundChannelModel inboundChannelModel) |
void |
KafkaChannelMessageListenerAdapter.setInboundChannelModel(InboundChannelModel inboundChannelModel) |
| Constructor and Description |
|---|
KafkaChannelMessageListenerAdapter(EventRegistry eventRegistry,
InboundChannelModel inboundChannelModel) |
| Modifier and Type | Field and Description |
|---|---|
protected InboundChannelModel |
RabbitChannelMessageListenerAdapter.inboundChannelModel |
| Modifier and Type | Method and Description |
|---|---|
InboundChannelModel |
RabbitChannelMessageListenerAdapter.getInboundChannelModel() |
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.amqp.core.MessageListener |
RabbitChannelDefinitionProcessor.createMessageListener(EventRegistry eventRegistry,
InboundChannelModel inboundChannelModel) |
void |
RabbitChannelMessageListenerAdapter.setInboundChannelModel(InboundChannelModel inboundChannelModel) |
| Constructor and Description |
|---|
RabbitChannelMessageListenerAdapter(EventRegistry eventRegistry,
InboundChannelModel inboundChannelModel) |
Copyright © 2023 Flowable. All rights reserved.