Method messageReceived

test/org/apache/catalina/tribes/demos/LoadTest.java:197–229

(Serializable msg, Member mbr)

    }

    @Override
    public void messageReceived(Serializable msg, Member mbr) {
        if (receiveStart == 0) {
            receiveStart = System.currentTimeMillis();
        }
        if (debug) {
            if (msg instanceof LoadMessage) {
                printArray(((LoadMessage) msg).getMessage());
            }
        }

        if (msg instanceof ByteMessage && !(msg instanceof LoadMessage)) {
            LoadMessage tmp = new LoadMessage();
            tmp.setMessage(((ByteMessage) msg).getMessage());
            msg = tmp;
            tmp = null;
        }


        bytesReceived += ((LoadMessage) msg).getMessage().length;
        mBytesReceived += (((LoadMessage) msg).getMessage().length) / 1024f / 1024f;
        messagesReceived++;
        if ((messagesReceived % statsInterval) == 0 || (messagesReceived == msgCount)) {
            float bytes = (((LoadMessage) msg).getMessage().length * messagesReceived);
            float seconds = (System.currentTimeMillis() - receiveStart) / 1000f;
            log.info("****RECEIVE STATS-" + Thread.currentThread().getName() + "*****" + "\n\tMessage count :" +
                    (long) messagesReceived + "\n\tMessage/sec   :" + messagesReceived / seconds +
                    "\n\tTotal bytes   :" + (long) bytes + "\n\tTotal mbytes  :" + (long) mBytesReceived +
                    "\n\tTime since 1st:" + seconds + " seconds" + "\n\tBytes/second  :" + (bytes / seconds) +
                    "\n\tMBytes/second :" + (mBytesReceived / seconds) + "\n");

        }
    }


    public static void printArray(byte[] data) {