com.opendxl.databus.entities

Class RoutingData

java.lang.Object

com.opendxl.databus.entities.RoutingData

public class RoutingData
extends java.lang.Object

Represent a address where a message must be sent. It is used by ProducerRecord to know what the destination is. It contains a mandatory topic name as well as optionals sharding key and tenant group and partitions.

See how to use in DatabusProducer example

Constructor Summary

Constructors

Constructor and Description
RoutingData(java.lang.String topic) RoutingData constructor with only topic name parameter
RoutingData(java.lang.String topic, java.lang.String shardingKey, java.lang.String tenantGroup) RoutingData constructor with topic name sharding key and tenant group parameters
RoutingData(java.lang.String topic, java.lang.String shardingKey, java.lang.String tenantGroup, java.lang.Integer partition) RoutingData constructor with all parameters

Method Summary

Modifier and Type	Method and Description
java.lang.Integer	getPartition() Gets the partition number
java.lang.String	getShardingKey() Gets the sharding key
java.lang.String	getTenantGroup() Gets the tenant group
java.lang.String	getTopic() Gets the topic name

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RoutingData

public RoutingData(java.lang.String topic)

RoutingData constructor with only topic name parameter

Parameters:

topic - The topic name where the message must be sent

RoutingData

public RoutingData(java.lang.String topic,
                   java.lang.String shardingKey,
                   java.lang.String tenantGroup)

RoutingData constructor with topic name sharding key and tenant group parameters

Parameters:

topic - The topic name where the message must be sent

shardingKey - The Databus sharding key

tenantGroup - The name that groups topics

RoutingData

public RoutingData(java.lang.String topic,
                   java.lang.String shardingKey,
                   java.lang.String tenantGroup,
                   java.lang.Integer partition)

RoutingData constructor with all parameters

Parameters:

topic - The topic name where the message must be sent

shardingKey - The Databus sharding key

tenantGroup - The name that groups topics

partition - The partition number

Method Detail

getTopic

public java.lang.String getTopic()

Gets the topic name

Returns:

A String with the topic name

getShardingKey

public java.lang.String getShardingKey()

Gets the sharding key

Returns:

A String with the sharding key

getTenantGroup

public java.lang.String getTenantGroup()

Gets the tenant group

Returns:

A String with the tentant group

getPartition

public java.lang.Integer getPartition()

Gets the partition number

Returns:

An Integer with the partition number