private JsonObject createTask ( JsonSimple response , String broker , String oid , String task ) { JsonObject object = newMessage ( response , TransactionManagerQueueConsumer . LISTENER_ID ) ; if ( broker != null ) { object . put ( "broker" , broker ) ; } JsonObject message = ( JsonObject ) object . get ( "message" ) ; message . put ( "task" , task ) ; message . put ( "oid" , oid ) ; return message ; }
Create a task . This is a more detailed option allowing for tasks being sent to remote brokers .