qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arnaudsi...@apache.org
Subject svn commit: r581052 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Date Mon, 01 Oct 2007 19:56:46 GMT
Author: arnaudsimon
Date: Mon Oct  1 12:56:46 2007
New Revision: 581052

URL: http://svn.apache.org/viewvc?rev=581052&view=rev
Log:
Changed to set topic names

Modified:
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=581052&r1=581051&r2=581052&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
(original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Mon Oct  1 12:56:46 2007
@@ -317,11 +317,10 @@
         }
         catch (JMSException e)
         {
-           throw new AMQException(AMQConstant.INTERNAL_ERROR, "problem when registering consumer",
e);
+            throw new AMQException(AMQConstant.INTERNAL_ERROR, "problem when registering
consumer", e);
         }
         getQpidSession().messageSubscribe(queueName.toString(), tag.toString(), Session.TRANSFER_CONFIRM_MODE_REQUIRED,
-                                          preAcquire ? Session.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE
:
-                                                  Session.TRANSFER_ACQUIRE_MODE_NO_ACQUIRE,
+                                          preAcquire ? Session.TRANSFER_ACQUIRE_MODE_PRE_ACQUIRE
: Session.TRANSFER_ACQUIRE_MODE_NO_ACQUIRE,
                                           new MessagePartListenerAdapter((BasicMessageConsumer_0_10)
consumer), null,
                                           consumer.isNoLocal() ? Option.NO_LOCAL : Option.NO_OPTION,
                                           consumer.isExclusive() ? Option.EXCLUSIVE : Option.NO_OPTION);
@@ -365,12 +364,26 @@
     public void sendQueueDeclare(final AMQDestination amqd, final AMQProtocolHandler protocolHandler)
             throws AMQException, FailoverException
     {
-        if( amqd.getAMQQueueName() == null )
+        // do nothing this is only used by 0_8
+    }
+
+    /**
+     * Declare a queue with the given queueName
+     */
+    public AMQShortString send0_10QueueDeclare(final AMQDestination amqd, final AMQProtocolHandler
protocolHandler)
+            throws AMQException, FailoverException
+    {
+        AMQShortString res;
+        if (amqd.getAMQQueueName() == null)
         {
             // generate a name for this queue
-            amqd.setQueueName(new AMQShortString("TempQueue" + UUID.randomUUID()));
+            res = new AMQShortString("TempQueue" + UUID.randomUUID());
+        }
+        else
+        {
+            res = amqd.getAMQQueueName();
         }
-        getQpidSession().queueDeclare(amqd.getAMQQueueName().toString(), null, null,
+        getQpidSession().queueDeclare(res.toString(), null, null,
                                       amqd.isAutoDelete() ? Option.AUTO_DELETE : Option.NO_OPTION,
                                       amqd.isDurable() ? Option.DURABLE : Option.NO_OPTION,
                                       amqd.isExclusive() ? Option.EXCLUSIVE : Option.NO_OPTION);
@@ -378,6 +391,7 @@
         // We need to sync so that we get notify of an error.
         getQpidSession().sync();
         getCurrentException();
+        return res;
     }
 
     /**
@@ -412,8 +426,8 @@
                 getQpidSession().messageFlow(consumer.getConsumerTag().toString(), Session.MESSAGE_FLOW_UNIT_MESSAGE,
                                              MAX_PREFETCH);
                 // todo this 
-                getQpidSession().messageFlow(consumer.getConsumerTag().toString(), Session.MESSAGE_FLOW_UNIT_BYTE,
-                                             0xFFFFFFFF);
+                getQpidSession()
+                        .messageFlow(consumer.getConsumerTag().toString(), Session.MESSAGE_FLOW_UNIT_BYTE,
0xFFFFFFFF);
             }
         }
         // We need to sync so that we get notify of an error.
@@ -462,36 +476,35 @@
             {
                 //todo check the error code for finding out if we need to notify the
                 // JMS connection exception listener
-                _currentException = new QpidException(reason,errorCode,null);
+                _currentException = new QpidException(reason, errorCode, null);
             }
         }
     }
 
     protected AMQShortString declareQueue(final AMQDestination amqd, final AMQProtocolHandler
protocolHandler)
-              throws AMQException
-      {
-          /*return new FailoverRetrySupport<AMQShortString, AMQException>(*/
-          return new FailoverNoopSupport<AMQShortString, AMQException>(
-                  new FailoverProtectedOperation<AMQShortString, AMQException>()
-                  {
-                      public AMQShortString execute() throws AMQException, FailoverException
-                      {
-                          // Generate the queue name if the destination indicates that a
client generated name is to be used.
-                          if (amqd.isNameRequired())
-                          {
-                                 amqd.setQueueName(new AMQShortString("TempQueue" + UUID.randomUUID()));
-                          }
-                          sendQueueDeclare(amqd,protocolHandler);
-                          return amqd.getAMQQueueName();
-                      }
-                  }, _connection).execute();
-      }
+            throws AMQException
+    {
+        /*return new FailoverRetrySupport<AMQShortString, AMQException>(*/
+        return new FailoverNoopSupport<AMQShortString, AMQException>(
+                new FailoverProtectedOperation<AMQShortString, AMQException>()
+                {
+                    public AMQShortString execute() throws AMQException, FailoverException
+                    {
+                        // Generate the queue name if the destination indicates that a client
generated name is to be used.
+                        if (amqd.isNameRequired())
+                        {
+                            amqd.setQueueName(new AMQShortString("TempQueue" + UUID.randomUUID()));
+                        }
+                        return send0_10QueueDeclare(amqd, protocolHandler);
+                    }
+                }, _connection).execute();
+    }
 
 
-      void start() throws AMQException
+    void start() throws AMQException
     {
 
-           super.suspendChannel(false);
+        super.suspendChannel(false);
 
         // If the event dispatcher is not running then start it too.
         if (hasMessageListeners())



Mime
View raw message