Updated package name

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@559475 13f79535-47bb-0310-9956-ffa450edef68

17 files changed, 137 insertions, 17 deletions

diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java b/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java
index fd59b95c0f..38e9b5cf98 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java
@@ -6,9 +6,9 @@
  * to you under the Apache License, Version 2.0 (the
  * "License"); you may not use this file except in compliance
  * with the License.  You may obtain a copy of the License at
- * 
+ *
  *   http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing,
  * software distributed under the License is distributed on an
  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@@ -16,7 +16,10 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
+
+
+
 
 import org.apache.qpid.nclient.exception.QpidException;
 
@@ -35,7 +38,7 @@ public interface Connection
      * Establish the connection with the broker identified by the provided URL.
      *
      * @param url The URL of the broker.
-     * @throws QpidException If the communication layer fails to connect with the broker.
+     * @throws org.apache.qpid.nclient.exception.QpidException If the communication layer fails to connect with the broker.
      */
     public void connect(URL url)
             throws
@@ -78,4 +81,12 @@ public interface Connection
     public DtxSession createDTXSession(int expiryInSeconds)
             throws
             QpidException;
+
+    /**
+     * If the communication layer detects a serious problem with a connection, it
+     * informs the connection's ExceptionListener
+     *
+     * @param exceptionListner The execptionListener
+     */
+    public void setExceptionListener(ExceptionListener exceptionListner);
 }
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java b/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java
index 4d8315c33b..e3cd813170 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java
@@ -1,4 +1,4 @@
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 /**
  * Enumeration of the options available when creating a receiver
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java b/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java
index 8674792252..241dd1d02f 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java
@@ -1,4 +1,4 @@
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 /**
  * Enumeration of the options available when declaring an exchange
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java b/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java
index e5b80b00df..89e3573024 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java
@@ -1,4 +1,4 @@
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 /**
  * Enumeration of the options available when declaring a queue
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java b/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java
index 188d665c8c..17ee5beb1f 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java
@@ -1,4 +1,4 @@
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 /**
  * Created by Arnaud Simon
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java b/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java
index 0062218a70..c0a30f8b68 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java
@@ -1,4 +1,4 @@
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 /**
  * Created by Arnaud Simon
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java b/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java
index c361fdcf82..89267025d3 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 import org.apache.qpid.nclient.exception.QpidException;
 
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java b/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java
new file mode 100644
index 0000000000..40a6e63771
--- /dev/null
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java
@@ -0,0 +1,41 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.qpid.nclient.api;
+
+import org.apache.qpid.nclient.exception.QpidException;
+
+/**
+ * If the communication layer detects a serious problem with a <CODE>connection</CODE>, it
+ * informs the connection's ExceptionListener
+ *
+ * Created by Arnaud Simon
+ * Date: 25-Jul-2007
+ * Time: 12:00:27
+ */
+public interface ExceptionListener
+{
+    /**
+     * If the communication layer detects a serious problem with a connection, it
+     * informs the connection's ExceptionListener
+     *
+     * @param exception The exception comming from the communication layer.
+     * @see org.apache.qpid.nclient.qpidapi.Connection
+     */
+    public void onException(QpidException exception);
+}
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java b/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java
index 6974d0cae2..fd9cead174 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 
 import org.apache.qpid.nclient.FieldTable;
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java b/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java
index d607d0a3c2..b0dfa15bbf 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 /**
  * MessageListeners are used to asynchronously receive messages.
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java b/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
index 6592857b2e..84d38057c3 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 import org.apache.qpid.nclient.exception.QpidException;
 
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java b/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java
index 545c06e67e..ab7604da77 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 import org.apache.qpid.nclient.exception.QpidException;
 
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java b/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java
new file mode 100644
index 0000000000..9683bd43f0
--- /dev/null
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java
@@ -0,0 +1,29 @@
+/* Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.qpid.nclient.api;
+
+import org.apache.qpid.nclient.jms.SessionImpl;
+
+/**
+ * Created by Arnaud Simon
+ * Date: 25-Jul-2007
+ * Time: 13:38:58
+ */
+public class QueueSessionImpl extends SessionImpl
+{
+}
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java b/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java
index 29965e0045..47587f1cde 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 import org.apache.qpid.nclient.exception.QpidException;
 
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java b/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
index 31b11134ba..50456378aa 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
 
 import org.apache.qpid.nclient.exception.QpidException;
 
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java b/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java
new file mode 100644
index 0000000000..214139fbdc
--- /dev/null
+++ b/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java
@@ -0,0 +1,29 @@
+/* Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.qpid.nclient.api;
+
+import org.apache.qpid.nclient.jms.SessionImpl;
+
+/**
+ * Created by Arnaud Simon
+ * Date: 25-Jul-2007
+ * Time: 13:39:35
+ */
+public class TopicSessionImpl extends SessionImpl
+{
+}
diff --git a/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java b/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java
index cacac98cc0..c2a70f705f 100644
--- a/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java
+++ b/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java
@@ -30,7 +30,7 @@ public class QpidException extends Exception
      * <p> This error code is set from the AMQP ones.
      * <TODO> So we may want to use the AMQP error code directly.
      */
-    String _errorCode;
+    private String _errorCode;
 
     /**
      * Constructor for a Qpid Exception.
@@ -45,4 +45,14 @@ public class QpidException extends Exception
         super(message, cause);
         _errorCode = errorCode;
     }
+
+    /**
+     * Get this execption error code.
+     *
+     * @return This exception error code.
+     */
+    public String getErrorCode()
+    {
+        return _errorCode;
+    }
 }