protected org.springframework.amqp.rabbit.listener.RabbitListenerEndpoint |
RabbitChannelDefinitionProcessor.createRabbitListenerEndpoint(RabbitInboundChannelModel channelModel,
String tenantId,
EventRegistry eventRegistry) |
protected org.springframework.amqp.core.AcknowledgeMode |
RabbitChannelDefinitionProcessor.resolveAckMode(RabbitInboundChannelModel channelDefinition) |
protected org.springframework.amqp.rabbit.core.RabbitAdmin |
RabbitChannelDefinitionProcessor.resolveAdmin(RabbitInboundChannelModel channelDefinition) |
protected org.springframework.core.task.TaskExecutor |
RabbitChannelDefinitionProcessor.resolveExecutor(RabbitInboundChannelModel channelDefinition) |
protected Integer |
RabbitChannelDefinitionProcessor.resolvePriority(RabbitInboundChannelModel channelDefinition) |
protected void |
RabbitChannelDefinitionProcessor.resolveQueues(Object resolvedValue,
List<String> result,
RabbitInboundChannelModel channelDefinition) |
protected String[] |
RabbitChannelDefinitionProcessor.resolveQueues(RabbitInboundChannelModel channelDefinition) |