You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ma...@apache.org on 2016/11/30 13:27:37 UTC

[17/27] activemq-artemis git commit: Fix temporary queue API

Fix temporary queue API


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/903d216c
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/903d216c
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/903d216c

Branch: refs/heads/ARTEMIS-780
Commit: 903d216ca837ae9dc8f6d510f297b8f9379e742a
Parents: c961c1d
Author: jbertram <jb...@apache.com>
Authored: Tue Nov 29 17:26:04 2016 -0600
Committer: jbertram <jb...@apache.com>
Committed: Tue Nov 29 17:26:04 2016 -0600

----------------------------------------------------------------------
 .../activemq/artemis/core/client/impl/ClientSessionImpl.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/903d216c/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
index 310644a..ae7603c 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/client/impl/ClientSessionImpl.java
@@ -422,7 +422,7 @@ public final class ClientSessionImpl implements ClientSessionInternal, FailureLi
 
    @Override
    public void createTemporaryQueue(final String address, final RoutingType routingType, final String queueName, final String filter) throws ActiveMQException {
-      createTemporaryQueue(SimpleString.toSimpleString(address), routingType, SimpleString.toSimpleString(queueName));
+      createTemporaryQueue(SimpleString.toSimpleString(address), routingType, SimpleString.toSimpleString(queueName), SimpleString.toSimpleString(filter));
    }
 
    /**