File tree Expand file tree Collapse file tree 3 files changed +8
-8
lines changed
RabbitMQ.Client/src/client Expand file tree Collapse file tree 3 files changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -857,7 +857,7 @@ public void EmitContentHeaderFactory(MethodInfo method) {
857
857
EmitLine ( " {" ) ;
858
858
if ( Attribute ( method , typeof ( AmqpUnsupportedAttribute ) ) != null )
859
859
{
860
- EmitLine ( String . Format ( " return default({0});" , method . ReturnType ) ) ;
860
+ EmitLine ( String . Format ( " throw new UnsupportedMethodException( \" " + method . Name + " \" );" ) ) ;
861
861
}
862
862
else
863
863
{
Original file line number Diff line number Diff line change @@ -386,11 +386,11 @@ BasicGetResult BasicGet(string queue,
386
386
void TxRollback ( ) ;
387
387
388
388
///<summary>(Spec method) Enable DTX mode for this session.</summary>
389
- [ AmqpMethodDoNotImplement ( "RabbitMQ.Client.Framing.v0_9_1" ) ]
389
+ [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_9_1" ) ]
390
390
void DtxSelect ( ) ;
391
391
392
392
///<summary>(Spec method)</summary>
393
- [ AmqpMethodDoNotImplement ( "RabbitMQ.Client.Framing.v0_9_1" ) ]
393
+ [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_9_1" ) ]
394
394
void DtxStart ( string dtxIdentifier ) ;
395
395
396
396
///<summary>Close this session.</summary>
@@ -701,7 +701,7 @@ void _Private_ConnectionOpen(string virtualHost,
701
701
bool insist ) ;
702
702
703
703
///<summary>Handle an incoming Connection.OpenOk.</summary>
704
- void HandleConnectionOpenOk ( [ AmqpUnsupported ( "RabbitMQ.Client.Framing.v0_9_1" ) ]
704
+ void HandleConnectionOpenOk ( [ AmqpFieldMapping ( "RabbitMQ.Client.Framing.v0_9_1" , "reserved1 ") ]
705
705
string knownHosts ) ;
706
706
707
707
///<summary>Handle an incoming Connection.Redirect.</summary>
Original file line number Diff line number Diff line change @@ -146,8 +146,8 @@ public event CallbackExceptionEventHandler CallbackException
146
146
m_callbackException -= value ;
147
147
}
148
148
}
149
- }
150
-
149
+ }
150
+
151
151
public IBasicConsumer DefaultConsumer { get ; set ; }
152
152
153
153
public ISession m_session ;
@@ -806,8 +806,8 @@ public abstract void BasicReject(ulong deliveryTag,
806
806
public abstract void TxCommit ( ) ;
807
807
public abstract void TxRollback ( ) ;
808
808
809
- public virtual void DtxSelect ( ) { }
810
- public virtual void DtxStart ( string dtxIdentifier ) { }
809
+ public abstract void DtxSelect ( ) ;
810
+ public abstract void DtxStart ( string dtxIdentifier ) ;
811
811
812
812
void IDisposable . Dispose ( )
813
813
{
You can’t perform that action at this time.
0 commit comments