Commits

chri...@81dbac14-341a-0410-aa85-cbcd92e6f43e  committed 121f098

[CACHE-55] - The JMS listener was throwing an exception on Weblogic

  • Participants
  • Parent commits 17fd622

Comments (0)

Files changed (2)

File src/plugins/clustersupport/java/com/opensymphony/oscache/plugins/clustersupport/JMS10BroadcastingListener.java

                             }
 
                             // This prevents the notification sent by this node from being handled by itself
-                            if (!objectMessage.getStringProperty("node.name").equals(clusterNode)) {
+                            if (!objectMessage.getStringProperty("nodeName").equals(clusterNode)) {
                                 //now handle the message
                                 ClusterNotification notification = (ClusterNotification) objectMessage.getObject();
                                 handleClusterNotification(notification);
             objectMessage.setObject(message);
 
             //sign the message, with the name of this node
-            objectMessage.setStringProperty("node.name", clusterNode);
+            objectMessage.setStringProperty("nodeName", clusterNode);
             publisher.publish(objectMessage);
         } catch (JMSException e) {
             log.error("Cannot send notification " + message, e);

File src/plugins/clustersupport/java/com/opensymphony/oscache/plugins/clustersupport/JMSBroadcastingListener.java

                             }
 
                             // This prevents the notification sent by this node from being handled by itself
-                            if (!objectMessage.getStringProperty("node.name").equals(clusterNode)) {
+                            if (!objectMessage.getStringProperty("nodeName").equals(clusterNode)) {
                                 //now handle the message
                                 ClusterNotification notification = (ClusterNotification) objectMessage.getObject();
                                 handleClusterNotification(notification);
             objectMessage.setObject(message);
 
             //sign the message, with the name of this node
-            objectMessage.setStringProperty("node.name", clusterNode);
+            objectMessage.setStringProperty("nodeName", clusterNode);
             messagePublisher.send(objectMessage);
         } catch (JMSException e) {
             log.error("Cannot send notification " + message, e);