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