blob: 0a87dfa87ec2f555da8c8c9252e0352a6e1e9f3a [file] [log] [blame]
/**
* 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.activemq.util;
import org.apache.activemq.command.SubscriptionInfo;
public class SubscriptionKey {
public final String clientId;
public final String subscriptionName;
private final int hashValue;
public SubscriptionKey(SubscriptionInfo info) {
this(info.getClientId(), info.getSubscriptionName());
}
public SubscriptionKey(String clientId, String subscriptionName) {
this.clientId = clientId;
this.subscriptionName = subscriptionName != null ? subscriptionName : "NOT_SET";
hashValue = clientId.hashCode() ^ this.subscriptionName.hashCode();
}
public int hashCode() {
return hashValue;
}
public boolean equals(Object o) {
try {
SubscriptionKey key = (SubscriptionKey)o;
return key.clientId.equals(clientId) && key.subscriptionName.equals(subscriptionName);
} catch (Throwable e) {
return false;
}
}
public String toString() {
return clientId + ":" + subscriptionName;
}
public String getClientId() {
return clientId;
}
public String getSubscriptionName() {
return subscriptionName;
}
}