public void sendMsgToTopic(String message){
String topicName = queueName;
if (topicName == null) {
logger.error("Must specify topic name");
}
try{
TopicConnectionFactory factory = new TibjmsTopicConnectionFactory(serverUrl);
TopicConnection connection = factory.createTopicConnection(userName, password);
TopicSession session = connection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic(topicName);
TopicPublisher publisher =session.createPublisher(topic);
TextMessage textMessage = session.createTextMessage();
textMessage.setText(message);
//publisher.publish(textMessage);
logger.debug("Message has been successfully sent to "+topicName);
logger.debug("Message Content is "+textMessage.getText());
}catch(JMSException exp){
exp.printStackTrace();
}
}
/**
*
* @param message
*/
public void sendMsgToQueue(String message) {
if (queueName == null) {
logger.error("Must specify queue name");
}
try {
QueueConnectionFactory factory = new TibjmsQueueConnectionFactory(serverUrl);
QueueConnection connection = factory.createQueueConnection(userName, password);
QueueSession session = connection.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
logger.info("The URL of queue server is "+serverUrl);
logger.info("The queue Name is "+queueName);
Queue queue = session.createQueue(queueName);
QueueSender sender = session.createSender(queue);
// set message to queue
TextMessage textMessage = session.createTextMessage();
textMessage.setText(message);
//sender.send(textMessage);
logger.debug("Message has been successfully sent to "+queueName);
logger.debug("Message Content is "+textMessage.getText());
connection.close();
} catch (JMSException e) {
e.printStackTrace();
System.exit(0);
}
}
分享到:
相关推荐
1. 创建多 Task,为每个Task 创建私有的Message Queue,每个Task 只通过自己的私有Message Queue 接收消息;Task 间消息通信通过向对方私有Message Queue 发送消息完 成。 2. Task1:管理Task。负责系统启动时同步...
在FB上一次发送多条消息-于2019年4月审查“ FB Message Sender”允许在Facebook上单击一次发送多条消息! 例如,只需单击一下,您就可以向您的朋友发送1000条消息,以创建1000个不同的对话! 如果您想保持对话私密性...
mirrorop sender安卓破解版是一款非常实用的闪电传输文件应用。使用mirrorop sender apk能够实现多屏互动,多平台之间的文件传输、分享,传输速度更快! 注:资源来源于网络。
TCP/IP sender and receiver and "TCP ping" application
Mirrorop无线投屏软件
Mms Message Sender for Andriod.
了解C#中的预定义事件处理机制 在写代码前我们先来熟悉.net框架... 注意这里的参数,前者是一个对象(其实这里传递的是对象的引用,如果是button1的click事件则sender就是button1),后面是包含事件数据的类的基类。
This is an example of how to send message using socket
UDP sender,通过UDP协议发送信息的软件。
So, the program is able to verifier will detect the attack of Adversary, which is placed in between Sender and Verifier and may change either the original message, or encrypted digest, or both
mirrorop sender PC发射端
数据包发送工具packetSender
udpsender主要用于udp测试和压力测试,自定义EPS,支持syslog和snmp协议。 使用方便,快捷,自定义性强
浅析C#中object_sender与EventArgs_e
语言:English,English (UK),English (United States),español,español (Latinoamérica),português (Brasil),português (Portugal) 发送whatsapp:trade_mark:消息而无需添加联系人,只需选择号码 ...
Sender-receiver 消息 ,还是老话,学习JMS和activemq必看资料一直
1.QQ:513187410 2.保证无毒 3.简单,方便,实用 4.实例可以自行改用 5.如有非法,本人无法律责任,由改动代码人负责! 6.需要更多本人作品,查找标签“朱建强” 7.请下载,杀毒后再使用!
即时通信软件,暂时只有群聊功能,还没实现文件发送和截图等功能
udpsender,udp发送工具,UDPSender UDP发包工具,支持自动及手动发送,可以进行压力测试等
Mirroring360 Sender Chrome应用程序使任何演示者均可将其Chromebook或计算机屏幕无线镜像到另一台PC或Mac。 您将需要在接收计算机上安装单独的Mirroring360 Receiver软件,该软件可以从www.mirroring360.com获得。...