qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r577223 - in /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client: ./ impl/ util/
Date Wed, 19 Sep 2007 09:56:23 GMT
Author: arnaudsimon
Date: Wed Sep 19 02:56:22 2007
New Revision: 577223

URL: http://svn.apache.org/viewvc?rev=577223&view=rev
Log:
added nclient

Modified:
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Client.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Connection.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/DtxSession.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/ExceptionListener.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/JMSTestCase.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/MessagePartListener.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Session.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSession.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSessionDelegate.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/DemoClient.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/LargeMsgDemoClient.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ByteBufferMessage.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/FileMessage.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessageListener.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessagePartListenerAdapter.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ReadOnlyMessage.java
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/StreamingMessage.java

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Client.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Client.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Client.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Client.java
Wed Sep 19 02:56:22 2007
@@ -1,4 +1,4 @@
-package org.apache.qpidity.client;
+package org.apache.qpidity.nclient;
 
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.locks.Condition;
@@ -8,8 +8,8 @@
 import org.apache.qpidity.BrokerDetails;
 import org.apache.qpidity.ErrorCode;
 import org.apache.qpidity.QpidException;
-import org.apache.qpidity.client.impl.ClientSession;
-import org.apache.qpidity.client.impl.ClientSessionDelegate;
+import org.apache.qpidity.nclient.impl.ClientSession;
+import org.apache.qpidity.nclient.impl.ClientSessionDelegate;
 import org.apache.qpidity.transport.Channel;
 import org.apache.qpidity.transport.Connection;
 import org.apache.qpidity.transport.ConnectionClose;
@@ -21,7 +21,7 @@
 import org.apache.qpidity.url.QpidURL;
 
 
-public class Client implements org.apache.qpidity.client.Connection
+public class Client implements org.apache.qpidity.nclient.Connection
 {
     private AtomicInteger _channelNo = new AtomicInteger();
     private Connection _conn;
@@ -32,7 +32,7 @@
      *
      * @return returns a new connection to the broker.
      */
-    public static org.apache.qpidity.client.Connection createConnection()
+    public static org.apache.qpidity.nclient.Connection createConnection()
     {
         return new Client();
     }

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Connection.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Connection.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Connection.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Connection.java
Wed Sep 19 02:56:22 2007
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpidity.client;
+package org.apache.qpidity.nclient;
 
 import org.apache.qpidity.QpidException;
 import org.apache.qpidity.url.QpidURL;

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/DtxSession.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/DtxSession.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/DtxSession.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/DtxSession.java
Wed Sep 19 02:56:22 2007
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpidity.client;
+package org.apache.qpidity.nclient;
 
 import org.apache.qpidity.transport.DtxCoordinationCommitResult;
 import org.apache.qpidity.transport.DtxCoordinationGetTimeoutResult;

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/ExceptionListener.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/ExceptionListener.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/ExceptionListener.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/ExceptionListener.java
Wed Sep 19 02:56:22 2007
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpidity.client;
+package org.apache.qpidity.nclient;
 
 import org.apache.qpidity.QpidException;
 

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/JMSTestCase.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/JMSTestCase.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/JMSTestCase.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/JMSTestCase.java
Wed Sep 19 02:56:22 2007
@@ -1,7 +1,7 @@
-package org.apache.qpidity.client;
+package org.apache.qpidity.nclient;
 
-import org.apache.qpidity.jms.ConnectionFactoryImpl;
-import org.apache.qpidity.jms.TopicImpl;
+import org.apache.qpidity.njms.ConnectionFactoryImpl;
+import org.apache.qpidity.njms.TopicImpl;
 
 public class JMSTestCase
 {

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/MessagePartListener.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/MessagePartListener.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/MessagePartListener.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/MessagePartListener.java
Wed Sep 19 02:56:22 2007
@@ -15,7 +15,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpidity.client;
+package org.apache.qpidity.nclient;
 
 import java.nio.ByteBuffer;
 

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Session.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Session.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Session.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/Session.java
Wed Sep 19 02:56:22 2007
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpidity.client;
+package org.apache.qpidity.nclient;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
@@ -118,8 +118,8 @@
      * <br><b><i>This method should only be used by large messages</b></i><br>
      * There are two convinience Message classes provided to facilitate this.
      * <ul>
-     * <li> <code>{@link org.apache.qpidity.client.util.FileMessage}</code>
-     * <li> <code>{@link org.apache.qpidity.client.util.StreamingMessage}</code>
+     * <li> <code>{@link org.apache.qpidity.nclient.util.FileMessage}</code>
+     * <li> <code>{@link org.apache.qpidity.nclient.util.StreamingMessage}</code>
      * </ul>
      * You could also implement a the <code>Message</code> interface to and wrap
any
      * data stream you want.
@@ -253,7 +253,7 @@
      *                    acquired when the transfer starts
      *                    </ul>
      * @param listener    The listener for this destination. When big message are transfered
then
-     *                    it is recommended to use a {@link org.apache.qpidity.client.MessagePartListener}.
+     *                    it is recommended to use a {@link org.apache.qpidity.nclient.MessagePartListener}.
      * @param options     Set of Options (valid options are {@link Option#NO_LOCAL}, {@link
Option#EXCLUSIVE}
      *                    and {@link Option#NO_OPTION})
      * @param filter      A set of filters for the subscription. The syntax and semantics
of these filters depends

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSession.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSession.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSession.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSession.java
Wed Sep 19 02:56:22 2007
@@ -1,4 +1,4 @@
-package org.apache.qpidity.client.impl;
+package org.apache.qpidity.nclient.impl;
 
 import java.io.EOFException;
 import java.io.IOException;
@@ -10,13 +10,13 @@
 import org.apache.qpidity.transport.Range;
 import org.apache.qpidity.transport.RangeSet;
 import org.apache.qpidity.api.Message;
-import org.apache.qpidity.client.ExceptionListener;
-import org.apache.qpidity.client.MessagePartListener;
+import org.apache.qpidity.nclient.ExceptionListener;
+import org.apache.qpidity.nclient.MessagePartListener;
 
 /**
  * Implements a Qpid Sesion. 
  */
-public class ClientSession extends org.apache.qpidity.transport.Session implements  org.apache.qpidity.client.DtxSession
+public class ClientSession extends org.apache.qpidity.transport.Session implements  org.apache.qpidity.nclient.DtxSession
 {
     private Map<String,MessagePartListener> _messageListeners = new HashMap<String,MessagePartListener>();
     private ExceptionListener _exceptionListner;

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSessionDelegate.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSessionDelegate.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSessionDelegate.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/ClientSessionDelegate.java
Wed Sep 19 02:56:22 2007
@@ -1,10 +1,10 @@
-package org.apache.qpidity.client.impl;
+package org.apache.qpidity.nclient.impl;
 
 import java.nio.ByteBuffer;
 
 import org.apache.qpidity.ErrorCode;
 
-import org.apache.qpidity.client.MessagePartListener;
+import org.apache.qpidity.nclient.MessagePartListener;
 
 import org.apache.qpidity.QpidException;
 import org.apache.qpidity.transport.Data;
@@ -16,7 +16,6 @@
 import org.apache.qpidity.transport.Session;
 import org.apache.qpidity.transport.SessionClosed;
 import org.apache.qpidity.transport.SessionDelegate;
-import org.apache.qpidity.transport.Struct;
 
 
 public class ClientSessionDelegate extends SessionDelegate

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/DemoClient.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/DemoClient.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/DemoClient.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/DemoClient.java
Wed Sep 19 02:56:22 2007
@@ -1,13 +1,13 @@
-package org.apache.qpidity.client.impl;
+package org.apache.qpidity.nclient.impl;
 
 import org.apache.qpidity.QpidException;
 import org.apache.qpidity.api.Message;
-import org.apache.qpidity.client.Client;
-import org.apache.qpidity.client.Connection;
-import org.apache.qpidity.client.ExceptionListener;
-import org.apache.qpidity.client.Session;
-import org.apache.qpidity.client.util.MessageListener;
-import org.apache.qpidity.client.util.MessagePartListenerAdapter;
+import org.apache.qpidity.nclient.Client;
+import org.apache.qpidity.nclient.Connection;
+import org.apache.qpidity.nclient.ExceptionListener;
+import org.apache.qpidity.nclient.Session;
+import org.apache.qpidity.nclient.util.MessageListener;
+import org.apache.qpidity.nclient.util.MessagePartListenerAdapter;
 import org.apache.qpidity.transport.DeliveryProperties;
 import org.apache.qpidity.transport.MessageProperties;
 

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/LargeMsgDemoClient.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/LargeMsgDemoClient.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/LargeMsgDemoClient.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/impl/LargeMsgDemoClient.java
Wed Sep 19 02:56:22 2007
@@ -1,16 +1,16 @@
-package org.apache.qpidity.client.impl;
+package org.apache.qpidity.nclient.impl;
 
 import java.io.FileInputStream;
 
 import org.apache.qpidity.QpidException;
 import org.apache.qpidity.api.Message;
-import org.apache.qpidity.client.Client;
-import org.apache.qpidity.client.Connection;
-import org.apache.qpidity.client.ExceptionListener;
-import org.apache.qpidity.client.Session;
-import org.apache.qpidity.client.util.FileMessage;
-import org.apache.qpidity.client.util.MessageListener;
-import org.apache.qpidity.client.util.MessagePartListenerAdapter;
+import org.apache.qpidity.nclient.Client;
+import org.apache.qpidity.nclient.Connection;
+import org.apache.qpidity.nclient.ExceptionListener;
+import org.apache.qpidity.nclient.Session;
+import org.apache.qpidity.nclient.util.FileMessage;
+import org.apache.qpidity.nclient.util.MessageListener;
+import org.apache.qpidity.nclient.util.MessagePartListenerAdapter;
 import org.apache.qpidity.transport.DeliveryProperties;
 import org.apache.qpidity.transport.MessageProperties;
 

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ByteBufferMessage.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ByteBufferMessage.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ByteBufferMessage.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ByteBufferMessage.java
Wed Sep 19 02:56:22 2007
@@ -1,4 +1,4 @@
-package org.apache.qpidity.client.util;
+package org.apache.qpidity.nclient.util;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/FileMessage.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/FileMessage.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/FileMessage.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/FileMessage.java
Wed Sep 19 02:56:22 2007
@@ -1,4 +1,4 @@
-package org.apache.qpidity.client.util;
+package org.apache.qpidity.nclient.util;
 
 import java.io.EOFException;
 import java.io.FileInputStream;

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessageListener.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessageListener.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessageListener.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessageListener.java
Wed Sep 19 02:56:22 2007
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpidity.client.util;
+package org.apache.qpidity.nclient.util;
 
 import org.apache.qpidity.api.Message;
 

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessagePartListenerAdapter.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessagePartListenerAdapter.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessagePartListenerAdapter.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/MessagePartListenerAdapter.java
Wed Sep 19 02:56:22 2007
@@ -1,4 +1,4 @@
-package org.apache.qpidity.client.util;
+package org.apache.qpidity.nclient.util;
 
 import java.io.IOException;
 import java.nio.ByteBuffer;
@@ -6,7 +6,7 @@
 import org.apache.qpidity.transport.DeliveryProperties;
 import org.apache.qpidity.transport.MessageProperties;
 import org.apache.qpidity.transport.Header;
-import org.apache.qpidity.client.MessagePartListener;
+import org.apache.qpidity.nclient.MessagePartListener;
 
 /**
  * This is a simple message assembler.

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ReadOnlyMessage.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ReadOnlyMessage.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ReadOnlyMessage.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/ReadOnlyMessage.java
Wed Sep 19 02:56:22 2007
@@ -1,4 +1,4 @@
-package org.apache.qpidity.client.util;
+package org.apache.qpidity.nclient.util;
 
 import java.nio.ByteBuffer;
 

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/StreamingMessage.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/StreamingMessage.java?rev=577223&r1=577222&r2=577223&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/StreamingMessage.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client/util/StreamingMessage.java
Wed Sep 19 02:56:22 2007
@@ -1,4 +1,4 @@
-package org.apache.qpidity.client.util;
+package org.apache.qpidity.nclient.util;
 
 import java.io.EOFException;
 import java.io.IOException;



Mime
View raw message