@@ -81,7 +81,6 @@ public override void CopyFrom(ServiceModelExtensionElement from)
81
81
{
82
82
this . HostName = element . HostName ;
83
83
this . Port = element . Port ;
84
- this . ProtocolVersion = element . ProtocolVersion ;
85
84
this . Password = element . Password ;
86
85
this . Username = element . Username ;
87
86
this . VirtualHost = element . VirtualHost ;
@@ -118,7 +117,6 @@ protected override void InitializeFrom(System.ServiceModel.Channels.BindingEleme
118
117
119
118
this . HostName = rabbind . HostName ;
120
119
this . Port = rabbind . Port ;
121
- this . ProtocolVersion = rabbind . BrokerProtocol . ApiName ;
122
120
this . Password = rabbind . ConnectionFactory . Password ;
123
121
this . Username = rabbind . ConnectionFactory . UserName ;
124
122
this . VirtualHost = rabbind . ConnectionFactory . VirtualHost ;
@@ -169,32 +167,9 @@ public string Username
169
167
set { base [ "username" ] = value ; }
170
168
}
171
169
172
- /// <summary>
173
- /// Specifies the protocol version to use when communicating with the broker
174
- /// </summary>
175
- [ ConfigurationProperty ( "protocolversion" , DefaultValue = "DefaultProtocol" ) ]
176
- public string ProtocolVersion
177
- {
178
- get
179
- {
180
- return ( ( string ) base [ "protocolversion" ] ) ;
181
- }
182
- set
183
- {
184
- base [ "protocolversion" ] = value ;
185
- GetProtocol ( ) ;
186
- }
187
- }
188
-
189
170
private IProtocol GetProtocol ( )
190
171
{
191
- IProtocol result = Protocols . Lookup ( this . ProtocolVersion ) ;
192
- if ( result == null )
193
- {
194
- throw new ConfigurationErrorsException ( string . Format ( "'{0}' is not a valid AMQP protocol name" ,
195
- this . ProtocolVersion ) ) ;
196
- }
197
- return result ;
172
+ return Protocols . DefaultProtocol ;
198
173
}
199
174
200
175
/// <summary>
0 commit comments