I have a problem where there are a lot of compressed messages coming into my
rosjava application, but I only care about decompressing the latest message. As
such, I want to set the size of my subscriber queue to 1. However, there is no
way to do this in rosjava
as the queue size is hard-coded in
src/main/java/org/ros/internal/transport/IncomingMessageQueue.java line 36:
private static final int MESSAGE_BUFFER_CAPACITY = 8192;
There is also, to my knowledge, no way to determine how many messages are left
in the queue in order to decide whether to process a message or move on to the
latest one. This, in turn, means that my node falls woefully behind in
processing messages.
Original issue reported on code.google.com by ei...@willowgarage.com on 26 Oct 2011 at 7:10
Original issue reported on code.google.com by
ei...@willowgarage.com
on 26 Oct 2011 at 7:10