Alpakka JMS With Oracle AQ

Akka Libraries Akka Streams & Alpakka
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.

2

User defined MessageConsumer creation is not possible with the current API in Alpakka Kafka.

This would require something similar to setup with CustomDestination where the user can mount a specific destination factory.

Feel free to propose a solution in a Pull Request.

Cheers,
Enno.

3

Is this still the case @ennru?