?? stmsgsender.java
字號:
package com.gsoft.workflow.msgsender;
public class STMsgSender extends Thread{
MsgQueue msgque;
int count=0;
private String sDomain = "";
private String sUserName = "";
private String sPassword = "";
public STMsgSender(MsgQueue msgque)
{
this.msgque=msgque;
}
public void run()
{
MsgPackage msgpackage;
MsgSenderThread service = null;
try{
service= new MsgSenderThread();
Configuration rc = new Configuration("st.property");
sDomain = rc.getValue("domain");
sDomain = (sDomain == null)?"":sDomain.trim();
sUserName = rc.getValue("username");
sUserName = (sUserName == null)?"":sUserName.trim();
sPassword = rc.getValue("password");
sPassword = (sPassword == null)?"":sPassword.trim();
String a = "aaa";
//service.start("foa3.zktx.com", "robot/zktx", "password");
service.start(sDomain, sUserName, sPassword);
Thread.sleep(10000);
}
catch(Exception e){
e.printStackTrace();
}
//從隊列取出message
while(true)
{
if(!msgque.empty())
{
msgpackage=(MsgPackage)msgque.deq();
//System.out.println("get message package:"+msgpackage.toString());
try {
service.setIm(null);
service.callrevsolve(msgpackage.getSentTo(),msgpackage.getSendTime(), msgpackage.getMsgConetent(),msgpackage.MsgType());
count=0;
while(!service.isSent&&count<50)
{
Thread.sleep(500);
count++;
}
System.out.println("sented");
}
catch(Exception e)
{
e.printStackTrace();
service.stop();
}
}else
{
//System.out.println("Queue Empty!");
}
}
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -