Commit fd93d76e authored by afreyssin's avatar afreyssin
Browse files

Bug fix (JORAM-284): The encoded size is incoherent with the encode/decode....

Bug fix (JORAM-284): The encoded size is incoherent with the encode/decode. This issue is hidden by a reverse issue in Destination class (JORAM-285).
parent e282b5a3
/* /*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging * JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2001 - 2017 ScalAgent Distributed Technologies * Copyright (C) 2001 - 2018 ScalAgent Distributed Technologies
* Copyright (C) 1996 - 2000 Dyade * Copyright (C) 1996 - 2000 Dyade
* *
* This library is free software; you can redistribute it and/or * This library is free software; you can redistribute it and/or
...@@ -1933,13 +1933,15 @@ public class Queue extends Destination implements QueueMBean { ...@@ -1933,13 +1933,15 @@ public class Queue extends Destination implements QueueMBean {
return stats; return stats;
} }
// Encodable interface
public int getEncodableClassId() { public int getEncodableClassId() {
return JoramHelper.QUEUE_CLASS_ID; return JoramHelper.QUEUE_CLASS_ID;
} }
public int getEncodedSize() throws Exception { public int getEncodedSize() throws Exception {
int encodedSize = super.getEncodedSize(); int encodedSize = super.getEncodedSize();
encodedSize += INT_ENCODED_SIZE * 4; encodedSize += INT_ENCODED_SIZE * 5;
encodedSize += LONG_ENCODED_SIZE; encodedSize += LONG_ENCODED_SIZE;
for (ReceiveRequest request : requests) { for (ReceiveRequest request : requests) {
encodedSize += request.getEncodedSize(); encodedSize += request.getEncodedSize();
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment