/** * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.activeblaze; /** * A SubscriptionHolder */ public class SubscriptionHolder { private final BlazeMessageListener listener; private final Subscription subscription; /** * Constructor */ public SubscriptionHolder(String destination, boolean topic, BlazeMessageListener listener) { this.listener = listener; this.subscription = new Subscription(destination, topic); } /** * Constructor */ public SubscriptionHolder(Subscription subscription, BlazeMessageListener listener) { this.listener = listener; this.subscription = subscription; } /** * Get the listener * * @return the listener */ public BlazeMessageListener getListener() { return this.listener; } /** * Get the subscription * * @return the subscription */ public Subscription getSubscription() { return this.subscription; } /** * @return hash code * @see java.lang.Object#hashCode() */ public int hashCode() { return this.listener.hashCode() ^ this.subscription.hashCode(); } /** * @return true if equals */ public boolean equals(Object obj) { if (obj instanceof SubscriptionHolder) { SubscriptionHolder other = (SubscriptionHolder) obj; return this.listener.equals(other.listener) && this.subscription.equals(other.subscription); } return false; } }