Page Comparison

...

• void publish(TopicId topic, List<byte[]> messages) throws TopicNotFoundException;
• void publish(TopicId topic, byte[] payloadmessage) throws TopicNotFoundException; 

For publishing storing messages transactionally by providing the Transaction object and as well as a boolean variable that indicates whether the messages should be persisted in the payloadTable before the messages are in the PayloadTable (requires Transaction - tx_write_ptr)

• void store(TopicId topic, byte[] message, Transaction transaction) throws TopicNotFoundException;
• void store(TopicId topic, List<byte[]> messages, Transaction transaction) throws TopicNotFoundException;  

For publishing messages without using payload table or to publish messages stored earlier in the PayloadTable:

• void publish(TopicId topic, Transaction transaction) throws TopicNotFoundException;
• void publish(TopicId topic, byte[] payloadmessage, Transaction transaction, boolean buffer) throws TopicNotFoundException;  

For committing messages published transactionally:

• void commit(TopicId topicvoid publish(TopcId topic, List<byte[]> messages, Transaction transaction) throws TopicNotFoundException;

...

• void rollback(TopicId topic, Transaction transaction) throws TopicNotFoundException;

Consuming Message (this set of API will also be Public enabling CDAP Apps, including Tracker, to consume (audit) messages from MessagingService:

For consuming messages non-transactionally:

...