|
||||||||||
上一个 下一个 | 框架 无框架 |
com.taobao.metamorphosis.client 中 Shutdownable 的使用 |
---|
com.taobao.metamorphosis.client 中 Shutdownable 的子接口 | |
---|---|
interface |
MessageSessionFactory
消息会话工厂,meta客户端的主接口,推荐一个应用只使用一个MessageSessionFactory |
interface |
TopicBrowser
Allows browsing of messages on a Topic. |
interface |
XAMessageSessionFactory
用于创建XA消息会话的工厂 |
实现 Shutdownable 的 com.taobao.metamorphosis.client 中的类 | |
---|---|
class |
MetaMessageSessionFactory
消息会话工厂,配置的优先级,优先使用传入的MetaClientConfig中的配置项, 其次使用MetaClientConfig中的zkConfig配置的zk中的选项,如果都没有,则从diamond获取zk地址来获取配置项 |
class |
MetaTopicBrowser
TopicBrowser implementation. |
class |
XAMetaMessageSessionFactory
支持事务的XA消息工厂 |
类型参数类型为 Shutdownable 的 com.taobao.metamorphosis.client 中的方法 | ||
---|---|---|
protected
|
MetaMessageSessionFactory.addChild(T child)
|
|
|
MetaMessageSessionFactory.removeChild(T child)
删除子会话 |
返回变量类型为 Shutdownable 的类型的 com.taobao.metamorphosis.client 中的方法 | |
---|---|
CopyOnWriteArrayList<Shutdownable> |
MetaMessageSessionFactory.getChildren()
返回此工厂创建的所有子对象,如生产者、消费者等 |
com.taobao.metamorphosis.client.consumer 中 Shutdownable 的使用 |
---|
com.taobao.metamorphosis.client.consumer 中 Shutdownable 的子接口 | |
---|---|
interface |
MessageConsumer
消息消费者,线程安全,推荐复用 |
interface |
RecoverManager
消费端的Recover管理器 |
实现 Shutdownable 的 com.taobao.metamorphosis.client.consumer 中的类 | |
---|---|
class |
AbstractRecoverManager
|
class |
RecoverStorageManager
Recover存储管理器 |
class |
SimpleMessageConsumer
消息消费者基类 |
com.taobao.metamorphosis.client.extension 中 Shutdownable 的使用 |
---|
com.taobao.metamorphosis.client.extension 中 Shutdownable 的子接口 | |
---|---|
interface |
AsyncMessageSessionFactory
用于创建异步单向发送消息的会话工厂. |
interface |
BroadcastMessageSessionFactory
广播消息会话工厂,使用这个创建的Consumer在同一分组内的每台机器都能收到同一条消息, 推荐一个应用只使用一个MessageSessionFactory |
interface |
ExtMessageSessionFactory
一个扩展的Meta会话工厂,提供一些扩展功能. |
interface |
OrderedMessageSessionFactory
消息会话工厂,meta客户端的主接口,推荐一个应用只使用一个. |
实现 Shutdownable 的 com.taobao.metamorphosis.client.extension 中的类 | |
---|---|
class |
AsyncMetaMessageSessionFactory
用于创建异步单向发送消息的会话工厂. |
class |
ExtMetaMessageSessionFactory
一个扩展的Meta会话工厂,提供一些扩展功能. |
class |
MetaBroadcastMessageSessionFactory
广播消息会话工厂,使用这个创建的Consumer在同一分组内的每台机器都能收到同一条消息, 推荐一个应用只使用一个MessageSessionFactory |
class |
OrderedMetaMessageSessionFactory
消息会话工厂,meta客户端的主接口,推荐一个应用只使用一个. |
com.taobao.metamorphosis.client.extension.consumer 中 Shutdownable 的使用 |
---|
实现 Shutdownable 的 com.taobao.metamorphosis.client.extension.consumer 中的类 | |
---|---|
class |
RecoverNotifyManager
Recover存储管理器,需要recover的消息存到notify. |
com.taobao.metamorphosis.client.extension.producer 中 Shutdownable 的使用 |
---|
com.taobao.metamorphosis.client.extension.producer 中 Shutdownable 的子接口 | |
---|---|
interface |
AsyncMessageProducer
异步发送消息的生产者. |
interface |
MessageRecoverManager
消息暂存和recover管理器的抽象 |
实现 Shutdownable 的 com.taobao.metamorphosis.client.extension.producer 中的类 | |
---|---|
class |
AsyncMetaMessageProducer
异步单向发送消息给服务器的生产者实现. |
class |
LocalMessageStorageManager
消息缓存在本地磁盘,并定期或手动recover |
class |
OrderedLocalMessageStorageManager
针对顺序消息做了特殊处理的LocalMessageStorageManager |
class |
OrderedMessageProducer
有序消息生产者的实现类,需要按照消息内容(例如某个id)散列到固定分区并要求有序的场景中使用. |
com.taobao.metamorphosis.client.producer 中 Shutdownable 的使用 |
---|
com.taobao.metamorphosis.client.producer 中 Shutdownable 的子接口 | |
---|---|
interface |
MessageProducer
消息生产者,线程安全,推荐复用 |
interface |
XAMessageProducer
支持XA事务的消息生产者 |
实现 Shutdownable 的 com.taobao.metamorphosis.client.producer 中的类 | |
---|---|
class |
SimpleMessageProducer
消费生产者实现 |
class |
SimpleXAMessageProducer
XA消息生产者的实现类 |
com.taobao.metamorphosis.metaslave 中 Shutdownable 的使用 |
---|
实现 Shutdownable 的 com.taobao.metamorphosis.metaslave 中的类 | |
---|---|
class |
SlaveMetaMessageSessionFactory
|
|
||||||||||
上一个 下一个 | 框架 无框架 |