IN
- The type of the data used by the sink.@PublicEvolving public interface RMQSinkPublishOptions<IN> extends Serializable
Modifier and Type | Method and Description |
---|---|
String |
computeExchange(IN a)
Compute the exchange from the data.
|
default boolean |
computeImmediate(IN a)
Compute the immediate flag passed to method
com.rabbitmq.client.Channel#basicPublish(String, String, boolean, boolean, BasicProperties,
byte[]) . |
default boolean |
computeMandatory(IN a)
Compute the mandatory flag passed to method
com.rabbitmq.client.Channel#basicPublish(String, String, boolean, boolean, BasicProperties,
byte[]) . |
com.rabbitmq.client.AMQP.BasicProperties |
computeProperties(IN a)
Compute the message's properties from the data.
|
String |
computeRoutingKey(IN a)
Compute the message's routing key from the data.
|
String computeRoutingKey(IN a)
a
- The data used by the sinkcom.rabbitmq.client.AMQP.BasicProperties computeProperties(IN a)
a
- The data used by the sinkString computeExchange(IN a)
a
- The data used by the sinkdefault boolean computeMandatory(IN a)
com.rabbitmq.client.Channel#basicPublish(String, String, boolean, boolean, BasicProperties,
byte[])
. A SerializableReturnListener
is mandatory if this flag can be true.a
- The data used by the sinkdefault boolean computeImmediate(IN a)
com.rabbitmq.client.Channel#basicPublish(String, String, boolean, boolean, BasicProperties,
byte[])
. A SerializableReturnListener
is mandatory if this flag can be true.a
- The data used by the sinkCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.