From e9d07c3c2eaad9ddb73673795c3ded6ff2c8b414 Mon Sep 17 00:00:00 2001
From: Trustin Lee <trustin@gmail.com>
Date: Thu, 11 Jun 2009 07:16:10 +0000
Subject: [PATCH] OioDatagramWorker now honors buffer factory's default byte
 order

---
 .../jboss/netty/channel/socket/oio/OioDatagramWorker.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/jboss/netty/channel/socket/oio/OioDatagramWorker.java b/src/main/java/org/jboss/netty/channel/socket/oio/OioDatagramWorker.java
index 233c16c6fb..4e70ec742f 100644
--- a/src/main/java/org/jboss/netty/channel/socket/oio/OioDatagramWorker.java
+++ b/src/main/java/org/jboss/netty/channel/socket/oio/OioDatagramWorker.java
@@ -28,6 +28,7 @@ import java.io.InterruptedIOException;
 import java.net.DatagramPacket;
 import java.net.MulticastSocket;
 import java.net.SocketAddress;
+import java.nio.ByteOrder;
 
 import org.jboss.netty.buffer.ChannelBuffer;
 import org.jboss.netty.buffer.ChannelBuffers;
@@ -89,11 +90,12 @@ class OioDatagramWorker implements Runnable {
             }
 
             ChannelBuffer buffer;
+            ByteOrder endianness = channel.getConfig().getBufferFactory().getDefaultOrder();
             int readBytes = packet.getLength();
             if (readBytes == buf.length) {
-                buffer = ChannelBuffers.wrappedBuffer(buf);
+                buffer = ChannelBuffers.wrappedBuffer(endianness, buf);
             } else {
-                buffer = ChannelBuffers.wrappedBuffer(buf, 0, readBytes);
+                buffer = ChannelBuffers.wrappedBuffer(endianness, buf, 0, readBytes);
             }
 
             fireMessageReceived(channel, buffer, packet.getSocketAddress());