com.aliyun.mns.client
类 CloudTopic

java.lang.Object
  com.aliyun.mns.client.CloudTopic

public class CloudTopic
extends Object

字段摘要

static org.apache.log4j.Logger

logger log4j object

构造方法摘要

protected

CloudTopic(String topicName, ServiceClient client, ServiceCredentials credentials, URI endpoint)

方法摘要

AsyncResult<Void>	asyncDelete(AsyncCallback<Void> callback) async delete topic
AsyncResult<TopicMeta>	asyncGetAttribute(AsyncCallback<TopicMeta> callback) async get topic attribute
AsyncResult<SubscriptionMeta>	asyncGetSubscriptionAttr(String subscriptionName, AsyncCallback<SubscriptionMeta> callback) async get subscription attribute
AsyncResult<TopicMessage>	asyncPublishMessage(TopicMessage msg, AsyncCallback<TopicMessage> callback) async publish message, we will do base64 encode for message body before publish it to MNS server.
AsyncResult<Void>	asyncSetAttribute(TopicMeta meta, AsyncCallback<Void> callback) async set topic attribute with given meta and callback object
AsyncResult<Void>	asyncSetSubscriptionAttr(SubscriptionMeta meta, AsyncCallback<Void> callback) async set subscription attribute
AsyncResult<String>	asyncSubscribe(SubscriptionMeta meta, AsyncCallback<String> callback) async subscribe this topic
AsyncResult<Void>	asyncUnsubscribe(String subscriptionName, AsyncCallback<Void> callback) async unsubscribe
String	create() create topic with default topic meta
String	create(TopicMeta meta) create topic with special topic meta
void	delete() delete topic
TopicMeta	getAttribute() get topic attribute
SubscriptionMeta	getSubscriptionAttr(String subscriptionName) get subscription attribute
String	getTopicURL() get topic url
PagingListResult<SubscriptionMeta>	listSubscriptions(String prefix, String marker, Integer retNumber) list topic subscription
PagingListResult<String>	listSubscriptionUrls(String prefix, String marker, Integer retNumber) list topic subscription
TopicMessage	publishMessage(TopicMessage msg) publish message to topic, we will do base64 encode for message body before publish it to MNS server.
void	setAttribute(TopicMeta meta) set tpoic attribute with given meta
void	setSubscriptionAttr(SubscriptionMeta meta) set subscription attribute
String	subscribe(SubscriptionMeta meta) subscribe this topic
void	unsubscribe(String subscriptionName) unsubscribe this topic

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

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

字段详细信息

logger

public static org.apache.log4j.Logger logger

log4j object

构造方法详细信息

CloudTopic

protected CloudTopic(String topicName,
                     ServiceClient client,
                     ServiceCredentials credentials,
                     URI endpoint)

参数：

topicName, - topic name

client, - ServiceClient object

credentials, - ServiceCredentials object

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

方法详细信息

getTopicURL

public String getTopicURL()

get topic url

返回：

topic url

create

public String create()

create topic with default topic meta

返回：

topic url

create

public String create(TopicMeta meta)

create topic with special topic meta

参数：

meta, - topic meta data

返回：

topic url

asyncSetAttribute

public AsyncResult<Void> asyncSetAttribute(TopicMeta meta,
                                           AsyncCallback<Void> callback)

async set topic attribute with given meta and callback object

参数：

meta, - tpoic meta data

callback, - user callback object

返回：

AsyncResult, you can wait result by AsyncResult if you want to do this

getAttribute

public TopicMeta getAttribute()

get topic attribute

返回：

topic meta data

setAttribute

public void setAttribute(TopicMeta meta)

set tpoic attribute with given meta

参数：

meta, - topic meta data

asyncGetAttribute

public AsyncResult<TopicMeta> asyncGetAttribute(AsyncCallback<TopicMeta> callback)

async get topic attribute

参数：

callback, - user callback object

返回：

AsyncResult, you can wait result by AsyncResult if you want to do this

delete

public void delete()

delete topic

asyncDelete

public AsyncResult<Void> asyncDelete(AsyncCallback<Void> callback)

async delete topic

参数：

callback, - user callback object

返回：

AsyncResult, you can wait result by AsyncResult if you want to do this

subscribe

public String subscribe(SubscriptionMeta meta)

subscribe this topic

参数：

meta, - SubscriptionMeta data

asyncSubscribe

public AsyncResult<String> asyncSubscribe(SubscriptionMeta meta,
                                          AsyncCallback<String> callback)

async subscribe this topic

参数：

meta, - SubscriptionMeta data

callback, - user callback object

返回：

AsyncResult, you can wait result by AsyncResult if you want to do this

setSubscriptionAttr

public void setSubscriptionAttr(SubscriptionMeta meta)

set subscription attribute

参数：

meta, - SubscriptionMeta data

asyncSetSubscriptionAttr

public AsyncResult<Void> asyncSetSubscriptionAttr(SubscriptionMeta meta,
                                                  AsyncCallback<Void> callback)

async set subscription attribute

参数：

meta, - SubscriptionMeta data

callback, - user callback object

返回：

AsyncResult, you can wait result by AsyncResult if you want to do this

getSubscriptionAttr

public SubscriptionMeta getSubscriptionAttr(String subscriptionName)

get subscription attribute

参数：

subscriptionName, - subscription name

返回：

SubscriptionMeta data

asyncGetSubscriptionAttr

public AsyncResult<SubscriptionMeta> asyncGetSubscriptionAttr(String subscriptionName,
                                                              AsyncCallback<SubscriptionMeta> callback)

async get subscription attribute

参数：

subscriptionName, - subscription name

callback, - user callback object

返回：

AsyncResult, you can wait result by AsyncResult if you want to do this

unsubscribe

public void unsubscribe(String subscriptionName)

unsubscribe this topic

参数：

subscriptionName, - subscription name

asyncUnsubscribe

public AsyncResult<Void> asyncUnsubscribe(String subscriptionName,
                                          AsyncCallback<Void> callback)

async unsubscribe

参数：

subscriptionName, - subscription name

callback, - user callback object

返回：

AsyncResult, you can wait result by AsyncResult if you want to do this

listSubscriptions

public PagingListResult<SubscriptionMeta> listSubscriptions(String prefix,
                                                            String marker,
                                                            Integer retNumber)

list topic subscription

参数：

prefix, - subscription name prefis

marker, - subscription start marker

retNumber, - return number

返回：

SubscriptionMeta list

listSubscriptionUrls

public PagingListResult<String> listSubscriptionUrls(String prefix,
                                                     String marker,
                                                     Integer retNumber)

list topic subscription

参数：

prefix, - subscription name prefis

marker, - subscription start marker

retNumber, - return number

返回：

subscription url list

publishMessage

public TopicMessage publishMessage(TopicMessage msg)

publish message to topic, we will do base64 encode for message body before publish it to MNS server. so, when you receive this message, you should do base64 decode before use it.

参数：

msg, - message，这里可以使用RawTopicMessage跟Base64TopicMessage作为向服务发消息的结构。 但我们推荐使用Base64TopicMessage，它会将消息体进行base64编码后再发送数据。 RawTopicMessage发送的数据是明文可读的串，我们不做任何改动。 如果你是用Base64TopicMessage发送消息的，那么在endpoint端收到的消息， 需要额外做一次base64解码，才能跟你发送的消息相匹配。

返回：

message

asyncPublishMessage

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

async publish message, we will do base64 encode for message body before publish it to MNS server. so, when you receive this message, you should do base64 decode before use it.

参数：

msg, - message，这里可以使用RawTopicMessage跟Base64TopicMessage作为向服务发消息的结构。 但我们推荐使用Base64TopicMessage，它会将消息体进行base64编码后再发送数据。 RawTopicMessage发送的数据是明文可读的串，我们不做任何改动。 如果你是用Base64TopicMessage发送消息的，那么在endpoint端收到的消息， 需要额外做一次base64解码，才能跟你发送的消息相匹配。

callback, - user callback object

返回：

AsyncResult, you can wait result by AsyncResult if you want to do this