package Ġdev . sk ye . da isy Ċ Ċ import Ġsoftware . amazon . aw ssdk . services . sqs . S qs Async Client Ċ import Ġsoftware . amazon . aw ssdk . services . sqs . model . Message Ċ import Ġsoftware . amazon . aw ssdk . services . sqs . model . Receive Message Request Ċ import Ġsoftware . amazon . aw ssdk . services . sqs . model . Receive Message Response Ċ import Ġjava . util . concurrent . Comp letableFuture Ċ import Ġjava . util . concurrent . Concurrent Linked Queue Ċ Ċ class ĠStub High Through put S qs Client ( ĊĠĠĠ Ġmessages : ĠList < Message > Ċ ) Ġ: ĠS qs Async Client Ġ{ ĊĊĠĠĠ Ġprivate Ġval Ġmessages Ġ= ĠConcurrent Linked Queue ( messages ) ĊĊĠĠĠ Ġoverride Ġfun Ġclose () Ġ{ ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġreceive Message ( ĊĠĠĠĠĠĠĠ Ġreceive Message Request : ĠReceive Message Request ĊĠĠĠ Ġ): ĠCompletableFuture < Receive Message Response > Ġ{ ĊĠĠĠĠĠĠĠ Ġval Ġmessages Ġ= Ġmessages . poll ()?. let Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ ĠlistOf ( it ) ĊĠĠĠĠĠĠĠ Ġ} Ġ?: ĠlistOf () ĊĠĠĠĠĠĠĠ Ġval Ġresponse Ġ= ĠReceive Message Response . builder () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. messages ( messages ) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ. build () ĊĠĠĠĠĠĠĠ Ġreturn ĠCompletableFuture . completed Future ( response ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun ĠserviceName (): ĠString Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġ" da isy - sqs " ĊĠĠĠ Ġ} Ċ } Ċ