|
57 | 57 | using System;
|
58 | 58 | using System.Collections;
|
59 | 59 |
|
60 |
| -namespace RabbitMQ.Client.Impl { |
61 |
| - public abstract class BasicProperties: ContentHeaderBase, IBasicProperties { |
62 |
| - public abstract string ContentType { get; set; } |
63 |
| - public abstract string ContentEncoding { get; set; } |
64 |
| - public abstract IDictionary Headers { get; set; } |
65 |
| - public abstract byte DeliveryMode { get; set; } |
66 |
| - public abstract byte Priority { get; set; } |
67 |
| - public abstract string CorrelationId { get; set; } |
68 |
| - public abstract string ReplyTo { get; set; } |
69 |
| - public abstract string Expiration { get; set; } |
70 |
| - public abstract string MessageId { get; set; } |
71 |
| - public abstract AmqpTimestamp Timestamp { get; set; } |
72 |
| - public abstract string Type { get; set; } |
73 |
| - public abstract string UserId { get; set; } |
74 |
| - public abstract string AppId { get; set; } |
75 |
| - public abstract string ClusterId { get; set; } |
| 60 | +namespace RabbitMQ.Client.Impl |
| 61 | +{ |
| 62 | + public abstract class BasicProperties: ContentHeaderBase, IBasicProperties |
| 63 | + { |
| 64 | + public abstract string ContentType { get; set; } |
| 65 | + public abstract string ContentEncoding { get; set; } |
| 66 | + public abstract IDictionary Headers { get; set; } |
| 67 | + public abstract byte DeliveryMode { get; set; } |
| 68 | + public abstract byte Priority { get; set; } |
| 69 | + public abstract string CorrelationId { get; set; } |
| 70 | + public abstract string ReplyTo { get; set; } |
| 71 | + public abstract string Expiration { get; set; } |
| 72 | + public abstract string MessageId { get; set; } |
| 73 | + public abstract AmqpTimestamp Timestamp { get; set; } |
| 74 | + public abstract string Type { get; set; } |
| 75 | + public abstract string UserId { get; set; } |
| 76 | + public abstract string AppId { get; set; } |
| 77 | + public abstract string ClusterId { get; set; } |
76 | 78 |
|
77 |
| - public abstract void ClearContentType(); |
78 |
| - public abstract void ClearContentEncoding(); |
79 |
| - public abstract void ClearHeaders(); |
80 |
| - public abstract void ClearDeliveryMode(); |
81 |
| - public abstract void ClearPriority(); |
82 |
| - public abstract void ClearCorrelationId(); |
83 |
| - public abstract void ClearReplyTo(); |
84 |
| - public abstract void ClearExpiration(); |
85 |
| - public abstract void ClearMessageId(); |
86 |
| - public abstract void ClearTimestamp(); |
87 |
| - public abstract void ClearType(); |
88 |
| - public abstract void ClearUserId(); |
89 |
| - public abstract void ClearAppId(); |
90 |
| - public abstract void ClearClusterId(); |
| 79 | + public abstract void ClearContentType(); |
| 80 | + public abstract void ClearContentEncoding(); |
| 81 | + public abstract void ClearHeaders(); |
| 82 | + public abstract void ClearDeliveryMode(); |
| 83 | + public abstract void ClearPriority(); |
| 84 | + public abstract void ClearCorrelationId(); |
| 85 | + public abstract void ClearReplyTo(); |
| 86 | + public abstract void ClearExpiration(); |
| 87 | + public abstract void ClearMessageId(); |
| 88 | + public abstract void ClearTimestamp(); |
| 89 | + public abstract void ClearType(); |
| 90 | + public abstract void ClearUserId(); |
| 91 | + public abstract void ClearAppId(); |
| 92 | + public abstract void ClearClusterId(); |
91 | 93 |
|
92 |
| - public abstract bool IsContentTypePresent(); |
93 |
| - public abstract bool IsContentEncodingPresent(); |
94 |
| - public abstract bool IsHeadersPresent(); |
95 |
| - public abstract bool IsDeliveryModePresent(); |
96 |
| - public abstract bool IsPriorityPresent(); |
97 |
| - public abstract bool IsCorrelationIdPresent(); |
98 |
| - public abstract bool IsReplyToPresent(); |
99 |
| - public abstract bool IsExpirationPresent(); |
100 |
| - public abstract bool IsMessageIdPresent(); |
101 |
| - public abstract bool IsTimestampPresent(); |
102 |
| - public abstract bool IsTypePresent(); |
103 |
| - public abstract bool IsUserIdPresent(); |
104 |
| - public abstract bool IsAppIdPresent(); |
105 |
| - public abstract bool IsClusterIdPresent(); |
| 94 | + public abstract bool IsContentTypePresent(); |
| 95 | + public abstract bool IsContentEncodingPresent(); |
| 96 | + public abstract bool IsHeadersPresent(); |
| 97 | + public abstract bool IsDeliveryModePresent(); |
| 98 | + public abstract bool IsPriorityPresent(); |
| 99 | + public abstract bool IsCorrelationIdPresent(); |
| 100 | + public abstract bool IsReplyToPresent(); |
| 101 | + public abstract bool IsExpirationPresent(); |
| 102 | + public abstract bool IsMessageIdPresent(); |
| 103 | + public abstract bool IsTimestampPresent(); |
| 104 | + public abstract bool IsTypePresent(); |
| 105 | + public abstract bool IsUserIdPresent(); |
| 106 | + public abstract bool IsAppIdPresent(); |
| 107 | + public abstract bool IsClusterIdPresent(); |
106 | 108 |
|
107 |
| - public PublicationAddress ReplyToAddress { |
108 |
| - get { |
| 109 | + public PublicationAddress ReplyToAddress |
| 110 | + { |
| 111 | + get |
| 112 | + { |
109 | 113 | return PublicationAddress.Parse(ReplyTo);
|
110 | 114 | }
|
111 |
| - set { |
| 115 | + set |
| 116 | + { |
112 | 117 | ReplyTo = value.ToString();
|
113 | 118 | }
|
114 | 119 | }
|
115 | 120 |
|
116 |
| - public void SetPersistent(bool persistent) { |
117 |
| - if (persistent) { |
118 |
| - DeliveryMode = 2; |
119 |
| - } else { |
120 |
| - DeliveryMode = 1; |
| 121 | + public void SetPersistent(bool persistent) |
| 122 | + { |
| 123 | + if (persistent) |
| 124 | + DeliveryMode = 2; |
| 125 | + else |
| 126 | + DeliveryMode = 1; |
121 | 127 | }
|
122 |
| - } |
123 | 128 |
|
124 |
| - public override object Clone() |
125 |
| - { |
126 |
| - BasicProperties clone = MemberwiseClone() as BasicProperties; |
127 |
| - if (IsHeadersPresent()) |
| 129 | + public override object Clone() |
128 | 130 | {
|
129 |
| - clone.Headers = new Hashtable(); |
130 |
| - foreach (DictionaryEntry entry in Headers) |
131 |
| - clone.Headers[entry.Key] = entry.Value; |
132 |
| - } |
| 131 | + BasicProperties clone = MemberwiseClone() as BasicProperties; |
| 132 | + if (IsHeadersPresent()) |
| 133 | + { |
| 134 | + clone.Headers = new Hashtable(); |
| 135 | + foreach (DictionaryEntry entry in Headers) |
| 136 | + clone.Headers[entry.Key] = entry.Value; |
| 137 | + } |
133 | 138 |
|
134 |
| - return clone; |
135 |
| - } |
| 139 | + return clone; |
| 140 | + } |
136 | 141 | }
|
137 | 142 | }
|
0 commit comments