Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Switch to proton snapshot to pick up fix /w link closing. Also make a link fail if the address is an empty string. 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1438570 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2013-01-25 16:07:12 +00:00
parent 37423d661c
commit 15298cb1b4
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
View File

@ -634,13 +634,13 @@ class AmqpProtocolConverter {
return null;
} else if( terminus instanceof org.apache.qpid.proton.amqp.messaging.Source) {
org.apache.qpid.proton.amqp.messaging.Source source = (org.apache.qpid.proton.amqp.messaging.Source)terminus;
if( source.getAddress() == null ) {
if( source.getAddress() == null || source.getAddress().length()==0) {
throw new AmqpProtocolException("amqp:invalid-field", "source address not set");
}
return ActiveMQDestination.createDestination(source.getAddress(), ActiveMQDestination.QUEUE_TYPE);
} else if( terminus instanceof org.apache.qpid.proton.amqp.messaging.Target) {
org.apache.qpid.proton.amqp.messaging.Target target = (org.apache.qpid.proton.amqp.messaging.Target)terminus;
if( target.getAddress() == null ) {
if( target.getAddress() == null || target.getAddress().length()==0) {
throw new AmqpProtocolException("amqp:invalid-field", "target address not set");
}
return ActiveMQDestination.createDestination(target.getAddress(), ActiveMQDestination.QUEUE_TYPE);

2
pom.xml
View File

@ -94,7 +94,7 @@
<org-apache-derby-version>10.9.1.0</org-apache-derby-version>
<org.osgi.core-version>4.3.1</org.osgi.core-version>
<p2psockets-version>1.1.2</p2psockets-version>
<qpid-proton-version>0.3.0-fuse-1</qpid-proton-version>
<qpid-proton-version>99.0.0-fuse-SNAPSHOT</qpid-proton-version>
<qpid-jms-version>0.18</qpid-jms-version>
<regexp-version>1.3</regexp-version>
<rome-version>1.0</rome-version>