Enum ConnectionCommand 

pub enum ConnectionCommand {
    Publish {
        exchange_name: String,
        routing_key: String,
        body: Vec<u8>,
        content_type: String,
        content_encoding: ContentEncoding,
        delivery_mode: DeliveryMode,
        expiration: Option<u32>,
        response: Sender<Result<(), AppError>>,
        confirm: Option<Sender<Result<(), AppError>>>,
    },
    Subscribe {
        handler: Handler,
        routing_key: String,
        exchange_name: String,
        exchange_type: String,
        queue_name: String,
        response: Sender<Result<(), AppError>>,
        process_timeout: Option<Duration>,
        queue_options: QueueOptions,
    },
    RpcServer {
        handler: RPCHandler,
        routing_key: String,
        exchange_name: String,
        exchange_type: String,
        queue_name: String,
        response: Sender<Result<(), AppError>>,
        response_timeout: Option<Duration>,
        queue_options: QueueOptions,
    },
    RpcClient {
        exchange_name: String,
        routing_key: String,
        body: Vec<u8>,
        content_type: String,
        content_encoding: ContentEncoding,
        response_timeout_millis: u32,
        delivery_mode: DeliveryMode,
        expiration: Option<u32>,
        response: Sender<Result<Vec<u8>, AppError>>,
        confirm: Option<Sender<Result<(), AppError>>>,
    },
    Close {
        response: Sender<()>,
    },
    CheckConnection {},
    UpdateSecret {
        new_secret: String,
        reason: String,
        response: Sender<Result<(), AppError>>,
    },
}

Variants

Publish

Fields

exchange_name: String

routing_key: String

body: Vec<u8>

content_type: String

content_encoding: ContentEncoding

delivery_mode: DeliveryMode

expiration: Option<u32>

response: Sender<Result<(), AppError>>

confirm: Option<Sender<Result<(), AppError>>>

Subscribe

Fields

handler: Handler

routing_key: String

exchange_name: String

exchange_type: String

queue_name: String

response: Sender<Result<(), AppError>>

process_timeout: Option<Duration>

queue_options: QueueOptions

RpcServer

Fields

handler: RPCHandler

routing_key: String

exchange_name: String

exchange_type: String

queue_name: String

response: Sender<Result<(), AppError>>

response_timeout: Option<Duration>

queue_options: QueueOptions

RpcClient

Fields

exchange_name: String

routing_key: String

body: Vec<u8>

content_type: String

content_encoding: ContentEncoding

response_timeout_millis: u32

delivery_mode: DeliveryMode

expiration: Option<u32>

response: Sender<Result<Vec<u8>, AppError>>

confirm: Option<Sender<Result<(), AppError>>>

Close

Fields

response: Sender<()>

CheckConnection

UpdateSecret

Fields

new_secret: String

reason: String

response: Sender<Result<(), AppError>>