@Aaron @Pankaj_Arora @Ken_Overton thanks a lot guys , let me check out those links, although i wrote a fair share of implementation ==> for each spark partition by making a connection object , a message producer and then iterating over the rows of spark dataFrame for that partition and sending them to messageProducer.send() of jms api and my solace on docker received those events which i sent in distributed way.
although i need to figure out some cases and improve efficiency but this has been a big boost . Will get back shortly to you guys.