com.github.aidensuen.cloud.stream

Class AbstractConsumer<T>

java.lang.Object

com.github.aidensuen.cloud.stream.AbstractConsumer<T>

@EnableBinding(value=org.springframework.cloud.stream.messaging.Processor.class)
public abstract class AbstractConsumer<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
AbstractConsumer()

Method Summary

Modifier and Type	Method and Description
abstract void	doProcess(T payload)
void	process(T payload)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractConsumer

public AbstractConsumer()

Method Detail

process

@StreamListener(value="input")
 @SendTo(value="output")
public void process(T payload)

doProcess

public abstract void doProcess(T payload)