Commit 67a03a5 1 parent 8158f1b commit 67a03a5 Copy full SHA for 67a03a5
File tree 2 files changed +8
-2
lines changed
2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -123,6 +123,8 @@ pub enum MessageProcessingError {
123
123
WrongCredentialType ( #[ from] BasicCredentialError ) ,
124
124
#[ error( "proto decode error: {0}" ) ]
125
125
DecodeError ( #[ from] prost:: DecodeError ) ,
126
+ #[ error( "generic:{0}" ) ]
127
+ Generic ( String ) ,
126
128
}
127
129
128
130
impl crate :: retry:: RetryableError for MessageProcessingError {
Original file line number Diff line number Diff line change @@ -237,7 +237,9 @@ where
237
237
conn. set_delivery_status_to_published ( & message_id, envelope_timestamp_ns) ?;
238
238
}
239
239
Some ( Content :: V2 ( _) ) => {
240
- todo ! ( )
240
+ return Err ( MessageProcessingError :: Generic (
241
+ "not yet implemented" . into ( ) ,
242
+ ) )
241
243
}
242
244
None => return Err ( MessageProcessingError :: InvalidPayload ) ,
243
245
} ;
@@ -297,7 +299,9 @@ where
297
299
. store ( provider. conn ( ) ) ?
298
300
}
299
301
Some ( Content :: V2 ( _) ) => {
300
- todo ! ( )
302
+ return Err ( MessageProcessingError :: Generic (
303
+ "not yet implemented" . into ( ) ,
304
+ ) )
301
305
}
302
306
None => return Err ( MessageProcessingError :: InvalidPayload ) ,
303
307
}
You can’t perform that action at this time.
0 commit comments