@@ -7,9 +7,9 @@ use super::{
7
7
} ;
8
8
#[ cfg( all( feature = "fe2o3_amqp" , not( target_arch = "wasm32" ) ) ) ]
9
9
use crate :: fe2o3:: error:: Fe2o3SerializationError ;
10
- #[ cfg( feature = "cplusplus " ) ]
10
+ #[ cfg( feature = "ffi " ) ]
11
11
use crate :: Deserializable ;
12
- #[ cfg( feature = "cplusplus " ) ]
12
+ #[ cfg( feature = "ffi " ) ]
13
13
use azure_core:: error:: ErrorKind ;
14
14
use azure_core:: { time:: Duration , Result , Uuid } ;
15
15
use typespec_macros:: SafeDebug ;
@@ -312,7 +312,7 @@ impl From<String> for AmqpTarget {
312
312
}
313
313
}
314
314
315
- #[ cfg( feature = "cplusplus " ) ]
315
+ #[ cfg( feature = "ffi " ) ]
316
316
impl From < AmqpList > for AmqpTarget {
317
317
fn from ( list : AmqpList ) -> Self {
318
318
let mut builder = AmqpTarget :: builder ( ) ;
@@ -374,7 +374,7 @@ impl From<AmqpList> for AmqpTarget {
374
374
}
375
375
}
376
376
377
- #[ cfg( feature = "cplusplus " ) ]
377
+ #[ cfg( feature = "ffi " ) ]
378
378
impl From < AmqpTarget > for AmqpList {
379
379
fn from ( target : AmqpTarget ) -> Self {
380
380
let mut list = vec ! [ AmqpValue :: Null ; 7 ] ;
@@ -477,7 +477,7 @@ impl AmqpSource {
477
477
}
478
478
}
479
479
480
- #[ cfg( feature = "cplusplus " ) ]
480
+ #[ cfg( feature = "ffi " ) ]
481
481
impl From < AmqpList > for AmqpSource {
482
482
fn from ( list : AmqpList ) -> Self {
483
483
let mut builder = AmqpSource :: builder ( ) ;
@@ -562,7 +562,7 @@ impl From<AmqpList> for AmqpSource {
562
562
}
563
563
}
564
564
565
- #[ cfg( feature = "cplusplus " ) ]
565
+ #[ cfg( feature = "ffi " ) ]
566
566
impl From < AmqpSource > for AmqpList {
567
567
fn from ( source : AmqpSource ) -> Self {
568
568
let mut list = vec ! [ AmqpValue :: Null ; 11 ] ;
@@ -661,7 +661,7 @@ impl AmqpMessageHeader {}
661
661
/// See also [Amqp Header](https://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-header) for more information
662
662
///
663
663
///
664
- #[ cfg( feature = "cplusplus " ) ]
664
+ #[ cfg( feature = "ffi " ) ]
665
665
impl From < AmqpList > for AmqpMessageHeader {
666
666
fn from ( list : AmqpList ) -> Self {
667
667
let mut header = AmqpMessageHeader :: default ( ) ;
@@ -695,7 +695,7 @@ impl From<AmqpList> for AmqpMessageHeader {
695
695
}
696
696
}
697
697
698
- #[ cfg( feature = "cplusplus " ) ]
698
+ #[ cfg( feature = "ffi " ) ]
699
699
impl From < AmqpMessageHeader > for AmqpList {
700
700
fn from ( header : AmqpMessageHeader ) -> AmqpList {
701
701
let mut list = vec ! [ AmqpValue :: Null ; 5 ] ;
@@ -786,7 +786,7 @@ impl AmqpMessageProperties {}
786
786
/// See also [Amqp Header](https://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-properties) for more information
787
787
///
788
788
///
789
- #[ cfg( feature = "cplusplus " ) ]
789
+ #[ cfg( feature = "ffi " ) ]
790
790
impl From < AmqpList > for AmqpMessageProperties {
791
791
fn from ( list : AmqpList ) -> Self {
792
792
let mut message_properties = AmqpMessageProperties :: default ( ) ;
@@ -886,7 +886,7 @@ impl From<AmqpList> for AmqpMessageProperties {
886
886
}
887
887
}
888
888
889
- #[ cfg( feature = "cplusplus " ) ]
889
+ #[ cfg( feature = "ffi " ) ]
890
890
impl From < AmqpMessageProperties > for AmqpList {
891
891
fn from ( properties : AmqpMessageProperties ) -> AmqpList {
892
892
let mut list = vec ! [ AmqpValue :: Null ; 13 ] ;
@@ -1399,7 +1399,7 @@ impl From<AmqpList> for AmqpMessage {
1399
1399
}
1400
1400
}
1401
1401
}
1402
- #[ cfg( feature = "cplusplus " ) ]
1402
+ #[ cfg( feature = "ffi " ) ]
1403
1403
impl Deserializable < AmqpMessage > for AmqpMessage {
1404
1404
fn decode ( data : & [ u8 ] ) -> azure_core:: Result < AmqpMessage > {
1405
1405
#[ cfg( all( feature = "fe2o3_amqp" , not( target_arch = "wasm32" ) ) ) ]
@@ -2188,7 +2188,7 @@ mod tests {
2188
2188
assert_eq ! ( amqp_message, value. 0 ) ;
2189
2189
}
2190
2190
2191
- #[ cfg( feature = "cplusplus " ) ]
2191
+ #[ cfg( feature = "ffi " ) ]
2192
2192
{
2193
2193
let deserialized = AmqpMessage :: decode ( & serialized) . unwrap ( ) ;
2194
2194
assert_eq ! ( deserialized, message) ;
0 commit comments