Not sure what happend, but my fault for not checking throughly. Regards,
Rajith On 7/31/07, Rafael Schloming <[EMAIL PROTECTED]> 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 > > [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) {} > > +} > > > > >
