com.aliyun.mq.http

类 MQProducer

java.lang.Object

com.aliyun.mq.http.MQProducer

public class MQProducer
extends Object

构造器概要

构造器

限定符	构造器和说明
protected	MQProducer(String instanceId, String topicName, com.aliyun.mq.http.common.http.ServiceClient client, com.aliyun.mq.http.common.auth.ServiceCredentials credentials, URI endpoint)

方法概要

限定符和类型	方法和说明
AsyncResult<TopicMessage>	asyncPublishMessage(TopicMessage msg, AsyncCallback<TopicMessage> callback) async publish message to topic so, when you receive this message, you should do base64 decode before use it.
String	getInstanceId()
String	getTopicName()
TopicMessage	publishMessage(TopicMessage msg) publish message to topic
String	toString()

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

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

构造器详细资料

MQProducer

protected MQProducer(String instanceId,
                     String topicName,
                     com.aliyun.mq.http.common.http.ServiceClient client,
                     com.aliyun.mq.http.common.auth.ServiceCredentials credentials,
                     URI endpoint)

参数:

instanceId, - instance id

topicName, - topic name

client, - ServiceClient object

credentials, - ServiceCredentials object

endpoint, - user mq http endpoint, ie: http://uid.mqrest.region.aliyuncs.com/

方法详细资料

getTopicName

public String getTopicName()

getInstanceId

public String getInstanceId()

publishMessage

public TopicMessage publishMessage(TopicMessage msg)
                            throws ServiceException,
                                   ClientException

publish message to topic

参数:

msg - message

返回:

message from server

抛出:

ServiceException - Exception from server

ClientException - Exception from client

asyncPublishMessage

public AsyncResult<TopicMessage> asyncPublishMessage(TopicMessage msg,
                                                     AsyncCallback<TopicMessage> callback)

async publish message to topic so, when you receive this message, you should do base64 decode before use it.

参数:

msg - message

callback, - user callback object

返回:

AsyncResult, you can get the result blocked.

toString

public String toString()

覆盖:

toString 在类中 Object