Also you can use the other API that returns a Future and save those futures into a list and do get() on them to check which message has been sent and which returned an error so that they can be retried.
Thanks, Mayuresh On Thu, Mar 19, 2015 at 9:19 AM, Steven Wu <stevenz...@gmail.com> wrote: > in your callback impl object, you can save a reference to the actual > message. > > On Wed, Mar 18, 2015 at 10:45 PM, sunil kalva <kalva.ka...@gmail.com> > wrote: > > > Hi > > How do i access the actual message which is failed to send to cluster > using > > Callback interface and onCompletion method. > > > > Basically if the sender is failed to send, i want to add it to a temp > queue > > and retry them later. > > > > --Sunil > > > -- -Regards, Mayuresh R. Gharat (862) 250-7125
