View Source RabbitMQStream.SuperProducer.Behaviour behaviour (rabbitmq_stream v0.4.2)

Summary

Callbacks

routing_key(message, partitions)

Callback responsible for generating the routing key for a given message and partitions size, which is then used to forward the publish request to the RabbitMQStream.Producer process responsible for the partition.

Callbacks

Link to this callback

routing_key(message, partitions)

View Source 
@callback routing_key(message :: binary(), partitions :: non_neg_integer()) ::
  non_neg_integer() | binary()

Callback responsible for generating the routing key for a given message and partitions size, which is then used to forward the publish request to the RabbitMQStream.Producer process responsible for the partition.