This change also broke the build. The ClientSession class imports and
uses the MessageSender class which doesn't exist on the head of the trunk.
This either happened because:
a) you didn't build before submitting
b) you didn't do a *clean* build before submitting, and there was a
stale .class file hanging around in your build classpath
c) you did a clean build before submitting, but you were building
against a stale checkout that still had the MessageSender.java file
Please be sure to always do an svn update, followed by a clean build
before submitting changes, particularly with the kind of development
going on in the common and client modules where classes are being
added/removed with relative frequency.
I've commented out the offending code in the ClientSession class. You
may want to take a look at it and either modify it to work or remove it.
--Rafael
[EMAIL PROTECTED] wrote:
Author: rajith
Date: Tue Jul 31 08:37:39 2007
New Revision: 561362
URL: http://svn.apache.org/viewvc?view=rev&rev=561362
Log:
adding impl classes
Added:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/SessionDelegate.java
Added:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java?view=auto&rev=561362
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
(added)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/ClientSession.java
Tue Jul 31 08:37:39 2007
@@ -0,0 +1,64 @@
+package org.apache.qpid.nclient.impl;
+
+import org.apache.qpid.nclient.api.Message;
+import org.apache.qpid.nclient.api.MessageReceiver;
+import org.apache.qpid.nclient.api.MessageSender;
+import org.apache.qpidity.Header;
+import org.apache.qpidity.Option;
+import org.apache.qpidity.QpidException;
+import org.apache.qpidity.Session;
+
+public class ClientSession extends Session implements
org.apache.qpid.nclient.api.Session
+{
+ /**
+ * ---------------------------------------------------
+ * Message methods
+ * ---------------------------------------------------
+ */
+ public MessageSender createSender(String queueName) throws QpidException
+ {
+ return null;
+ }
+
+ public MessageReceiver createReceiver(String queueName, Option...
options) throws QpidException
+ {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ public void setTransacted() throws QpidException, IllegalStateException
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ public void messageBody(byte[] src) throws QpidException
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ public void messageClose() throws QpidException
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ public void messageHeaders(Header... headers) throws QpidException
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ public void messageTransfer(String destination, Message msg) throws
QpidException
+ {
+ // TODO Auto-generated method stub
+
+ }
+
+ public void messageTransfer(Option... options) throws QpidException
+ {
+ // TODO Auto-generated method stub
+
+ }
+}
Added:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/SessionDelegate.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/SessionDelegate.java?view=auto&rev=561362
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/SessionDelegate.java
(added)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl/SessionDelegate.java
Tue Jul 31 08:37:39 2007
@@ -0,0 +1,56 @@
+package org.apache.qpid.nclient.impl;
+
+import org.apache.qpidity.CommonSessionDelegate;
+import org.apache.qpidity.Delegate;
+import org.apache.qpidity.ExchangeDeclare;
+import org.apache.qpidity.ExchangeDelete;
+import org.apache.qpidity.ExchangeQuery;
+import org.apache.qpidity.ExchangeQueryOk;
+import org.apache.qpidity.QueueBind;
+import org.apache.qpidity.QueueDeclare;
+import org.apache.qpidity.QueueDeclareOk;
+import org.apache.qpidity.QueueDelete;
+import org.apache.qpidity.QueueDeleteOk;
+import org.apache.qpidity.QueuePurge;
+import org.apache.qpidity.QueuePurgeOk;
+import org.apache.qpidity.QueueUnbind;
+import org.apache.qpidity.Session;
+
+
+public class SessionDelegate extends CommonSessionDelegate
+{
+
+ /**
+ * --------------------------------------------
+ * Exchange related functionality
+ * --------------------------------------------
+ */
+ public void exchangeDeclare(Session session, ExchangeDeclare struct) {}
+
+ public void exchangeDelete(Session session, ExchangeDelete struct) {}
+
+ public void exchangeQuery(Session session, ExchangeQuery struct) {}
+
+ public void exchangeQueryOk(Session session, ExchangeQueryOk struct) {}
+
+ /**
+ * --------------------------------------------
+ * Queue related functionality
+ * --------------------------------------------
+ */
+ public void queueDeclare(Session session, QueueDeclare struct) {}
+
+ public void queueDeclareOk(Session session, QueueDeclareOk struct) {}
+
+ public void queueBind(Session session, QueueBind struct) {}
+
+ public void queueUnbind(Session session, QueueUnbind struct) {}
+
+ public void queuePurge(Session session, QueuePurge struct) {}
+
+ public void queuePurgeOk(Session session, QueuePurgeOk struct) {}
+
+ public void queueDelete(Session session, QueueDelete struct) {}
+
+ public void queueDeleteOk(Session session, QueueDeleteOk struct) {}
+}
