activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From martyntay...@apache.org
Subject [1/2] activemq-artemis git commit: fix example compilation
Date Wed, 13 Jan 2016 10:46:37 GMT
Repository: activemq-artemis
Updated Branches:
  refs/heads/master a8443512b -> aab09a77d


fix example compilation


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

Branch: refs/heads/master
Commit: 14ad3ebcdf21de937959c3e84cb0d45c243d9db8
Parents: a844351
Author: Andy Taylor <andy.tayls67@gmail.com>
Authored: Wed Jan 13 10:32:20 2016 +0000
Committer: Andy Taylor <andy.tayls67@gmail.com>
Committed: Wed Jan 13 10:32:20 2016 +0000

----------------------------------------------------------------------
 .../artemis/jms/example/ClientSideLoadBalancingExample.java  | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/14ad3ebc/examples/features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java
----------------------------------------------------------------------
diff --git a/examples/features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java
b/examples/features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java
index 1281017..41a3a64 100644
--- a/examples/features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java
+++ b/examples/features/clustered/client-side-load-balancing/src/main/java/org/apache/activemq/artemis/jms/example/ClientSideLoadBalancingExample.java
@@ -16,6 +16,8 @@
  */
 package org.apache.activemq.artemis.jms.example;
 
+import org.apache.activemq.artemis.core.client.impl.ClientSessionInternal;
+
 import javax.jms.Connection;
 import javax.jms.ConnectionFactory;
 import javax.jms.JMSException;
@@ -67,9 +69,9 @@ public class ClientSideLoadBalancingExample {
          Session sessionB = connectionB.createSession(false, Session.AUTO_ACKNOWLEDGE);
          Session sessionC = connectionC.createSession(false, Session.AUTO_ACKNOWLEDGE);
 
-         System.out.println("Session A - " + ((org.apache.activemq.artemis.core.client.impl.DelegatingSession)
((org.apache.activemq.artemis.jms.client.ActiveMQSession) sessionA).getCoreSession()).getConnection().getRemoteAddress());
-         System.out.println("Session B - " + ((org.apache.activemq.artemis.core.client.impl.DelegatingSession)
((org.apache.activemq.artemis.jms.client.ActiveMQSession) sessionB).getCoreSession()).getConnection().getRemoteAddress());
-         System.out.println("Session C - " + ((org.apache.activemq.artemis.core.client.impl.DelegatingSession)
((org.apache.activemq.artemis.jms.client.ActiveMQSession) sessionC).getCoreSession()).getConnection().getRemoteAddress());
+         System.out.println("Session A - " + ((ClientSessionInternal) ((org.apache.activemq.artemis.jms.client.ActiveMQSession)
sessionA).getCoreSession()).getConnection().getRemoteAddress());
+         System.out.println("Session B - " + ((ClientSessionInternal)((org.apache.activemq.artemis.jms.client.ActiveMQSession)
sessionB).getCoreSession()).getConnection().getRemoteAddress());
+         System.out.println("Session C - " + ((ClientSessionInternal)((org.apache.activemq.artemis.jms.client.ActiveMQSession)
sessionC).getCoreSession()).getConnection().getRemoteAddress());
 
          // Step 6. We create JMS MessageProducer objects on the sessions
          MessageProducer producerA = sessionA.createProducer(queue);


Mime
View raw message