You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2007/07/31 17:37:40 UTC
svn commit: r561362 - in
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl:
./ ClientSession.java SessionDelegate.java
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) {}
+}
Re: svn commit: r561362 - in /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl: ./ ClientSession.java SessionDelegate.java
Posted by Rajith Attapattu <ra...@gmail.com>.
Not sure what happend, but my fault for not checking throughly.
Regards,
Rajith
On 7/31/07, Rafael Schloming <ra...@redhat.com> wrote:
>
> 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
>
> rajith@apache.org 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) {}
> > +}
> >
> >
>
Re: svn commit: r561362 - in /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/nclient/impl:
./ ClientSession.java SessionDelegate.java
Posted by Rafael Schloming <ra...@redhat.com>.
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
rajith@apache.org 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) {}
> +}
>
>