corrected out of order message updates issue

3 files changed, 4 insertions, 3 deletions

diff --git a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/ChannelProcessor.java b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/ChannelProcessor.java
index bb424c842dd..770b56bba5d 100644
--- a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/ChannelProcessor.java
+++ b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/ChannelProcessor.java
@@ -17,6 +17,7 @@ import java.util.Arrays;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.ExecutorService;
 import java.util.logging.Level;
+
 import org.eclipse.osee.framework.logging.OseeLog;
 import org.eclipse.osee.ote.client.msg.core.db.AbstractMessageDataBase;
 import org.eclipse.osee.ote.client.msg.core.db.MessageInstance;
@@ -71,7 +72,6 @@ final public class ChannelProcessor {
 				OseeLog.log(Activator.class, Level.SEVERE, "failed to process message update", ex);

 			}

 		}

-

 	}

 

 	public ChannelProcessor(int depth, int bufferSize, ExecutorService threadPool, AbstractMessageDataBase msgDb, DataType memType) {

diff --git a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java
index 46023d39b07..aa0f7dabf20 100644
--- a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java
+++ b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/MessageSubscriptionService.java
@@ -188,7 +188,7 @@ public class MessageSubscriptionService implements IOteMessageService, IMessageD
 
       int port = PortUtil.getInstance().getConsecutiveValidPorts(availableTypes.size());
       for (DataType type : availableTypes) {
-         final ChannelProcessor handler = new ChannelProcessor(type.getToolingDepth(), type.getToolingBufferSize(), threadPool, msgDatabase, type);
+         final ChannelProcessor handler = new ChannelProcessor(1, type.getToolingBufferSize(), threadPool, msgDatabase, type);
 	  
          dispatcher.addChannel(localAddress, port, type, handler);
          port++;
diff --git a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java
index 0175ddc9d49..b55fb5b1fcd 100644
--- a/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java
+++ b/plugins/org.eclipse.osee.ote.client.msg/src/org/eclipse/osee/ote/client/msg/core/internal/UpdateDispatcher.java
@@ -21,6 +21,7 @@ import java.util.Iterator;
 import java.util.Map;
 import java.util.Set;
 import java.util.logging.Level;
+
 import org.eclipse.osee.framework.logging.OseeLog;
 import org.eclipse.osee.ote.message.enums.DataType;
 

@@ -34,7 +35,7 @@ public final class UpdateDispatcher {
 	/**
 	 * 
 	 */
-	private static final int RECEIVE_BUFFER_SIZE = 1024 * 128;
+	private static final int RECEIVE_BUFFER_SIZE = 1024 * 256;
 
 	/** * Class Instance Fields ** */

 	private final Map<DataType, DatagramChannel> channelMap = new HashMap<DataType, DatagramChannel>();