Alpakka JMS With Oracle AQ

(Vaibhav Khanduja) #1

I am connecting Alpakka JMS with Oracle AQ topic. The message sent from Oracle DB is of sqltype clob. I could write code using JMS api where I specified in consumer the oradatatype

MessageConsumer consumer = ((AQjmsSession)connection).createDurableSubscriber(t_recv.getTopic(), “test”, null,false, MyObject.getORADataFactory());

I need to understand as how can I specify the same oradata type with JmsSource coming from alpakka.

A sample code will surely help.