Fixed incorrect error message in gryo serializer for Gryo 3.0 CTR
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/327b9137 Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/327b9137 Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/327b9137 Branch: refs/heads/TINKERPOP-1682 Commit: 327b9137a6f5c1e70def915a61dec89b36cbb591 Parents: 0ba34be Author: Stephen Mallette <[email protected]> Authored: Thu Jul 20 14:54:49 2017 -0400 Committer: Stephen Mallette <[email protected]> Committed: Thu Jul 20 14:54:49 2017 -0400 ---------------------------------------------------------------------- .../driver/ser/AbstractGryoMessageSerializerV3d0.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/327b9137/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/ser/AbstractGryoMessageSerializerV3d0.java ---------------------------------------------------------------------- diff --git a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/ser/AbstractGryoMessageSerializerV3d0.java b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/ser/AbstractGryoMessageSerializerV3d0.java index 1bca386..63cfa64 100644 --- a/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/ser/AbstractGryoMessageSerializerV3d0.java +++ b/gremlin-driver/src/main/java/org/apache/tinkerpop/gremlin/driver/ser/AbstractGryoMessageSerializerV3d0.java @@ -154,7 +154,7 @@ public abstract class AbstractGryoMessageSerializerV3d0 extends AbstractMessageS return kryo.readObject(input, ResponseMessage.class); } } catch (Exception ex) { - logger.warn("Response [{}] could not be deserialized by {}.", msg, GryoMessageSerializerV1d0.class.getName()); + logger.warn("Response [{}] could not be deserialized by {}.", msg, GryoMessageSerializerV3d0.class.getName()); throw new SerializationException(ex); } } @@ -188,7 +188,7 @@ public abstract class AbstractGryoMessageSerializerV3d0 extends AbstractMessageS } catch (Exception ex) { if (encodedMessage != null) ReferenceCountUtil.release(encodedMessage); - logger.warn("Response [{}] could not be serialized by {}.", responseMessage.toString(), GryoMessageSerializerV1d0.class.getName()); + logger.warn("Response [{}] could not be serialized by {}.", responseMessage.toString(), GryoMessageSerializerV3d0.class.getName()); throw new SerializationException(ex); } } @@ -205,7 +205,7 @@ public abstract class AbstractGryoMessageSerializerV3d0 extends AbstractMessageS return kryo.readObject(input, RequestMessage.class); } } catch (Exception ex) { - logger.warn("Request [{}] could not be deserialized by {}.", msg, GryoMessageSerializerV1d0.class.getName()); + logger.warn("Request [{}] could not be deserialized by {}.", msg, GryoMessageSerializerV3d0.class.getName()); throw new SerializationException(ex); } } @@ -236,7 +236,7 @@ public abstract class AbstractGryoMessageSerializerV3d0 extends AbstractMessageS } catch (Exception ex) { if (encodedMessage != null) ReferenceCountUtil.release(encodedMessage); - logger.warn("Request [{}] could not be serialized by {}.", requestMessage.toString(), GryoMessageSerializerV1d0.class.getName()); + logger.warn("Request [{}] could not be serialized by {}.", requestMessage.toString(), GryoMessageSerializerV3d0.class.getName()); throw new SerializationException(ex); } }
