You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2017/11/15 14:07:17 UTC
qpid-jms-amqp-0-x git commit: QPID-7898: Address review feedback from
Alex Rudyy
Repository: qpid-jms-amqp-0-x
Updated Branches:
refs/heads/master ae6d79d38 -> 9aea5431e
QPID-7898: Address review feedback from Alex Rudyy <or...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/commit/9aea5431
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/tree/9aea5431
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/diff/9aea5431
Branch: refs/heads/master
Commit: 9aea5431ebad90e2f64710ba704d721ca8a0a48e
Parents: ae6d79d
Author: Keith Wall <kw...@apache.org>
Authored: Wed Nov 15 14:05:20 2017 +0000
Committer: Keith Wall <kw...@apache.org>
Committed: Wed Nov 15 14:05:20 2017 +0000
----------------------------------------------------------------------
.../qpid/client/AMQUndefinedDestination.java | 45 --------------------
.../qpid/client/BasicMessageProducer.java | 23 +++++-----
.../client/message/AMQMessageDelegate_0_8.java | 10 +++++
3 files changed, 22 insertions(+), 56 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/9aea5431/client/src/main/java/org/apache/qpid/client/AMQUndefinedDestination.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/qpid/client/AMQUndefinedDestination.java b/client/src/main/java/org/apache/qpid/client/AMQUndefinedDestination.java
deleted file mode 100644
index caf54e5..0000000
--- a/client/src/main/java/org/apache/qpid/client/AMQUndefinedDestination.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.client;
-
-public class AMQUndefinedDestination extends AMQDestination
-{
-
- private static final String UNKNOWN_EXCHANGE_CLASS = "unknown";
- private static final long serialVersionUID = -3938019873332367947L;
-
-
- public AMQUndefinedDestination(String exchange, String routingKey, String queueName)
- {
- super(exchange, UNKNOWN_EXCHANGE_CLASS, routingKey, queueName);
- }
-
- public boolean isNameRequired()
- {
- return getAMQQueueName() == null;
- }
-
- @Override
- public boolean neverDeclare()
- {
- return true;
- }
-}
http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/9aea5431/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java b/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
index e7e29ba..12fa91f 100644
--- a/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
+++ b/client/src/main/java/org/apache/qpid/client/BasicMessageProducer.java
@@ -48,7 +48,7 @@ public abstract class BasicMessageProducer extends Closeable implements org.apac
{
- enum PublishMode { ASYNC_PUBLISH_ALL, SYNC_PUBLISH_PERSISTENT, SYNC_PUBLISH_ALL };
+ enum PublishMode { ASYNC_PUBLISH_ALL, SYNC_PUBLISH_PERSISTENT, SYNC_PUBLISH_ALL }
private final Logger _logger ;
@@ -491,17 +491,18 @@ public abstract class BasicMessageProducer extends Closeable implements org.apac
}
AMQDestination amqDestination = (AMQDestination) destination;
- if (!_session.isResolved(amqDestination))
+ if (_session.isResolved(amqDestination) || amqDestination.neverDeclare())
{
- try
- {
- declareDestination(amqDestination);
- }
- catch(Exception e)
- {
- throw JMSExceptionHelper.chainJMSException(new InvalidDestinationException(
- "Error validating destination"), e);
- }
+ return;
+ }
+ try
+ {
+ declareDestination(amqDestination);
+ }
+ catch(Exception e)
+ {
+ throw JMSExceptionHelper.chainJMSException(new InvalidDestinationException(
+ "Error validating destination"), e);
}
}
http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/9aea5431/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_8.java
----------------------------------------------------------------------
diff --git a/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_8.java b/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_8.java
index 8a9aec8..054be82 100644
--- a/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_8.java
+++ b/client/src/main/java/org/apache/qpid/client/message/AMQMessageDelegate_0_8.java
@@ -689,6 +689,11 @@ public class AMQMessageDelegate_0_8 extends AbstractAMQMessageDelegate
{
private static final long serialVersionUID = -5042408431861384536L;
+ // For Externalizable contract
+ public DefaultRouterDestination()
+ {
+ }
+
public DefaultRouterDestination(final String replyToEncoding)
{
super("",
@@ -714,6 +719,11 @@ public class AMQMessageDelegate_0_8 extends AbstractAMQMessageDelegate
{
private static final long serialVersionUID = 122897705932489259L;
+ // For Externalizable contract
+ public NonBURLReplyToDestination()
+ {
+ }
+
public NonBURLReplyToDestination(final String exchangeClass,
final String exchange,
final String routingKey)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org