| java.lang.Object
 de.danet.an.workflow.ejbs.util.QueuerEJB
| QueuerEJB | | public class QueuerEJB implements SessionBean(Code) | | This class provides a method to queue an event in the internal
event queue or a tool invocation in the tool invocation queue. We
use a session bean for this to enable pooling of queue connections
(as a result of pooling stateless session beans) by the
container. Opening the queue connections in e.g. entity beans
results in too many connections being open.
author:
Michael Lipp
version:
$Revision: 1.9 $ |
| broadcastChannelMessage | | public void broadcastChannelMessage(String processKey, String channel, Map data)(Code) | | Broadcast the given channel message.
Parameters:
processKey - the process key
Parameters:
channel - the channel
Parameters:
message - the message |
| closeChannels | | public void closeChannels(String processKey)(Code) | | Send a message about process completion and cleanup in queue.
Parameters:
processKey - the process key |
| ejbActivate | | public void ejbActivate()(Code) | | The activate method is called when the instance is activated from its
"passive" state. The instance should acquire any resource that it has
released earlier in the ejbPassivate() method.
See Also: javax.ejb.SessionBean |
| ejbCreate | | public void ejbCreate() throws CreateException(Code) | | Create an new instance of the EJB.
throws:
CreateException - if the EJB can not be create. |
| ejbPassivate | | public void ejbPassivate()(Code) | | The passivate method is called before the instance enters the
"passive" state. The instance should release any resources that it
can re-acquire later in the ejbActivate() method.
See Also: javax.ejb.SessionBean |
| ejbRemove | | public void ejbRemove()(Code) | | A container invokes this method before it ends the life of the session
object. This happens as a result of a client's invoking a remove
operation, or when a container decides to terminate the session object
after a timeout.
See Also: javax.ejb.SessionBean |
| lookForChannelMessage | | public Map lookForChannelMessage(String processKey, String channel)(Code) | | Looks for a message for the given process and channel on the
channel in queue and if found return it.
Parameters:
processKey - the process key
Parameters:
channel - the channel the message or null |
| queue | | public void queue(DefaultAuditEvent evt, int requeued)(Code) | | Queue the given event with a requeued count.
Parameters:
evt - the WfAuditEvent
Parameters:
requeued - the number of times this has been queued |
| queueChannelMessage | | public void queueChannelMessage(String processKey, String channel, Map message)(Code) | | Queue the given channel message.
Parameters:
processKey - the process key
Parameters:
channel - the channel
Parameters:
message - the message |
| queueToolInvocation | | public void queueToolInvocation(Map args)(Code) | | Queue the given invocation.
Parameters:
args - the invocation arguments |
| setSessionContext | | public void setSessionContext(SessionContext context)(Code) | | Set the associated session context. The container calls this method
after the instance creation.
See Also: javax.ejb.SessionBean
Parameters:
context - a SessionContext interface for the instance |
|
|