/*
* JBoss, Home of Professional Open Source
* Copyright 2005, JBoss Inc., and individual contributors as indicated
* by the @authors tag. See the copyright.txt in the distribution for a
* full listing of individual contributors.
*
* This is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as
* published by the Free Software Foundation; either version 2.1 of
* the License, or (at your option) any later version.
*
* This software is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this software; if not, write to the Free
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
*/
package org.jbpm.pvm.internal.model;
import org.jbpm.api.listener.EventListener;
import org.jbpm.pvm.internal.util.ReflectUtil;
import org.jbpm.pvm.internal.wire.Descriptor;
/**
* @author Tom Baeyens
*/
public class EventListenerReference extends ProcessElementImpl {
private static final long serialVersionUID = 1L;
protected EventListener eventListener;
protected boolean isEventListenerStateful= false;
protected Descriptor eventListenerDescriptor;
/** does this action accept propagated events ? */
protected boolean isPropagationEnabled = false;
protected Continuation continuation = Continuation.SYNCHRONOUS;
/** does this action accept propagated events ? Default is false. */
public boolean isPropagationEnabled() {
return isPropagationEnabled;
}
/** does this action accept propagated events ? Default is false. */
public void setPropagationEnabled(boolean isPropagationEnabled) {
this.isPropagationEnabled = isPropagationEnabled;
}
public boolean isAsync() {
return Continuation.SYNCHRONOUS!=continuation;
}
// customized getters and setters ///////////////////////////////////////////
public EventListener getEventListener() {
if (eventListener!=null) {
return eventListener;
}
if (eventListenerDescriptor!=null) {
EventListener createdEventListener = (EventListener) ReflectUtil.instantiateUserCode(eventListenerDescriptor, processDefinition);
if (!isEventListenerStateful) {
eventListener = createdEventListener;
}
return createdEventListener;
}
return null;
}
// getters and setters //////////////////////////////////////////////////////
public Continuation getContinuation() {
return continuation;
}
public void setContinuation(Continuation continuation) {
this.continuation = continuation;
}
public void setEventListener(EventListener eventListener) {
this.eventListener = eventListener;
}
public boolean isEventListenerStateful() {
return isEventListenerStateful;
}
public void setEventListenerStateful(boolean isEventListenerStateful) {
this.isEventListenerStateful = isEventListenerStateful;
}
public Descriptor getEventListenerDescriptor() {
return eventListenerDescriptor;
}
public void setEventListenerDescriptor(Descriptor eventListenerDescriptor) {
this.eventListenerDescriptor = eventListenerDescriptor;
}
}