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

   package com.ubermq.chord.jms;
   
   import com.ubermq.chord.*;
   import java.util.*;
   import javax.jms.*;
   
   /**
    * A chord store command.
    */
  public final class ChordStoreMessage
      extends ChordMessage
  {
      private Object key, value;
  
      /**
       * Constructs a chord store message from an incoming
       * JMS message. <P>
       *
       * @throws IllegalArgumentException if the message is invalid.
       */
      ChordStoreMessage(Message m)
      {
          super(m);
  
          try
          {
              List l = (List) ((ObjectMessage)m).getObject();
              this.key = l.get(0);
              this.value = l.get(1);
          }
          catch (JMSException e) {
              throw new IllegalArgumentException("Invalid chord store message.");
          }
      }
  
      /**
       * Constructs an outgoing chord store command.<P>
       *
       * @param session a JMS session
       * @param key the key to store the value under
       * @param value the value to store
       */
      ChordStoreMessage(Session session,
                        Object key,
                        Object value)
          throws JMSException
      {
          super(session.createObjectMessage(),
                CHORD_STORE);
  
          this.key = key;
          this.value = value;
  
          List pair = new ArrayList(2);
          pair.add(key);
          pair.add(value);
  
          ObjectMessage m = (ObjectMessage)getJMSMessage();
          m.setObject((java.io.Serializable)pair);
      }
  
      /**
       * Returns the key to store the value under.
       * @return a key
       */
      public Object getKey()
      {
          return key;
      }
  
      /**
       * Returns the value that should be stored.
       */
      public Object getValue()
      {
          return value;
      }
  
      public void execute(TopicSession session,
                          TopicPublisher pub,
                          ChordNodeProvider p)
      {
          p.store(key, value);
      }
  }