SessionsContainer.java

  public static class SessionsContainer implements Serializable {
    private final Map<String, Object> sharedAttributes = new HashMap<String, Object>();
    private final Map<String, QueueSession> queueSessions = new HashMap<String, QueueSession>();

    public QueueSession createSession(final String httpSessionId, final String remoteQueueId) {
      final QueueSession qs = new HttpSessionWrapper(this, httpSessionId, remoteQueueId);
      queueSessions.put(remoteQueueId, qs);
      return qs;
    }

    public QueueSession getSession(final String remoteQueueId) {
      return queueSessions.get(remoteQueueId);
    }

    public void removeSession(final String remoteQueueId) {
      queueSessions.remove(remoteQueueId);
    }
    
    private void writeObject(ObjectOutputStream out) throws IOException {
      System.out.println("SessionsContainer is about to get serialized. Contents:");
      System.out.println("sharedAttributes: " + sharedAttributes);
      System.out.println("queueSessions: " + queueSessions);
      out.defaultWriteObject();
    }
  }