你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

ServiceBusMessageBatch 类

  • java.lang.Object
    • com.azure.messaging.servicebus.ServiceBusMessageBatch

public final class ServiceBusMessageBatch

用于聚合 ServiceBusMessage 到单个大小受限的批处理的类。 发送到Azure 服务总线服务时,它被视为单个 AMQP 消息。

方法摘要

修饰符和类型 方法和描述
int getCount()

获取批中的 的 ServiceBusMessage 编号。

int getMaxSizeInBytes()

获取 的最大大小(以字节 ServiceBusMessageBatch为单位)。

int getSizeInBytes()

获取 的大小( ServiceBusMessageBatch 以字节为单位)。

boolean tryAddMessage(ServiceBusMessage serviceBusMessage)

尝试将 添加到 ServiceBusMessage 批处理。

方法继承自 java.lang.Object

方法详细信息

getCount

public int getCount()

获取批中的 的 ServiceBusMessage 编号。

Returns:

批中的 的 ServiceBusMessage 编号。

getMaxSizeInBytes

public int getMaxSizeInBytes()

获取 的最大大小(以字节 ServiceBusMessageBatch为单位)。

Returns:

的最大大小(以字节 ServiceBusMessageBatch为单位)。

getSizeInBytes

public int getSizeInBytes()

获取 的大小( ServiceBusMessageBatch 以字节为单位)。

Returns:

ServiceBusMessageBatch 的大小(以字节为单位)。

tryAddMessage

public boolean tryAddMessage(ServiceBusMessage serviceBusMessage)

尝试将 添加到 ServiceBusMessage 批处理。

此方法不是线程安全的;在使用多个线程添加消息时,请确保同步方法访问。

Parameters:

serviceBusMessage - 要添加到批处理的 ServiceBusMessage

Returns:

true 如果消息可以添加到批处理中,则为 ; false 如果事件太大而无法容纳批处理,则为 。

适用于