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 © 2021 The Apache Software Foundation. All rights reserved.