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

   package com.ubermq.chord.jms;
   
   import javax.jms.*;
   import java.util.*;
   
   /**
    * A chord store command.
    */
   public final class ChordValueMessage
      extends ChordMessage
  {
      private Object key, value;
      private long queryId;
  
      /**
       * Constructs a chord value reply message.
       * @throws IllegalArgumentException if the message is invalid.
       */
      ChordValueMessage(Message m)
      {
          super(m);
  
          try
          {
              List l = (List) ((ObjectMessage)m).getObject();
              this.key = l.get(0);
              if (l.size() > 1)
                  this.value = l.get(1);
              else this.value = null;
  
              this.queryId = m.getLongProperty(ChordQueryMessage.CHORD_QUERY_ID_PROPERTY);
          }
          catch (Exception e) {
              e.printStackTrace();
              throw new IllegalArgumentException("Invalid chord value reply message.");
          }
      }
  
      /**
       * Constructs an outgoing value command.
       *
       * @param session a session, used for message creation
       * @param replyTopic the topic that the value message will be sent to
       * @param key the key to look up
       */
      ChordValueMessage(Session session,
                        long queryId,
                        Object key,
                        Object value)
          throws JMSException
      {
          super(session.createObjectMessage(),
                CHORD_VALUE);
  
          List pair = new ArrayList(2);
          pair.add(key);
          pair.add(value);
  
          ObjectMessage m = (ObjectMessage)getJMSMessage();
          m.setObject((java.io.Serializable)pair);
          m.setLongProperty(ChordQueryMessage.CHORD_QUERY_ID_PROPERTY, queryId);
      }
  
      /**
       * Returns the key that was queried.
       * @return a key
       */
      public Object getKey()
      {
          return key;
      }
  
      /**
       * Returns the query identifier that this value
       * is in response to.
       * @return the query id
       */
      public long getQueryId()
      {
          return queryId;
      }
  
      /**
       * Returns the value that was found associated with the key,
       * or <code>null</code> if no value was found.
       */
      public Object getValue()
      {
          return value;
      }
  }