com.aliyun.eventbridge20200401.models

类 CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters

java.lang.Object

com.aliyun.tea.TeaModel

com.aliyun.eventbridge20200401.models.CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters

封闭类:

CreateEventStreamingRequest

public static class CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters
extends com.aliyun.tea.TeaModel

字段概要

字段

限定符和类型	字段和说明
String	authType The authentication method.
String	bodyDataType example: JSON
String	filterSql The SQL statement that you want to use to filter messages.
String	filterType The method that you want to use to filter messages.
String	groupID The ID of the consumer group on the ApsaraMQ for RocketMQ instance.
String	instanceEndpoint The endpoint that you want to use to access the ApsaraMQ for RocketMQ instance.
String	instanceId The ID of the ApsaraMQ for RocketMQ instance.
String	instanceNetwork The network type.
String	instancePassword The password that you want to use to access the ApsaraMQ for RocketMQ instance.
String	instanceSecurityGroupId The ID of the security group to which the ApsaraMQ for RocketMQ instance belongs.
String	instanceType The type of the ApsaraMQ for RocketMQ instance.
String	instanceUsername The username that you want to use to access the ApsaraMQ for RocketMQ instance.
String	instanceVpcId The ID of the VPC to which the ApsaraMQ for RocketMQ instance belongs.
String	instanceVSwitchIds The ID of the vSwitch with which the ApsaraMQ for RocketMQ instance is associated.
String	network The network type.
String	offset The offset from which messages are consumed.
String	regionId The ID of the region where the ApsaraMQ for RocketMQ instance resides.
String	securityGroupId The security group ID of the cross-border task.
String	tag The tag that you want to use to filter messages.
Long	timestamp The timestamp that indicates the time from which messages are consumed.
String	topic The name of the topic on the ApsaraMQ for RocketMQ instance.
String	vpcId The VPC ID of the cross-border task.
String	vSwitchIds The vSwitch ID of the cross-border task.

构造器概要

构造器

构造器和说明
CreateEventStreamingRequestSourceSourceRocketMQParameters()

方法概要

限定符和类型	方法和说明
static CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	build(Map<String,?> map)
String	getAuthType()
String	getBodyDataType()
String	getFilterSql()
String	getFilterType()
String	getGroupID()
String	getInstanceEndpoint()
String	getInstanceId()
String	getInstanceNetwork()
String	getInstancePassword()
String	getInstanceSecurityGroupId()
String	getInstanceType()
String	getInstanceUsername()
String	getInstanceVpcId()
String	getInstanceVSwitchIds()
String	getNetwork()
String	getOffset()
String	getRegionId()
String	getSecurityGroupId()
String	getTag()
Long	getTimestamp()
String	getTopic()
String	getVpcId()
String	getVSwitchIds()
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setAuthType(String authType)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setBodyDataType(String bodyDataType)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setFilterSql(String filterSql)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setFilterType(String filterType)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setGroupID(String groupID)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstanceEndpoint(String instanceEndpoint)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstanceId(String instanceId)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstanceNetwork(String instanceNetwork)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstancePassword(String instancePassword)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstanceSecurityGroupId(String instanceSecurityGroupId)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstanceType(String instanceType)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstanceUsername(String instanceUsername)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstanceVpcId(String instanceVpcId)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setInstanceVSwitchIds(String instanceVSwitchIds)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setNetwork(String network)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setOffset(String offset)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setRegionId(String regionId)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setSecurityGroupId(String securityGroupId)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setTag(String tag)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setTimestamp(Long timestamp)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setTopic(String topic)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setVpcId(String vpcId)
CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters	setVSwitchIds(String vSwitchIds)

从类继承的方法 com.aliyun.tea.TeaModel

build, buildMap, confirmType, confirmType, parseObject, toMap, toMap, toModel, validate, validateParams

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

authType

@NameInMap(value="AuthType")
public String authType

The authentication method.

example:

ACL

bodyDataType

@NameInMap(value="BodyDataType")
public String bodyDataType

example:

JSON

filterSql

@NameInMap(value="FilterSql")
public String filterSql

The SQL statement that you want to use to filter messages.

example:

index > 10

filterType

@NameInMap(value="FilterType")
public String filterType

The method that you want to use to filter messages.

example:

Tag

groupID

@NameInMap(value="GroupID")
public String groupID

The ID of the consumer group on the ApsaraMQ for RocketMQ instance.

example:

GID_group1

instanceEndpoint

@NameInMap(value="InstanceEndpoint")
public String instanceEndpoint

The endpoint that you want to use to access the ApsaraMQ for RocketMQ instance.

example:

registry-vpc.cn-zhangjiakou.aliyuncs.com

instanceId

@NameInMap(value="InstanceId")
public String instanceId

The ID of the ApsaraMQ for RocketMQ instance.

example:

default_C56C360261515

instanceNetwork

@NameInMap(value="InstanceNetwork")
public String instanceNetwork

The network type. Valid values:

• PublicNetwork
• PrivateNetwork

example:

PublicNetwork

instancePassword

@NameInMap(value="InstancePassword")
public String instancePassword

The password that you want to use to access the ApsaraMQ for RocketMQ instance.

example:

admin

instanceSecurityGroupId

@NameInMap(value="InstanceSecurityGroupId")
public String instanceSecurityGroupId

The ID of the security group to which the ApsaraMQ for RocketMQ instance belongs.

example:

sg-m5edtu24f123456789

instanceType

@NameInMap(value="InstanceType")
public String instanceType

The type of the ApsaraMQ for RocketMQ instance.

example:

2

instanceUsername

@NameInMap(value="InstanceUsername")
public String instanceUsername

The username that you want to use to access the ApsaraMQ for RocketMQ instance.

example:

admin

instanceVSwitchIds

@NameInMap(value="InstanceVSwitchIds")
public String instanceVSwitchIds

The ID of the vSwitch with which the ApsaraMQ for RocketMQ instance is associated.

example:

vsw-m5ev8asdc6h123456789

instanceVpcId

@NameInMap(value="InstanceVpcId")
public String instanceVpcId

The ID of the VPC to which the ApsaraMQ for RocketMQ instance belongs.

example:

vpc-m5e3sv4b123456789

network

@NameInMap(value="Network")
public String network

The network type. Valid values: PublicNetwork and PrivateNetwork.

example:

PrivateNetwork

offset

@NameInMap(value="Offset")
public String offset

The offset from which messages are consumed. Valid values:

• CONSUME_FROM_LAST_OFFSET: Messages are consumed from the latest offset.
• CONSUME_FROM_FIRST_OFFSET: Messages are consumed from the earliest offset.
• CONSUME_FROM_TIMESTAMP: Messages are consumed from the offset at the specified point in time.

Default value: CONSUME_FROM_LAST_OFFSET.

example:

CONSUMEFROMLAST_OFFSET

regionId

@NameInMap(value="RegionId")
public String regionId

The ID of the region where the ApsaraMQ for RocketMQ instance resides.

example:

cn-qingdao

securityGroupId

@NameInMap(value="SecurityGroupId")
public String securityGroupId

The security group ID of the cross-border task.

example:

sg-m5edtu24f123456789

tag

@NameInMap(value="Tag")
public String tag

The tag that you want to use to filter messages.

example:

test

timestamp

@NameInMap(value="Timestamp")
public Long timestamp

The timestamp that indicates the time from which messages are consumed. This parameter is valid only if you set Offset to CONSUME_FROM_TIMESTAMP.

example:

1670656652009

topic

@NameInMap(value="Topic")
public String topic

The name of the topic on the ApsaraMQ for RocketMQ instance.

example:

Topic_publicRule_api_1667273421288

vSwitchIds

@NameInMap(value="VSwitchIds")
public String vSwitchIds

The vSwitch ID of the cross-border task.

example:

vsw-m5ev8asdc6h123456789

vpcId

@NameInMap(value="VpcId")
public String vpcId

The VPC ID of the cross-border task.

example:

vpc-m5e3sv4b123456789

构造器详细资料

CreateEventStreamingRequestSourceSourceRocketMQParameters

public CreateEventStreamingRequestSourceSourceRocketMQParameters()

方法详细资料

build

public static CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters build(Map<String,?> map)
                                                                                                   throws Exception

抛出:

Exception

setAuthType

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setAuthType(String authType)

getAuthType

public String getAuthType()

setBodyDataType

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setBodyDataType(String bodyDataType)

getBodyDataType

public String getBodyDataType()

setFilterSql

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setFilterSql(String filterSql)

getFilterSql

public String getFilterSql()

setFilterType

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setFilterType(String filterType)

getFilterType

public String getFilterType()

setGroupID

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setGroupID(String groupID)

getGroupID

public String getGroupID()

setInstanceEndpoint

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstanceEndpoint(String instanceEndpoint)

getInstanceEndpoint

public String getInstanceEndpoint()

setInstanceId

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstanceId(String instanceId)

getInstanceId

public String getInstanceId()

setInstanceNetwork

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstanceNetwork(String instanceNetwork)

getInstanceNetwork

public String getInstanceNetwork()

setInstancePassword

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstancePassword(String instancePassword)

getInstancePassword

public String getInstancePassword()

setInstanceSecurityGroupId

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstanceSecurityGroupId(String instanceSecurityGroupId)

getInstanceSecurityGroupId

public String getInstanceSecurityGroupId()

setInstanceType

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstanceType(String instanceType)

getInstanceType

public String getInstanceType()

setInstanceUsername

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstanceUsername(String instanceUsername)

getInstanceUsername

public String getInstanceUsername()

setInstanceVSwitchIds

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstanceVSwitchIds(String instanceVSwitchIds)

getInstanceVSwitchIds

public String getInstanceVSwitchIds()

setInstanceVpcId

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setInstanceVpcId(String instanceVpcId)

getInstanceVpcId

public String getInstanceVpcId()

setNetwork

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setNetwork(String network)

getNetwork

public String getNetwork()

setOffset

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setOffset(String offset)

getOffset

public String getOffset()

setRegionId

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setRegionId(String regionId)

getRegionId

public String getRegionId()

setSecurityGroupId

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setSecurityGroupId(String securityGroupId)

getSecurityGroupId

public String getSecurityGroupId()

setTag

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setTag(String tag)

getTag

public String getTag()

setTimestamp

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setTimestamp(Long timestamp)

getTimestamp

public Long getTimestamp()

setTopic

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setTopic(String topic)

getTopic

public String getTopic()

setVSwitchIds

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setVSwitchIds(String vSwitchIds)

getVSwitchIds

public String getVSwitchIds()

setVpcId

public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceRocketMQParameters setVpcId(String vpcId)

getVpcId

public String getVpcId()