File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -74,7 +74,8 @@ mod stream;
7474/// The message received from a subscription.
7575#[ derive( Debug ) ]
7676pub struct PublishedMessage {
77- pub id : MessageId ,
77+ pub message_id : MessageId ,
78+ pub subscription_id : SubscriptionId ,
7879 pub topic : Topic ,
7980 pub message : Arc < str > ,
8081 pub tag : u32 ,
@@ -84,11 +85,12 @@ pub struct PublishedMessage {
8485
8586impl PublishedMessage {
8687 fn from_request ( request : & InboundRequest < Subscription > ) -> Self {
87- let data = & request. data ( ) . data ;
88+ let Subscription { id , data } = request. data ( ) ;
8889 let now = chrono:: Utc :: now ( ) ;
8990
9091 Self {
91- id : request. id ( ) ,
92+ message_id : request. id ( ) ,
93+ subscription_id : id. clone ( ) ,
9294 topic : data. topic . clone ( ) ,
9395 message : data. message . clone ( ) ,
9496 tag : data. tag ,
You can’t perform that action at this time.
0 commit comments