package Ġio . datal br y . connector . sdk . messaging . amqp Ċ Ċ import Ġio . datal br y . connector . api . Document Edge Ċ import Ġio . datal br y . connector . sdk . Connector Properties Ċ import Ġio . datal br y . connector . sdk . messaging . Channel Ċ import Ġorg . springframework . amqp . rabbit . core . Rabbit Template Ċ Ċ class ĠRabbit Mq Add Channel ( private Ġval Ġrabbit Mq : ĠRabbit Template ) Ġ: ĠChannel < Document Edge > Ġ{ ĊĠĠĠ Ġprivate Ġval Ġtopic Ġ= ĠChannel . DEST INATION _ NODE _ AD DITION ĊĠĠĠ Ġprivate Ġval Ġrouting Ġ= ĠChannel . DEST INATION _ NODE _ AD DITION ĊĊĠĠĠ Ġoverride Ġfun Ġpropagate ( message : ĠDocument Edge ) Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġheaders Ġ= Ġmessage . headers . to Mutable Map () ĊĠĠĠĠĠĠĠ Ġheaders [" _ type "] Ġ= ĠDocument Edge :: class . qualified Name . toString () ĊĠĠĠĠĠĠĠ Ġval Ġen ric hed Message Ġ= Ġmessage . copy ( headers Ġ= Ġheaders ) ĊĠĠĠĠĠĠĠ Ġrabbit Mq . convert And Send ( topic , Ġrouting , Ġen ric hed Message ) ĊĠĠĠ Ġ} Ċ } Ċ