@EnableBinding(value=org.springframework.cloud.stream.messaging.Sink.class) @EnableConfigurationProperties(value=ThroughputSinkProperties.class) public class ThroughputSinkConfiguration extends Object implements org.springframework.context.Lifecycle
Constructor and Description |
---|
ThroughputSinkConfiguration() |
Modifier and Type | Method and Description |
---|---|
boolean |
isRunning() |
void |
start() |
void |
stop() |
void |
throughputSink(org.springframework.messaging.Message<?> message) |
public void start()
start
in interface org.springframework.context.Lifecycle
public void stop()
stop
in interface org.springframework.context.Lifecycle
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
@ServiceActivator(inputChannel="input") public void throughputSink(org.springframework.messaging.Message<?> message)
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.