org.jbpm.task.service.jms
Class JMSTaskClientConnector

java.lang.Object
  org.jbpm.task.service.jms.JMSTaskClientConnector

All Implemented Interfaces:

TaskClientConnector

public class JMSTaskClientConnector
extends Object
implements TaskClientConnector

Nested Class Summary

protected class

JMSTaskClientConnector.Responder

Field Summary

protected javax.jms.QueueConnection	connection
protected AtomicInteger	counter
protected BaseJMSHandler	handler
protected String	name
protected javax.jms.Queue	queue
protected javax.jms.Queue	responseQueue
protected javax.jms.QueueSession	session

Constructor Summary

JMSTaskClientConnector(String name, BaseJMSHandler handler, Properties connectionProperties, Context context)

Method Summary

boolean	connect()
boolean	connect(String address, int port)
void	disconnect()
AtomicInteger	getCounter()
BaseHandler	getHandler()
String	getName()
void	write(Object object)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

connection

protected javax.jms.QueueConnection connection

session

protected javax.jms.QueueSession session

queue

protected javax.jms.Queue queue

responseQueue

protected javax.jms.Queue responseQueue

handler

protected final BaseJMSHandler handler

name

protected final String name

counter

protected AtomicInteger counter

Constructor Detail

JMSTaskClientConnector

public JMSTaskClientConnector(String name,
                              BaseJMSHandler handler,
                              Properties connectionProperties,
                              Context context)

Method Detail

connect

public boolean connect(String address,
                       int port)

Specified by:

connect in interface TaskClientConnector

connect

public boolean connect()

Specified by:

connect in interface TaskClientConnector

disconnect

public void disconnect()

Specified by:

disconnect in interface TaskClientConnector

write

public void write(Object object)

Specified by:

write in interface TaskClientConnector

getCounter

public AtomicInteger getCounter()

Specified by:

getCounter in interface TaskClientConnector

getHandler

public BaseHandler getHandler()

Specified by:

getHandler in interface TaskClientConnector

getName

public String getName()

Specified by:

getName in interface TaskClientConnector