# gg-9792 - Fixing DR communication
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7cfcaa7e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7cfcaa7e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7cfcaa7e Branch: refs/heads/ignite-292 Commit: 7cfcaa7e4f77135db8a1bf31d2f33114a027eb83 Parents: 3021ef8 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Tue Feb 17 14:43:01 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Tue Feb 17 14:43:01 2015 -0800 ---------------------------------------------------------------------- .../CommunicationMessageCodeGenerator.java | 56 +++++++++----------- 1 file changed, 26 insertions(+), 30 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7cfcaa7e/modules/codegen/src/main/java/org/apache/ignite/codegen/CommunicationMessageCodeGenerator.java ---------------------------------------------------------------------- diff --git a/modules/codegen/src/main/java/org/apache/ignite/codegen/CommunicationMessageCodeGenerator.java b/modules/codegen/src/main/java/org/apache/ignite/codegen/CommunicationMessageCodeGenerator.java index 91fdc1f..0aa9482 100644 --- a/modules/codegen/src/main/java/org/apache/ignite/codegen/CommunicationMessageCodeGenerator.java +++ b/modules/codegen/src/main/java/org/apache/ignite/codegen/CommunicationMessageCodeGenerator.java @@ -123,40 +123,36 @@ public class CommunicationMessageCodeGenerator { /** * @param args Arguments. + * @throws Exception In case of error. */ - public static void main(String[] args) { + public static void main(String[] args) throws Exception { CommunicationMessageCodeGenerator gen = new CommunicationMessageCodeGenerator(); - try { - gen.generateAll(true); - -// gen.generateAndWrite(GridDistributedLockRequest.class); -// gen.generateAndWrite(GridDistributedLockResponse.class); -// gen.generateAndWrite(GridNearLockRequest.class); -// gen.generateAndWrite(GridNearLockResponse.class); -// gen.generateAndWrite(GridDhtLockRequest.class); -// gen.generateAndWrite(GridDhtLockResponse.class); + gen.generateAll(true); + +// gen.generateAndWrite(GridDistributedLockRequest.class); +// gen.generateAndWrite(GridDistributedLockResponse.class); +// gen.generateAndWrite(GridNearLockRequest.class); +// gen.generateAndWrite(GridNearLockResponse.class); +// gen.generateAndWrite(GridDhtLockRequest.class); +// gen.generateAndWrite(GridDhtLockResponse.class); // -// gen.generateAndWrite(GridDistributedTxPrepareRequest.class); -// gen.generateAndWrite(GridDistributedTxPrepareResponse.class); -// gen.generateAndWrite(GridNearTxPrepareRequest.class); -// gen.generateAndWrite(GridNearTxPrepareResponse.class); -// gen.generateAndWrite(GridDhtTxPrepareRequest.class); -// gen.generateAndWrite(GridDhtTxPrepareResponse.class); +// gen.generateAndWrite(GridDistributedTxPrepareRequest.class); +// gen.generateAndWrite(GridDistributedTxPrepareResponse.class); +// gen.generateAndWrite(GridNearTxPrepareRequest.class); +// gen.generateAndWrite(GridNearTxPrepareResponse.class); +// gen.generateAndWrite(GridDhtTxPrepareRequest.class); +// gen.generateAndWrite(GridDhtTxPrepareResponse.class); // -// gen.generateAndWrite(GridDistributedTxFinishRequest.class); -// gen.generateAndWrite(GridDistributedTxFinishResponse.class); -// gen.generateAndWrite(GridNearTxFinishRequest.class); -// gen.generateAndWrite(GridNearTxFinishResponse.class); -// gen.generateAndWrite(GridDhtTxFinishRequest.class); -// gen.generateAndWrite(GridDhtTxFinishResponse.class); +// gen.generateAndWrite(GridDistributedTxFinishRequest.class); +// gen.generateAndWrite(GridDistributedTxFinishResponse.class); +// gen.generateAndWrite(GridNearTxFinishRequest.class); +// gen.generateAndWrite(GridNearTxFinishResponse.class); +// gen.generateAndWrite(GridDhtTxFinishRequest.class); +// gen.generateAndWrite(GridDhtTxFinishResponse.class); // -// gen.generateAndWrite(GridCacheOptimisticCheckPreparedTxRequest.class); -// gen.generateAndWrite(GridCacheOptimisticCheckPreparedTxResponse.class); - } - catch (Exception e) { - e.printStackTrace(); - } +// gen.generateAndWrite(GridCacheOptimisticCheckPreparedTxRequest.class); +// gen.generateAndWrite(GridCacheOptimisticCheckPreparedTxResponse.class); } /** @@ -189,7 +185,7 @@ public class CommunicationMessageCodeGenerator { * @throws Exception In case of error. */ @SuppressWarnings("ConstantConditions") - private void generateAndWrite(Class<? extends MessageAdapter> cls) throws Exception { + public void generateAndWrite(Class<? extends MessageAdapter> cls) throws Exception { assert cls != null; generate(cls); @@ -272,7 +268,7 @@ public class CommunicationMessageCodeGenerator { * @param cls Class. * @throws Exception In case of error. */ - public void generate(Class<? extends MessageAdapter> cls) throws Exception { + private void generate(Class<? extends MessageAdapter> cls) throws Exception { assert cls != null; write.clear();
