avro/src/main/java/org/apache/mina/avro/codec/serialization/AvroMessageEncoder.java [62:68]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                encoder.flush();
                byte[] encoded = out.toByteArray();
                encodedMessage = ByteBuffer.wrap(encoded);
                out.close();
            } catch (IOException ioEx) {
                LOG.error("error while marshalling", ioEx);
                throw new ProtocolEncoderException(ioEx.getMessage());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



avro/src/main/java/org/apache/mina/avro/codec/serialization/AvroMessageEncoder.java [75:81]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                encoder.flush();
                byte[] encoded = out.toByteArray();
                encodedMessage = ByteBuffer.wrap(encoded);
                out.close();
            } catch (IOException ioEx) {
                LOG.error("error while marshalling", ioEx);
                throw new ProtocolEncoderException(ioEx.getMessage());
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -