Author: arnaudsimon
Date: Wed Jul 25 07:29:46 2007
New Revision: 559475
URL: http://svn.apache.org/viewvc?view=rev&rev=559475
Log:
Updated package name
Added:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java
(with props)
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java
(with props)
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java
(with props)
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Connection.java
Wed Jul 25 07:29:46 2007
@@ -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 @@
* 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 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);
}
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/CreateReceiverOption.java
Wed Jul 25 07:29:46 2007
@@ -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
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareExchangeOption.java
Wed Jul 25 07:29:46 2007
@@ -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
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeclareQueueOption.java
Wed Jul 25 07:29:46 2007
@@ -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
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteExchangeOption.java
Wed Jul 25 07:29:46 2007
@@ -1,4 +1,4 @@
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
/**
* Created by Arnaud Simon
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DeleteQueueOption.java
Wed Jul 25 07:29:46 2007
@@ -1,4 +1,4 @@
-package org.apache.qpid.nclient.qpidapi;
+package org.apache.qpid.nclient.api;
/**
* Created by Arnaud Simon
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/DtxSession.java
Wed Jul 25 07:29:46 2007
@@ -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;
Added:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java?view=auto&rev=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java
(added)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java
Wed Jul 25 07:29:46 2007
@@ -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);
+}
Propchange:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/ExceptionListener.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Message.java
Wed Jul 25 07:29:46 2007
@@ -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;
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageListener.java
Wed Jul 25 07:29:46 2007
@@ -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.
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageReceiver.java
Wed Jul 25 07:29:46 2007
@@ -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;
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/MessageSender.java
Wed Jul 25 07:29:46 2007
@@ -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;
Added:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java?view=auto&rev=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java
(added)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java
Wed Jul 25 07:29:46 2007
@@ -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
+{
+}
Propchange:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/QueueSessionImpl.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Resource.java
Wed Jul 25 07:29:46 2007
@@ -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;
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/Session.java
Wed Jul 25 07:29:46 2007
@@ -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;
Added:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java?view=auto&rev=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java
(added)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java
Wed Jul 25 07:29:46 2007
@@ -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
+{
+}
Propchange:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/api/TopicSessionImpl.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java?view=diff&rev=559475&r1=559474&r2=559475
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/exception/QpidException.java
Wed Jul 25 07:29:46 2007
@@ -30,7 +30,7 @@
* <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.
@@ -44,5 +44,15 @@
{
super(message, cause);
_errorCode = errorCode;
+ }
+
+ /**
+ * Get this execption error code.
+ *
+ * @return This exception error code.
+ */
+ public String getErrorCode()
+ {
+ return _errorCode;
}
}
