Struct SubscriptionGroupConfig 

pub struct SubscriptionGroupConfig { /* private fields */ }

Implementations

impl SubscriptionGroupConfig

pub fn new(group_name: CheetahString) -> Self

impl SubscriptionGroupConfig

pub fn group_name(&self) -> &CheetahString

pub fn consume_enable(&self) -> bool

pub fn consume_from_min_enable(&self) -> bool

pub fn consume_broadcast_enable(&self) -> bool

pub fn consume_message_orderly(&self) -> bool

pub fn retry_queue_nums(&self) -> i32

pub fn retry_max_times(&self) -> i32

pub fn group_retry_policy(&self) -> &GroupRetryPolicy

pub fn broker_id(&self) -> u64

pub fn which_broker_when_consume_slowly(&self) -> u64

pub fn notify_consumer_ids_changed_enable(&self) -> bool

pub fn group_sys_flag(&self) -> i32

pub fn consume_timeout_minute(&self) -> i32

pub fn subscription_data_set(&self) -> Option<&HashSet<SimpleSubscriptionData>>

pub fn attributes(&self) -> &HashMap<CheetahString, CheetahString>

pub fn lite_bind_topic(&self) -> Option<&CheetahString>

pub fn lite_sub_client_quota(&self) -> i32

pub fn lite_sub_exclusive(&self) -> bool

pub fn max_client_event_count(&self) -> i32

pub fn lite_sub_wildcard(&self) -> bool

Returns whether this group follows every active Lite topic under its bound parent topic.

Java 5.5 models this as the presence of the lite.sub.wildcard attribute rather than as a normal tag expression. Preserve that presence-based wire contract for compatibility.

pub fn set_lite_sub_wildcard(&mut self, wildcard: bool)

pub fn reset_offset_in_exclusive_mode(&self) -> bool

pub fn reset_offset_on_unsubscribe(&self) -> bool

pub fn priority_factor(&self) -> i32

pub fn set_group_name(&mut self, group_name: CheetahString)

pub fn set_consume_enable(&mut self, consume_enable: bool)

pub fn set_consume_from_min_enable(&mut self, consume_from_min_enable: bool)

pub fn set_consume_broadcast_enable(&mut self, consume_broadcast_enable: bool)

pub fn set_consume_message_orderly(&mut self, consume_message_orderly: bool)

pub fn set_retry_queue_nums(&mut self, retry_queue_nums: i32)

pub fn set_retry_max_times(&mut self, retry_max_times: i32)

pub fn set_group_retry_policy(&mut self, group_retry_policy: GroupRetryPolicy)

pub fn set_broker_id(&mut self, broker_id: u64)

pub fn set_which_broker_when_consume_slowly( &mut self, which_broker_when_consume_slowly: u64, )

pub fn set_notify_consumer_ids_changed_enable( &mut self, notify_consumer_ids_changed_enable: bool, )

pub fn set_group_sys_flag(&mut self, group_sys_flag: i32)

pub fn set_consume_timeout_minute(&mut self, consume_timeout_minute: i32)

pub fn set_subscription_data_set( &mut self, subscription_data_set: Option<HashSet<SimpleSubscriptionData>>, )

pub fn set_attributes( &mut self, attributes: HashMap<CheetahString, CheetahString>, )

pub fn set_lite_bind_topic(&mut self, lite_bind_topic: Option<CheetahString>)

Trait Implementations

impl Clone for SubscriptionGroupConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionGroupConfig

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

Formats the value using the given formatter.

impl Default for SubscriptionGroupConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SubscriptionGroupConfig

where SubscriptionGroupConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SubscriptionGroupConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.