# ignite-nio - JavaDoc
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/512ffc51 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/512ffc51 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/512ffc51 Branch: refs/heads/sprint-1 Commit: 512ffc51e310c0461fc2167d1a90bf1216c13bd5 Parents: c09107b Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Sun Feb 15 00:02:41 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Sun Feb 15 00:02:41 2015 -0800 ---------------------------------------------------------------------- .../extensions/communication/MessageWriter.java | 25 ++++++++++++++++++++ 1 file changed, 25 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/512ffc51/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageWriter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageWriter.java b/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageWriter.java index ee729e8..564fc1e 100644 --- a/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageWriter.java +++ b/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageWriter.java @@ -256,17 +256,42 @@ public interface MessageWriter { public <K, V> boolean writeMap(String name, Map<K, V> map, MessageAdapter.Type keyType, MessageAdapter.Type valType); + /** + * @return Whether type of current message is already written. + */ public boolean isTypeWritten(); + /** + * Callback called when type of the message is written. + */ public void onTypeWritten(); + /** + * Gets current message state. + * + * @return State. + */ public int state(); + /** + * Increments state. + */ public void incrementState(); + /** + * Callback called before inner message is written. + */ public void beforeInnerMessageWrite(); + /** + * Callback called after inner message is written. + * + * @param finished Whether message was fully written. + */ public void afterInnerMessageWrite(boolean finished); + /** + * Resets this writer. + */ public void reset(); }
