/* * 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. */ using System; namespace Apache.NMS.Stomp.Commands { public class ConsumerId : BaseDataStructure { public const byte ID_CONSUMERID = 122; private string key; private SessionId parentId; string connectionId; long sessionId; long value; public ConsumerId() { } public ConsumerId( string consumerKey ) { this.key = consumerKey; // We give the Connection ID the key for now so there's at least some // data stored into the Id. this.ConnectionId = consumerKey; int idx = consumerKey.LastIndexOf(':'); if( idx >= 0 ) { try { this.Value = Int32.Parse(consumerKey.Substring(idx + 1)); consumerKey = consumerKey.Substring(0, idx); idx = consumerKey.LastIndexOf(':'); if (idx >= 0) { try { this.SessionId = Int32.Parse(consumerKey.Substring(idx + 1)); consumerKey = consumerKey.Substring(0, idx); } catch(Exception ex) { Tracer.Debug(ex.Message); } } this.ConnectionId = consumerKey; } catch(Exception ex) { Tracer.Debug(ex.Message); } } } public ConsumerId( SessionId sessionId, long consumerId ) { this.connectionId = sessionId.ConnectionId; this.sessionId = sessionId.Value; this.value = consumerId; } /// /// /// Get the unique identifier that this object and its own /// Marshaler share. /// /// public override byte GetDataStructureType() { return ID_CONSUMERID; } /// /// /// Returns a string containing the information for this DataStructure /// such as its type and value of its elements. /// /// public override string ToString() { if( key == null ) { this.key = ConnectionId + ":" + SessionId + ":" + Value; } return key; } public SessionId ParentId { get { if( this.parentId == null ) { this.parentId = new SessionId( this ); } return this.parentId; } } public string ConnectionId { get { return connectionId; } set { this.connectionId = value; } } public long SessionId { get { return sessionId; } set { this.sessionId = value; } } public long Value { get { return value; } set { this.value = value; } } public override int GetHashCode() { int answer = 0; answer = (answer * 37) + HashCode(ConnectionId); answer = (answer * 37) + HashCode(SessionId); answer = (answer * 37) + HashCode(Value); return answer; } public override bool Equals(object that) { if(that is ConsumerId) { return Equals((ConsumerId) that); } return false; } public virtual bool Equals(ConsumerId that) { if(this.key != null && that.key != null) { return this.key.Equals(that.key); } if(!Equals(this.ConnectionId, that.ConnectionId)) { return false; } if(!Equals(this.SessionId, that.SessionId)) { return false; } if(!Equals(this.Value, that.Value)) { return false; } return true; } }; }