类的使用
org.redkale.mq.spi.MessageAgent

使用MessageAgent的程序包

程序包	说明
org.redkale.boot	提供Redkale服务器的启动、初始化和加载功能
org.redkale.mq.spi
org.redkale.net.http	HTTP协议包,提供HTTP协议服务器
org.redkale.net.sncp	SNCP协议包,提供SNCP协议服务器

org.redkale.boot中MessageAgent的使用

类型参数类型为MessageAgent的org.redkale.boot中的字段

修饰符和类型	字段	说明
protected Map<String,MessageAgent>	NodeServer.messageAgents
protected Map<String,MessageAgent>	NodeServer.sncpRemoteAgents

返回MessageAgent的org.redkale.boot中的方法

修饰符和类型	方法	说明
protected MessageAgent	NodeServer.getMessageAgent(AnyValue serviceConf)

org.redkale.mq.spi中MessageAgent的使用

返回MessageAgent的org.redkale.mq.spi中的方法

修饰符和类型	方法	说明
MessageAgent	MessageModuleEngine.findMessageAgent(String mqName)
MessageAgent	MessageClient.getMessageAgent()

参数类型为MessageAgent的org.redkale.mq.spi中的构造器

构造器	说明
MessageClient(String protocol, MessageAgent messageAgent, String appRespTopic)
MessageConsumerWrapper(MessageAgent messageAgent, MessageConsumer<T> consumer, String regexTopic, ConvertType convertType)

org.redkale.net.http中MessageAgent的使用

声明为MessageAgent的org.redkale.net.http中的字段

修饰符和类型	字段	说明
protected MessageAgent	WebSocketNode.messageAgent
protected MessageAgent	WebSocketServlet.messageAgent

返回MessageAgent的org.redkale.net.http中的方法

修饰符和类型	方法	说明
MessageAgent	WebSocketNode.getMessageAgent()

参数类型为MessageAgent的org.redkale.net.http中的方法

修饰符和类型	方法	说明
<S extends WebSocket,T extends WebSocketServlet> T	HttpServer.addRestWebSocketServlet(ClassLoader classLoader, Class<S> webSocketType, MessageAgent messageAgent, String prefix, AnyValue conf)	添加WebSocketServlet
static <T extends WebSocketServlet> T	Rest.createRestWebSocketServlet(ClassLoader classLoader, Class<? extends WebSocket> webSocketType, MessageAgent messageAgent)

org.redkale.net.sncp中MessageAgent的使用

声明为MessageAgent的org.redkale.net.sncp中的字段

修饰符和类型	字段	说明
protected MessageAgent	SncpRemoteInfo.messageAgent

参数类型为MessageAgent的org.redkale.net.sncp中的方法

修饰符和类型	方法	说明
static <T extends Service> T	Sncp.createLocalService(RedkaleClassLoader classLoader, String name, Class<T> serviceImplClass, org.redkale.asm.AsmMethodBoost methodBoost, ResourceFactory resourceFactory, SncpRpcGroups sncpRpcGroups, SncpClient client, MessageAgent agent, String remoteGroup, AnyValue conf)	创建本地模式Service实例
static <T extends Service> T	Sncp.createRemoteService(ClassLoader classLoader, String name, Class<T> serviceTypeOrImplClass, org.redkale.asm.AsmMethodBoost methodBoost, ResourceFactory resourceFactory, SncpRpcGroups sncpRpcGroups, SncpClient client, MessageAgent agent, String remoteGroup, AnyValue conf)
static <T extends Service> SncpRemoteInfo	Sncp.createSncpRemoteInfo(String resourceName, Class<T> resourceServiceType, Class<T> serviceImplClass, ProtobufConvert convert, SncpRpcGroups sncpRpcGroups, SncpClient sncpClient, MessageAgent messageAgent, String remoteGroup)