public static class RocketMqState.Options extends Object implements Serializable
Constructor and Description |
---|
Options() |
Modifier and Type | Method and Description |
---|---|
RocketMqState.Options |
withMapper(TupleToMessageMapper mapper) |
RocketMqState.Options |
withProperties(Properties properties) |
RocketMqState.Options |
withSelector(TopicSelector selector) |
public RocketMqState.Options withSelector(TopicSelector selector)
public RocketMqState.Options withMapper(TupleToMessageMapper mapper)
public RocketMqState.Options withProperties(Properties properties)
Copyright © 2020 The Apache Software Foundation. All rights reserved.