public interface MessageEndpointConnection
The interface implemented by the application using a custom transportation method to exchange replication data between peers.
Modifier and Type | Method and Description |
---|---|
void |
close(Exception error,
MessagingCloseCompletion completion)
Called to close the remote connection with the other peer when the
replicator stops or when the MessageEndpointListener closes the connection.
|
void |
open(ReplicatorConnection connection,
MessagingCompletion completion)
Called to open a remote connection to the other peer when the replicator
starts or when the MessageEndpointListener accepts the connection.
|
void |
send(Message message,
MessagingCompletion completion)
Called to send the replication data to the other peer.
|
void open(@NonNull ReplicatorConnection connection, @NonNull MessagingCompletion completion)
connection
- the replicator connectioncompletion
- the completion callbackvoid close(Exception error, @NonNull MessagingCloseCompletion completion)
completion
- the completion callbackvoid send(@NonNull Message message, @NonNull MessagingCompletion completion)
message
- the messagecompletion
- the completion callback