Class TaskEventLoopProcessor
java.lang.Object
org.springframework.shell.component.view.event.processor.TaskEventLoopProcessor
- All Implemented Interfaces:
EventLoop.EventLoopProcessor
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
canProcess
(org.springframework.messaging.Message<?> message) Checks if this processor can process an event.reactor.core.publisher.Flux<? extends org.springframework.messaging.Message<?>>
process
(org.springframework.messaging.Message<?> message) Process a message and transform it into a newFlux
ofMessage
instances.
-
Constructor Details
-
TaskEventLoopProcessor
public TaskEventLoopProcessor()
-
-
Method Details
-
canProcess
public boolean canProcess(org.springframework.messaging.Message<?> message) Description copied from interface:EventLoop.EventLoopProcessor
Checks if this processor can process an event. If this method returnstrue
it's quaranteed thatEventLoop.EventLoopProcessor.process(Message)
is called to resolve translation of a message.- Specified by:
canProcess
in interfaceEventLoop.EventLoopProcessor
- Parameters:
message
- the message- Returns:
- true if processor can process an event
-
process
public reactor.core.publisher.Flux<? extends org.springframework.messaging.Message<?>> process(org.springframework.messaging.Message<?> message) Description copied from interface:EventLoop.EventLoopProcessor
Process a message and transform it into a newFlux
ofMessage
instances.- Specified by:
process
in interfaceEventLoop.EventLoopProcessor
- Parameters:
message
- the message to process- Returns:
- a flux of messages
-