Struct RabbitMQCommunicator 

pub struct RabbitMQCommunicator { /* private fields */ }

Implementations

impl RabbitMQCommunicator

pub async fn connect(amqp_url: &str) -> Self

pub fn load_queues(&mut self, path: &str)

Trait Implementations

impl Communicator for RabbitMQCommunicator

async fn on_match_abrupt_close<F, Fut>(&self, callback: F)

where F: MessageHandler<MatchAbrubtClose, Fut>, Fut: Future<Output = ()> + Send + 'static,

Registers a callback for when a match is abruptly closed.

async fn on_game_create<F, Fut>(&self, callback: F)

where F: MessageHandler<GameServerCreate, Fut>, Fut: Future<Output = String> + Send + 'static,

Registers a callback for when a game server is created.

async fn on_match_created<F, Fut>(&self, callback: F)

where F: MessageHandler<CreatedMatch, Fut>, Fut: Future<Output = ()> + Send + 'static,

Registers a callback for when a match is created.

async fn on_match_result<F, Fut>(&self, callback: F)

where F: MessageHandler<MatchResult, Fut>, Fut: Future<Output = ()> + Send + 'static,

Registers a callback for when a match result is reported.

async fn on_match_create<F, Fut>(&self, callback: F)

where F: MessageHandler<CreateMatch, Fut>, Fut: Future<Output = ()> + Send + 'static,

Registers a callback for when a match creation request is received.

async fn create_game( &self, game_server: &GameServerCreate, ) -> Result<(), Box<dyn Error>>

Creates a game on the game server.

async fn create_match(&self, match_request: &CreateMatch)

Creates a match based on the provided match request.

async fn report_match_abrupt_close(&self, match_close: &MatchAbrubtClose)

Reports that a match was abruptly closed.

async fn report_match_created(&self, created_match: &CreatedMatch)

Reports that a match has been created.

async fn create_ai_task(&self, task: &Task)

Sends a message to create a new AI-Task.

async fn report_match_result(&self, match_result: &MatchResult)

Reports the result of a match.

async fn send_health_check(&self, client_id: String)

Sends a health check to the specified client.

async fn on_health_check<F, Fut>(&self, callback: F)

where F: MessageHandler<String, Fut>, Fut: Future<Output = ()> + Send + 'static,

Registers a callback for health check events.

async fn on_ai_register<F, Fut>(&self, callback: F)

where F: MessageHandler<AIPlayerRegister, Fut>, Fut: Future<Output = ()> + Send + 'static,

Registers a callback for when a new ai-player is registered.

async fn register_ai_player(&self, ai_player: &AIPlayerRegister)

Sends a message to create a new AI-Player.