Author: arnaudsimon
Date: Mon Oct 1 06:22:05 2007
New Revision: 580944
URL: http://svn.apache.org/viewvc?rev=580944&view=rev
Log:
Changed for setting new name to destinations
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=580944&r1=580943&r2=580944&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 06:22:05 2007
@@ -364,6 +364,11 @@
public void sendQueueDeclare(final AMQDestination amqd, final
AMQProtocolHandler protocolHandler)
throws AMQException, FailoverException
{
+ if( amqd.getAMQQueueName() == null )
+ {
+ // generate a name for this queue
+ amqd.setQueueName(new AMQShortString("tmp_"
+System.currentTimeMillis()));
+ }
getQpidSession().queueDeclare(amqd.getAMQQueueName().toString(), null,
null,
amqd.isAutoDelete() ? Option.AUTO_DELETE
: Option.NO_OPTION,
amqd.isDurable() ? Option.DURABLE :
Option.NO_OPTION,
