You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/09/19 11:56:23 UTC
svn commit: r577223 - in
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpidity/client:
./ impl/ util/
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;