You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ni...@apache.org on 2013/10/18 12:54:21 UTC
[4/4] git commit: altering receiver accordingly
altering receiver accordingly
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/f2960914
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/f2960914
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/f2960914
Branch: refs/heads/master
Commit: f2960914f2d3e513ca831d6d8574ae72db8ea7ab
Parents: ea592fd
Author: Nirmal Fernando <ni...@apache.org>
Authored: Fri Oct 18 16:20:18 2013 +0530
Committer: Nirmal Fernando <ni...@apache.org>
Committed: Fri Oct 18 16:20:18 2013 +0530
----------------------------------------------------------------------
.../lb/endpoint/topology/TopologyEventMessageReceiver.java | 2 +-
.../apache/stratos/lb/endpoint/topology/TopologyEventQueue.java | 4 +++-
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/f2960914/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventMessageReceiver.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventMessageReceiver.java b/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventMessageReceiver.java
index 8040314..ac7e6af 100644
--- a/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventMessageReceiver.java
+++ b/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventMessageReceiver.java
@@ -40,7 +40,7 @@ public class TopologyEventMessageReceiver implements MessageListener {
log.debug("Message received: " + ((TextMessage) message).getText());
}
// Add received message to the queue
- TopologyEventQueue.getInstance().add(receivedMessage.getText());
+ TopologyEventQueue.getInstance().add(receivedMessage);
} catch (JMSException e) {
log.error(e.getMessage(), e);
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/f2960914/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventQueue.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventQueue.java b/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventQueue.java
index c2cebff..7db33da 100644
--- a/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventQueue.java
+++ b/components/org.apache.stratos.lb.endpoint/src/main/java/org/apache/stratos/lb/endpoint/topology/TopologyEventQueue.java
@@ -22,10 +22,12 @@ package org.apache.stratos.lb.endpoint.topology;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
+import javax.jms.TextMessage;
+
/**
* Implements topology event queue.
*/
-public class TopologyEventQueue extends LinkedBlockingQueue<String>{
+public class TopologyEventQueue extends LinkedBlockingQueue<TextMessage>{
private static volatile TopologyEventQueue instance;
private TopologyEventQueue(){