Skip to content

Commit 8e13490

Browse files
committed
feat(dmq): add 'DmqPublisherServer' trait
1 parent b146a57 commit 8e13490

File tree

3 files changed

+17
-0
lines changed

3 files changed

+17
-0
lines changed
Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,5 @@
11
mod client;
2+
mod server;
23

34
pub use client::*;
5+
pub use server::*;
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
use mithril_common::StdResult;
2+
3+
/// Trait for the server side of publishing messages from a DMQ node.
4+
#[cfg_attr(test, mockall::automock)]
5+
#[async_trait::async_trait]
6+
pub trait DmqPublisherServer: Send + Sync {
7+
/// Processes the next message received from the DMQ client.
8+
async fn process_message(&self) -> StdResult<()>;
9+
10+
/// Runs the DMQ publisher server.
11+
async fn run(&self) -> StdResult<()>;
12+
}
Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
mod interface;
2+
3+
pub use interface::*;

0 commit comments

Comments
 (0)