131132133134135136137138139140141
Message[] allMessages = queue_.getAllMessages(false); for (int i = 0; i < allMessages.length; i++) { Message message = allMessages[i]; message.dispose(); } } catch (InterruptedException e) { // should not happen as above call does not wait. }
761762763764765766767768769770771
try { return match_ReadLock(_evaluationContext, _event); } finally { _event.dispose(); } } finally { _evaluationContext.dispose(); }
794795796797798799800801802803804
820821822823824825826827828829830
156157158159160161162163164165166
request.arguments(_args); } finally { if (_mesg != null) { _mesg.dispose(); } } } catch (InterruptedException e) { // ignore
126127128129130131132133134135136
try { return deliverMessageWithRetry(_message); } finally { _message.dispose(); } } return false; }
96979899100101102103104105106
{ return _event.toAny(); } finally { _event.dispose(); } } catch (InterruptedException e) { logger_.error("interrupted", e);
125126127128129130131132133134135
return _message.toAny(); } finally { _message.dispose(); } } return sUndefinedAny; }
161162163164165166167168169170171
919293949596979899100101