Struct azure_functions::bindings::QueueMessage

pub struct QueueMessage(_);

Represents an Azure Storage Queue message output binding.

The following binding attributes are supported:

Name	Description
name	The name of the parameter being bound.
queue_name	The name of the queue.
connection	The name of an app setting that contains the Azure Storage connection string to use for this binding. Defaults to the AzureWebJobsStorage.

Examples

Creating a queue message from a string:

use azure_functions::bindings::{HttpRequest, QueueMessage};
use azure_functions::func;

#[func]
#[binding(name = "output1", queue_name = "example")]
pub fn example(_req: HttpRequest) -> ((), QueueMessage) {
    ((), "Hello world!".into())
}

Creating a queue message from a JSON value (see the json! macro from the serde_json crate):

use azure_functions::bindings::{HttpRequest, QueueMessage};
use azure_functions::func;
use serde_json::json;

#[func]
#[binding(name = "output1", queue_name = "example")]
pub fn example(_req: HttpRequest) -> ((), QueueMessage) {
    ((), json!({ "hello": "world" }).into())
}

Creating a queue message from a sequence of bytes:

use azure_functions::bindings::{HttpRequest, QueueMessage};
use azure_functions::func;
use serde_json::json;

#[func]
#[binding(name = "output1", queue_name = "example")]
pub fn example(_req: HttpRequest) -> ((), QueueMessage) {
    ((), [1, 2, 3][..].into())
}

Methods

impl QueueMessage

pub fn as_str(&self) -> Option<&str>

Gets the content of the message as a string.

Returns None if there is no valid string representation of the message.

pub fn as_bytes(&self) -> &[u8]

Gets the content of the message as a slice of bytes.

pub fn as_json<'b, T>(&'b self) -> Result<T> where
    T: Deserialize<'b>, 

Deserializes the message as JSON to the requested type.

Trait Implementations

impl Into<String> for QueueMessage

fn into(self) -> String

Performs the conversion.

impl Into<Value> for QueueMessage

fn into(self) -> Value

Performs the conversion.

impl Into<Vec<u8>> for QueueMessage

fn into(self) -> Vec<u8>

Performs the conversion.

impl<'a> Into<Body<'a>> for QueueMessage

fn into(self) -> Body<'a>

Performs the conversion.

impl<'a> From<&'a str> for QueueMessage

fn from(content: &'a str) -> Self

Performs the conversion.

impl From<String> for QueueMessage

fn from(content: String) -> Self

Performs the conversion.

impl<'_> From<&'_ Value> for QueueMessage

fn from(content: &Value) -> Self

Performs the conversion.

impl From<Value> for QueueMessage

fn from(content: Value) -> Self

Performs the conversion.

impl<'a> From<&'a [u8]> for QueueMessage

fn from(content: &'a [u8]) -> Self

Performs the conversion.

impl From<Vec<u8>> for QueueMessage

fn from(content: Vec<u8>) -> Self

Performs the conversion.

impl Clone for QueueMessage

fn clone(&self) -> QueueMessage

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Display for QueueMessage

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Debug for QueueMessage

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.