return null;//这里会返回方法调用这句应该永远执行不到
解决方案 »
- java的jar包,急需,急需!
- Ehcache 页面缓存getCache()空指针
- jvm 绑定端口
- axis 客户端调用 xfire webservice 用DataHandler实现附件上传,可服务端获取到的DataHandler对象为空
- struts+spring集成出错问题
- 两年经验java期望薪水应该要多少 ???????
- spring 中嵌套事物如何配置
- HTML语法问题
- Weblogic 6.0y启动出错如下...
- Java集合知识总结
- 请问高手,垃圾回收器能不能回收Class.forName()动态加载类的内存?
- 用JBuilder7作EJB时,在datasources上右键import schema from database,弹出的界面中的选项jndi name在weblogic中是否应已经存在?
public MsgReply waitToReply(String mid) throws JMSException
{
long begin = System.currentTimeMillis();
begin += 60000;
while (begin > System.currentTimeMillis())
{
synchronized (messages)
{
try
{
//System.out.println("Session waitToReply() messages.wait()");
messages.wait();
for (int i = 0; i < messages.size(); i++)
{
Object obj = messages.get(i);
if (obj instanceof MsgReply)
{
if ( ( (MsgReply) obj).GetCorrelationID().equals(mid))
{
messages.removeElement(obj);
return (MsgReply) obj;
}
}
}
}
catch (InterruptedException e)//当捕获一个这样的异常时
{
throw new JMSException("break Exception!");//这里不返回方法调用,只结束本次循环,接着进入下次循环 }
} }
throw new JMSException("timeout while waiting for server reply"); }
{
long begin = System.currentTimeMillis();
begin += 60000;
while (begin > System.currentTimeMillis())
{
synchronized (messages)
{
try
{
//System.out.println("Session waitToReply() messages.wait()");
messages.wait();
for (int i = 0; i < messages.size(); i++)
{
Object obj = messages.get(i);
if (obj instanceof MsgReply)
{
if ( ( (MsgReply) obj).GetCorrelationID().equals(mid))
{
messages.removeElement(obj);
return (MsgReply) obj;
}
}
}
}
catch (InterruptedException e)//当捕获一个这样的异常时
{
public MsgReply waitToReply(String mid) throws JMSException
{
long begin = System.currentTimeMillis();
begin += 60000;
while (begin > System.currentTimeMillis())
{
synchronized (messages)
{
try
{
//System.out.println("Session waitToReply() messages.wait()");
messages.wait();
for (int i = 0; i < messages.size(); i++)
{
Object obj = messages.get(i);
if (obj instanceof MsgReply)
{
if ( ( (MsgReply) obj).GetCorrelationID().equals(mid))
{
messages.removeElement(obj);
return (MsgReply) obj;
}
}
}
}
catch (InterruptedException e)//当捕获一个这样的异常时
{ return null; }
} }
throw new JMSException("timeout while waiting for server reply"); }
}
} }
throw new JMSException("timeout while waiting for server reply"); }
{
long begin = System.currentTimeMillis();
begin += 60000;
while (begin > System.currentTimeMillis())
{
synchronized (messages)
{
try
{
//System.out.println("Session waitToReply() messages.wait()");
messages.wait();
for (int i = 0; i < messages.size(); i++)
{
Object obj = messages.get(i);
if (obj instanceof MsgReply)
{
if ( ( (MsgReply) obj).GetCorrelationID().equals(mid))
{
messages.removeElement(obj);
return (MsgReply) obj;
}
}
}
}
catch (InterruptedException e)//当捕获一个这样的异常时
{
return null;
}
} }
throw new JMSException("timeout while waiting for server reply"); }
1.throw new JMSException("break Exception!");//这里不返回方法调用,只结束本次循环,接着进入下次循环
或
2.return null;//这里会返回方法调用