com.sh.wf.mq.activemq

类 ActiveMQProducer

java.lang.Object

com.sh.wf.mq.activemq.ActiveMQBase

com.sh.wf.mq.activemq.ActiveMQProducer

public class ActiveMQProducer
extends ActiveMQBase

Description: ActiveMQ消息中间件发布消息

Title:首亨软件 - TSS/CRM等

从以下版本开始:

2016年12月5日

版本:

3.0

作者:

江兴春

字段概要

从类继承的字段 com.sh.wf.mq.activemq.ActiveMQBase

DEFAULT_TOPIC

构造器概要

构造器

构造器和说明
ActiveMQProducer()
ActiveMQProducer(java.lang.String topicName)

方法概要

限定符和类型	方法和说明
static ActiveMQProducer	getInstance()
static ActiveMQProducer	getInstance(java.lang.String topicId)
static void	main(java.lang.String[] args)
void	processAfterGetConnecion(org.apache.activemq.pool.PooledConnection connection)
void	processConnect(javax.jms.Topic topic)
boolean	sendMessage(java.lang.String msg) 发送消息
boolean	sendMessageSecurity(java.lang.String msg) 发送消息，发送完毕后会马上关闭
boolean	sendObjectMessage(java.io.Serializable obj) 发送对象
boolean	sendObjectMessageSecurity(java.io.Serializable obj) 发送消息，发送完毕后会马上关闭

从类继承的方法 com.sh.wf.mq.activemq.ActiveMQBase

commit, connect, connect, disconnect, getTopicName, rollback, setTopicName

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

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

构造器详细资料

ActiveMQProducer

public ActiveMQProducer()

ActiveMQProducer

public ActiveMQProducer(java.lang.String topicName)

方法详细资料

getInstance

public static ActiveMQProducer getInstance()

getInstance

public static ActiveMQProducer getInstance(java.lang.String topicId)

processAfterGetConnecion

public void processAfterGetConnecion(org.apache.activemq.pool.PooledConnection connection)

sendMessage

public boolean sendMessage(java.lang.String msg)

发送消息

参数:

msg - String

返回:

boolean

sendObjectMessage

public boolean sendObjectMessage(java.io.Serializable obj)

发送对象

参数:

obj - 实现了Serializable可序列化的对象

返回:

boolean

sendMessageSecurity

public boolean sendMessageSecurity(java.lang.String msg)

发送消息，发送完毕后会马上关闭

参数:

msg - String

返回:

boolean

sendObjectMessageSecurity

public boolean sendObjectMessageSecurity(java.io.Serializable obj)

发送消息，发送完毕后会马上关闭

参数:

obj - Serializable

返回:

boolean

processConnect

public void processConnect(javax.jms.Topic topic)
                    throws javax.jms.JMSException

指定者:

processConnect 在类中 ActiveMQBase

抛出:

javax.jms.JMSException

main

public static void main(java.lang.String[] args)