io.openmessaging.producer

Interface BatchMessageSender

public interface BatchMessageSender

A message sender created through Producer.createBatchMessageSender(), to send messages in batch manner, and commit or roll back at the appropriate time.

Since:

OMS 1.0.0

Version:

OMS 1.0.0

Method Summary

Modifier and Type	Method and Description
void	close() Close this sender.
void	commit() Commits all the uncommitted messages in this sender.
void	rollback() Discards all the uncommitted messages in this sender.
BatchMessageSender	send(Message message) Submits a message to this sender

Method Detail

send

BatchMessageSender send(Message message)

Submits a message to this sender

Parameters:

message - a message to be sent

Returns:

this batch sender

commit

void commit()

Commits all the uncommitted messages in this sender.

Throws:

OMSRuntimeException - if the sender fails to commit the messages due to some internal error.

rollback

void rollback()

Discards all the uncommitted messages in this sender.

close

void close()

Close this sender.