You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@directory.apache.org by ka...@apache.org on 2010/12/08 19:46:44 UTC

svn commit: r1043590 - /directory/sandbox/kayyagari/kerberos-client/src/main/java/org/apache/directory/kerberos/client/ReplyFuture.java

Author: kayyagari
Date: Wed Dec  8 18:46:43 2010
New Revision: 1043590

URL: http://svn.apache.org/viewvc?rev=1043590&view=rev
Log:
o fixed a NPE

Modified:
    directory/sandbox/kayyagari/kerberos-client/src/main/java/org/apache/directory/kerberos/client/ReplyFuture.java

Modified: directory/sandbox/kayyagari/kerberos-client/src/main/java/org/apache/directory/kerberos/client/ReplyFuture.java
URL: http://svn.apache.org/viewvc/directory/sandbox/kayyagari/kerberos-client/src/main/java/org/apache/directory/kerberos/client/ReplyFuture.java?rev=1043590&r1=1043589&r2=1043590&view=diff
==============================================================================
--- directory/sandbox/kayyagari/kerberos-client/src/main/java/org/apache/directory/kerberos/client/ReplyFuture.java (original)
+++ directory/sandbox/kayyagari/kerberos-client/src/main/java/org/apache/directory/kerberos/client/ReplyFuture.java Wed Dec  8 18:46:43 2010
@@ -21,6 +21,7 @@
 package org.apache.directory.kerberos.client;
 
 
+import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.TimeUnit;
 
@@ -35,7 +36,7 @@ import org.apache.directory.shared.kerbe
 public class ReplyFuture
 {
     /** the queue for holding the KerberosMessage sent from server */
-    private BlockingQueue<KerberosMessage> queue;
+    private BlockingQueue<KerberosMessage> queue = new ArrayBlockingQueue<KerberosMessage>( 1 );
 
 
     public KerberosMessage get() throws InterruptedException