01: /*
02: * JacORB - a free Java ORB
03: *
04: * Copyright (C) 1999-2004 Gerald Brose
05: *
06: * This library is free software; you can redistribute it and/or
07: * modify it under the terms of the GNU Library General Public
08: * License as published by the Free Software Foundation; either
09: * version 2 of the License, or (at your option) any later version.
10: *
11: * This library is distributed in the hope that it will be useful,
12: * but WITHOUT ANY WARRANTY; without even the implied warranty of
13: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14: * Library General Public License for more details.
15: *
16: * You should have received a copy of the GNU Library General Public
17: * License along with this library; if not, write to the Free
18: * Software Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
19: *
20: */
21:
22: package org.jacorb.notification.engine;
23:
24: import org.jacorb.notification.interfaces.Message;
25:
26: /**
27: * @author Alphonse Bendt
28: * @version $Id: AbstractMessageTask.java,v 1.3 2005/04/27 10:48:40 alphonse.bendt Exp $
29: */
30: public abstract class AbstractMessageTask extends AbstractTask {
31: private Message message_;
32:
33: /**
34: * set the Message for this Task to use.
35: */
36: public void setMessage(Message message) {
37: if (message_ != null) {
38: throw new RuntimeException("remove old first");
39: }
40:
41: message_ = message;
42: }
43:
44: public Message removeMessage() {
45: Message _mesg = message_;
46:
47: message_ = null;
48:
49: return _mesg;
50: }
51:
52: public Message copyMessage() {
53: return (Message) message_.clone();
54: }
55:
56: protected boolean isRunnable() {
57: return !message_.isInvalid();
58: }
59:
60: protected void checkInterrupt() throws InterruptedException {
61: super .checkInterrupt();
62:
63: if (message_.isInvalid()) {
64: throw new InterruptedException();
65: }
66: }
67:
68: protected Message getMessage() {
69: return message_;
70: }
71:
72: public void dispose() {
73: if (message_ != null) {
74: message_.dispose();
75: }
76:
77: super .dispose();
78: }
79:
80: public void reset() {
81: message_ = null;
82: }
83: }
|