Source code: com/ubermq/chord/jms/ChordNotifyMessage.java

   package com.ubermq.chord.jms;
   
   import com.ubermq.chord.*;
   import javax.jms.*;
   
   /**
    * A chord notify command.
    */
   public final class ChordNotifyMessage
      extends ChordMessage
  {
      private ChordNode node;
      private boolean goingAway;
  
      /**
       * A boolean property that signifies whether the notify message
       * indicates a node joining, or leaving, the infrastructure.
       */
      private static final String CHORD_NOTIFY_GOING_AWAY_PROPERTY = "com.ubermq.chord.notify.going-away";
  
      ChordNotifyMessage(Session session,
                         boolean goingAway,
                         ChordNode node)
          throws JMSException
      {
          super(session.createObjectMessage((java.io.Serializable)node),
                ChordMessage.CHORD_NOTIFY);
  
          ObjectMessage m = (ObjectMessage)getJMSMessage();
          m.setBooleanProperty(CHORD_NOTIFY_GOING_AWAY_PROPERTY, goingAway);
      }
  
      /**
       * Constructs a chord node notification message.
       * @throws IllegalArgumentException if the message is invalid.
       */
      ChordNotifyMessage(Message m)
      {
          super(m);
  
          try
          {
              this.node = (ChordNode)((ObjectMessage)m).getObject();
              this.goingAway = m.getBooleanProperty(CHORD_NOTIFY_GOING_AWAY_PROPERTY);
          }
          catch (JMSException e) {
              throw new IllegalArgumentException("Invalid chord notify message.");
          }
      }
  
      /**
       * Returns the node that is doing the notification.
       * @return a node
       */
      public ChordNode getNode()
      {
          return node;
      }
  
      public void execute(TopicSession session,
                          TopicPublisher pub,
                          ChordNodeProvider p)
          throws JMSException
      {
          if (goingAway)
              p.notifyGoingAway(node);
          else
              p.notify(node);
      }
  }